clients

Documentation

Index

• func GetClient(connectionType string, props map[string]interface{}) (io.MessageClient, error)
• func RegisterClientFactory(clientType string, creatorFunc ClientFactoryFunc)
• func ReleaseClient(ctx api.StreamContext, cli io.MessageClient)
• type ClientFactoryFunc
• type ClientWrapper
• type ConsumerInfo
• type SubscribedTopics

Functions

func GetClient

func GetClient(connectionType string, props map[string]interface{}) (io.MessageClient, error)

func RegisterClientFactory

func RegisterClientFactory(clientType string, creatorFunc ClientFactoryFunc)

func ReleaseClient

func ReleaseClient(ctx api.StreamContext, cli io.MessageClient)

Types

type ClientFactoryFunc

type ClientFactoryFunc func(props map[string]interface{}) (ClientWrapper, error)

type ClientWrapper

type ClientWrapper interface {
	Subscribe(c api.StreamContext, subChan []io.TopicChannel, messageErrors chan error, params map[string]interface{}) error
	Release(c api.StreamContext) bool
	Publish(c api.StreamContext, topic string, message []byte, params map[string]interface{}) error
	SetConnectionSelector(conSelector string)
	GetConnectionSelector() string
	AddRef()
	Ping() error
}

type ConsumerInfo

type ConsumerInfo struct {
	ConsumerId   string
	ConsumerChan chan<- interface{}
	SubErrors    chan error
}

type SubscribedTopics

type SubscribedTopics struct {
	Topics []string
}