stream

type Channel struct {
	// description for the channel
	Description string `json:"description"`
	// last activity time
	LastActive string `json:"lastActive"`
	// name of the channel
	Name string `json:"name"`
}

type CreateChannelRequest struct {
	// description for the channel
	Description string `json:"description"`
	// name of the channel
	Name string `json:"name"`
}

type CreateChannelResponse struct {
}

type ListChannelsRequest struct {
}

type ListChannelsResponse struct {
	Channels []Channel `json:"channels"`
}

type ListMessagesRequest struct {
	// The channel to subscribe to
	Channel string `json:"channel"`
	// number of message to return
	Limit int32 `json:"limit"`
}

type ListMessagesResponse struct {
	// The channel subscribed to
	Channel string `json:"channel"`
	// Messages are chronological order
	Messages []Message `json:"messages"`
}

type Message struct {
	// the channel name
	Channel string `json:"channel"`
	// id of the message
	Id string `json:"id"`
	// the associated metadata
	Metadata map[string]string `json:"metadata"`
	// text of the message
	Text string `json:"text"`
	// time of message creation
	Timestamp string `json:"timestamp"`
}

type SendMessageRequest struct {
	// The channel to send to
	Channel string `json:"channel"`
	// The message text to send
	Text string `json:"text"`
}

type SendMessageResponse struct {
}

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