io

Documentation

Index

• type ConnStatus
• type MessageClient
• type TopicChannel

Types

type ConnStatus

type ConnStatus int

const (
	Connecting ConnStatus = iota
	Connected
	Disconnect
	Subscribed
	SubError
)

type MessageClient

type MessageClient interface {
	Subscribe(c api.StreamContext, subChan []TopicChannel, messageErrors chan error, params map[string]interface{}) error
	Publish(c api.StreamContext, topic string, message []byte, params map[string]interface{}) error
	Ping() error
}

type TopicChannel

type TopicChannel struct {
	// Topic for subscriber to filter on if any
	Topic string
	// Messages is the returned message channel for the subscriber
	Messages chan<- interface{}
}

TopicChannel is the data structure for subscriber