stream

type Channel struct {

	// name of the channel
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// description for the channel
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// last activity time
	LastActive string `protobuf:"bytes,3,opt,name=last_active,json=lastActive,proto3" json:"last_active,omitempty"`
	// contains filtered or unexported fields
}

type CreateChannelRequest struct {

	// name of the channel
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// description for the channel
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

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

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

type ListChannelsResponse struct {
	Channels []*Channel `protobuf:"bytes,1,rep,name=channels,proto3" json:"channels,omitempty"`
	// contains filtered or unexported fields
}

type ListMessagesRequest struct {

	// The channel to subscribe to
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// number of message to return
	Limit int32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

type ListMessagesResponse struct {

	// The channel subscribed to
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// Messages are chronological order
	Messages []*Message `protobuf:"bytes,2,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

type Message struct {

	// id of the message
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// text of the message
	Text string `protobuf:"bytes,2,opt,name=text,proto3" json:"text,omitempty"`
	// time of message creation
	Timestamp string `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// the channel name
	Channel string `protobuf:"bytes,4,opt,name=channel,proto3" json:"channel,omitempty"`
	// the associated metadata
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

type SendMessageRequest struct {

	// The channel to send to
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// The message text to send
	Text string `protobuf:"bytes,2,opt,name=text,proto3" json:"text,omitempty"`
	// contains filtered or unexported fields
}

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

type StreamHandler interface {
	CreateChannel(context.Context, *CreateChannelRequest, *CreateChannelResponse) error
	SendMessage(context.Context, *SendMessageRequest, *SendMessageResponse) error
	ListMessages(context.Context, *ListMessagesRequest, *ListMessagesResponse) error
	ListChannels(context.Context, *ListChannelsRequest, *ListChannelsResponse) error
}

type StreamService interface {
	CreateChannel(ctx context.Context, in *CreateChannelRequest, opts ...client.CallOption) (*CreateChannelResponse, error)
	SendMessage(ctx context.Context, in *SendMessageRequest, opts ...client.CallOption) (*SendMessageResponse, error)
	ListMessages(ctx context.Context, in *ListMessagesRequest, opts ...client.CallOption) (*ListMessagesResponse, error)
	ListChannels(ctx context.Context, in *ListChannelsRequest, opts ...client.CallOption) (*ListChannelsResponse, error)
}