cluster

type Ack struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type Cluster struct {
	Peers *sync.Map

	UnimplementedClusterServer
	// contains filtered or unexported fields
}

type ClusterClient interface {
	Ping(ctx context.Context, in *PingReq, opts ...grpc.CallOption) (*PingRsp, error)
	Sync(ctx context.Context, opts ...grpc.CallOption) (Cluster_SyncClient, error)
}

type ClusterServer interface {
	Ping(context.Context, *PingReq) (*PingRsp, error)
	Sync(Cluster_SyncServer) error
	// contains filtered or unexported methods
}

type Cluster_SyncClient interface {
	Send(*Event) error
	Recv() (*Ack, error)
	grpc.ClientStream
}

type Cluster_SyncServer interface {
	Send(*Ack) error
	Recv() (*Event, error)
	grpc.ServerStream
}

type Event struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Event:
	//
	//	*Event_Subscribe
	//	*Event_Message
	//	*Event_Unsubscribe
	Event isEvent_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

type Event_Message struct {
	Message *Message `protobuf:"bytes,3,opt,name=message,proto3,oneof"`
}

type Event_Subscribe struct {
	Subscribe *Subscribe `protobuf:"bytes,2,opt,name=subscribe,proto3,oneof"`
}

type Event_Unsubscribe struct {
	Unsubscribe *Unsubscribe `protobuf:"bytes,4,opt,name=unsubscribe,proto3,oneof"`
}

type Message struct {
	Topic   string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type PingReq struct {
	SessionId string `protobuf:"bytes,1,opt,name=sessionId,proto3" json:"sessionId,omitempty"`
	// contains filtered or unexported fields
}

type PingRsp struct {
	Restart bool   `protobuf:"varint,1,opt,name=restart,proto3" json:"restart,omitempty"`
	NextId  uint64 `protobuf:"varint,2,opt,name=nextId,proto3" json:"nextId,omitempty"`
	// contains filtered or unexported fields
}

type Subscribe struct {
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedClusterServer struct {
}

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

type Unsubscribe struct {
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}