hedgeproto

type HedgeClient ¶

type HedgeClient interface {
	Send(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[Payload, Payload], error)
	Broadcast(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[Payload, Payload], error)
	SoSWrite(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[Payload, Payload], error)
	SoSRead(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[Payload, Payload], error)
	SoSClose(ctx context.Context, in *Payload, opts ...grpc.CallOption) (*Payload, error)
}

HedgeClient is the client API for Hedge service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewHedgeClient(cc grpc.ClientConnInterface) HedgeClient

type HedgeServer ¶

type HedgeServer interface {
	Send(grpc.BidiStreamingServer[Payload, Payload]) error
	Broadcast(grpc.BidiStreamingServer[Payload, Payload]) error
	SoSWrite(grpc.BidiStreamingServer[Payload, Payload]) error
	SoSRead(grpc.BidiStreamingServer[Payload, Payload]) error
	SoSClose(context.Context, *Payload) (*Payload, error)
	// contains filtered or unexported methods
}

HedgeServer is the server API for Hedge service. All implementations must embed UnimplementedHedgeServer for forward compatibility.

type Hedge_BroadcastClient ¶

type Hedge_BroadcastClient = grpc.BidiStreamingClient[Payload, Payload]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Hedge_BroadcastServer ¶

type Hedge_BroadcastServer = grpc.BidiStreamingServer[Payload, Payload]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Hedge_SendClient ¶

type Hedge_SendClient = grpc.BidiStreamingClient[Payload, Payload]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Hedge_SendServer ¶

type Hedge_SendServer = grpc.BidiStreamingServer[Payload, Payload]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Hedge_SoSReadClient ¶

type Hedge_SoSReadClient = grpc.BidiStreamingClient[Payload, Payload]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Hedge_SoSReadServer ¶

type Hedge_SoSReadServer = grpc.BidiStreamingServer[Payload, Payload]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Hedge_SoSWriteClient ¶

type Hedge_SoSWriteClient = grpc.BidiStreamingClient[Payload, Payload]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Hedge_SoSWriteServer ¶

type Hedge_SoSWriteServer = grpc.BidiStreamingServer[Payload, Payload]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Payload ¶

type Payload struct {
	Meta map[string]string `` /* 135-byte string literal not displayed */
	Data []byte            `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Payload) Descriptor() ([]byte, []int)

func (x *Payload) GetData() []byte

func (x *Payload) GetMeta() map[string]string

func (*Payload) ProtoMessage()

func (x *Payload) ProtoReflect() protoreflect.Message

func (x *Payload) Reset()

func (x *Payload) String() string

type UnimplementedHedgeServer ¶

type UnimplementedHedgeServer struct{}

UnimplementedHedgeServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedHedgeServer) Broadcast(grpc.BidiStreamingServer[Payload, Payload]) error

func (UnimplementedHedgeServer) Send(grpc.BidiStreamingServer[Payload, Payload]) error

func (UnimplementedHedgeServer) SoSClose(context.Context, *Payload) (*Payload, error)

func (UnimplementedHedgeServer) SoSRead(grpc.BidiStreamingServer[Payload, Payload]) error

func (UnimplementedHedgeServer) SoSWrite(grpc.BidiStreamingServer[Payload, Payload]) error

type UnsafeHedgeServer ¶

type UnsafeHedgeServer interface {
	// contains filtered or unexported methods
}

UnsafeHedgeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HedgeServer will result in compilation errors.