channels

type Channel struct {
	ID     string         `json:"id"`
	Config *ChannelConfig `json:"config"`
	Type   string         `json:"type"`
	// contains filtered or unexported fields
}

type ChannelConfig struct {
	MaxOfChannelConnections int `json:"maxOfChannelConnections"`
}

type Client struct {
	ID        string `json:"id"`
	ChannelID string `json:"channelId"`
	UserAgent string `json:"userAgent"`
	IPAddress string `json:"ipAddress"`
	// contains filtered or unexported fields
}

type ConsumerAdapter interface {
	Subscribe(client *Client) error
}

type Message struct {
	ID        string    `json:"id"`
	ChannelID string    `json:"channelId"`
	ClientID  string    `json:"clientId"`
	Payload   string    `json:"payload"`
	CreatedAt time.Time `json:"createdAt"`
}

type ProducerAdapter interface {
	Send(message *Message) error
}