server

type Message struct {
	Offset uint64 `protobuf:"varint,1,opt,name=offset" json:"offset,omitempty"`
	Crc    uint32 `protobuf:"varint,2,opt,name=crc" json:"crc,omitempty"`
	Key    []byte `protobuf:"bytes,10,opt,name=key,proto3" json:"key,omitempty"`
	Value  []byte `protobuf:"bytes,11,opt,name=value,proto3" json:"value,omitempty"`
}

type MessageSet struct {
	// contains filtered or unexported fields
}

type MessageSetReader struct {
	// contains filtered or unexported fields
}

type MessageSetSort []MessageSet

type PubSubClient interface {
	PublishMulti(ctx context.Context, in *PublishMultiRequest, opts ...grpc.CallOption) (*PublishMultiReply, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (PubSub_SubscribeClient, error)
}

type PubSubServer interface {
	PublishMulti(context.Context, *PublishMultiRequest) (*PublishMultiReply, error)
	Subscribe(*SubscribeRequest, PubSub_SubscribeServer) error
}

type PubSub_SubscribeClient interface {
	Recv() (*SubscribeResponse, error)
	grpc.ClientStream
}

type PubSub_SubscribeServer interface {
	Send(*SubscribeResponse) error
	grpc.ServerStream
}

type PublishMultiReply struct {
}

type PublishMultiRequest struct {
	Topic    string     `protobuf:"bytes,1,opt,name=topic" json:"topic,omitempty"`
	Messages []*Message `protobuf:"bytes,2,rep,name=messages" json:"messages,omitempty"`
}

type Server struct {
	// contains filtered or unexported fields
}

type SubscribeRequest struct {
	Topic  string `protobuf:"bytes,1,opt,name=topic" json:"topic,omitempty"`
	Offset uint64 `protobuf:"varint,2,opt,name=offset" json:"offset,omitempty"`
}

type SubscribeResponse struct {
	Messages []*Message `protobuf:"bytes,1,rep,name=messages" json:"messages,omitempty"`
}

type Topic struct {
	// contains filtered or unexported fields
}