v1

type BroadcastMessage struct {
	Request        *totem.RPC          `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	TargetSelector *v1.ClusterSelector `protobuf:"bytes,2,opt,name=targetSelector,proto3" json:"targetSelector,omitempty"`
	// contains filtered or unexported fields
}

type BroadcastReply struct {
	Ref   *v1.Reference `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	Reply *totem.RPC    `protobuf:"bytes,2,opt,name=reply,proto3" json:"reply,omitempty"`
	// contains filtered or unexported fields
}

type BroadcastReplyList struct {
	Responses []*BroadcastReply `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

type DelegateClient interface {
	// A synchronous request-response RPC sent to a single client.
	Request(ctx context.Context, in *DelegatedMessage, opts ...grpc.CallOption) (*totem.RPC, error)
	// A best-effort broadcast sent to all connected clients, with an
	// optional target filter.
	Broadcast(ctx context.Context, in *BroadcastMessage, opts ...grpc.CallOption) (*BroadcastReplyList, error)
}

type DelegateServer interface {
	// A synchronous request-response RPC sent to a single client.
	Request(context.Context, *DelegatedMessage) (*totem.RPC, error)
	// A best-effort broadcast sent to all connected clients, with an
	// optional target filter.
	Broadcast(context.Context, *BroadcastMessage) (*BroadcastReplyList, error)
	// contains filtered or unexported methods
}

type DelegatedMessage struct {
	Request *totem.RPC    `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Target  *v1.Reference `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

type DelegatedMessageReply struct {
	Reply  *totem.RPC     `protobuf:"bytes,1,opt,name=reply,proto3" json:"reply,omitempty"`
	Status *status.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type EventType int32

type StreamClient interface {
	Connect(ctx context.Context, opts ...grpc.CallOption) (Stream_ConnectClient, error)
	// Used for implementation-specific events. No guarantees are made about
	// whether events will be sent or when.
	Notify(ctx context.Context, in *StreamEvent, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

type StreamEvent struct {
	Type          EventType `protobuf:"varint,1,opt,name=type,proto3,enum=stream.EventType" json:"type,omitempty"`
	CorrelationId string    `protobuf:"bytes,2,opt,name=correlationId,proto3" json:"correlationId,omitempty"`
	// contains filtered or unexported fields
}

type StreamServer interface {
	Connect(Stream_ConnectServer) error
	// Used for implementation-specific events. No guarantees are made about
	// whether events will be sent or when.
	Notify(context.Context, *StreamEvent) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

type Stream_ConnectClient interface {
	Send(*totem.RPC) error
	Recv() (*totem.RPC, error)
	grpc.ClientStream
}

type Stream_ConnectServer interface {
	Send(*totem.RPC) error
	Recv() (*totem.RPC, error)
	grpc.ServerStream
}

type UnimplementedDelegateServer struct {
}

type UnimplementedStreamServer struct {
}

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

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