Documentation ¶
Index ¶
- type PubSubAgent
- func (s *PubSubAgent) CleanAllData()
- func (s *PubSubAgent) GetMetaPath() string
- func (s *PubSubAgent) GetPublisherID() string
- func (s *PubSubAgent) GetSubscriberID() string
- func (s *PubSubAgent) Start() error
- func (s *PubSubAgent) StartPublish(ctx context.Context, topicName string, sendChan chan pubsub.TopicData) error
- func (s *PubSubAgent) StartSubscribe(ctx context.Context, topicName string, batchSize, flushInterval uint32) (chan []pubsub.SubscriptionResult, error)
- func (s *PubSubAgent) StartWithServer() error
- func (s *PubSubAgent) Stop()
- type RetrievablePubSubAgent
- func (s *RetrievablePubSubAgent) CleanAllData()
- func (s *RetrievablePubSubAgent) GetMetaPath() string
- func (s *RetrievablePubSubAgent) GetPublisherID() string
- func (s *RetrievablePubSubAgent) GetSubscriberID() string
- func (s *RetrievablePubSubAgent) Start() error
- func (s *RetrievablePubSubAgent) StartRetrievablePublish(ctx context.Context, topicName string, sendChan chan pubsub.TopicData) (chan []pubsub.TopicDataResult, error)
- func (s *RetrievablePubSubAgent) StartRetrievableSubscribe(ctx context.Context, topicName string, batchSize, flushInterval uint32) (chan pubsub.RetrievableSubscriptionResults, error)
- func (s *RetrievablePubSubAgent) StartWithServer() error
- func (s *RetrievablePubSubAgent) Stop()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PubSubAgent ¶
type PubSubAgent struct {
// contains filtered or unexported fields
}
func NewPubSubAgent ¶
func NewPubSubAgent(config config.AgentConfig) *PubSubAgent
func (*PubSubAgent) CleanAllData ¶
func (s *PubSubAgent) CleanAllData()
func (*PubSubAgent) GetMetaPath ¶
func (s *PubSubAgent) GetMetaPath() string
func (*PubSubAgent) GetPublisherID ¶
func (s *PubSubAgent) GetPublisherID() string
func (*PubSubAgent) GetSubscriberID ¶
func (s *PubSubAgent) GetSubscriberID() string
func (*PubSubAgent) Start ¶
func (s *PubSubAgent) Start() error
func (*PubSubAgent) StartPublish ¶
func (*PubSubAgent) StartSubscribe ¶
func (s *PubSubAgent) StartSubscribe(ctx context.Context, topicName string, batchSize, flushInterval uint32) (chan []pubsub.SubscriptionResult, error)
func (*PubSubAgent) StartWithServer ¶
func (s *PubSubAgent) StartWithServer() error
type RetrievablePubSubAgent ¶
type RetrievablePubSubAgent struct {
// contains filtered or unexported fields
}
func NewRetrievablePubSubAgent ¶
func NewRetrievablePubSubAgent(config config.AgentConfig) *RetrievablePubSubAgent
func (*RetrievablePubSubAgent) CleanAllData ¶
func (s *RetrievablePubSubAgent) CleanAllData()
func (*RetrievablePubSubAgent) GetMetaPath ¶
func (s *RetrievablePubSubAgent) GetMetaPath() string
func (*RetrievablePubSubAgent) GetPublisherID ¶
func (s *RetrievablePubSubAgent) GetPublisherID() string
func (*RetrievablePubSubAgent) GetSubscriberID ¶
func (s *RetrievablePubSubAgent) GetSubscriberID() string
func (*RetrievablePubSubAgent) Start ¶
func (s *RetrievablePubSubAgent) Start() error
func (*RetrievablePubSubAgent) StartRetrievablePublish ¶
func (s *RetrievablePubSubAgent) StartRetrievablePublish(ctx context.Context, topicName string, sendChan chan pubsub.TopicData) (chan []pubsub.TopicDataResult, error)
func (*RetrievablePubSubAgent) StartRetrievableSubscribe ¶
func (s *RetrievablePubSubAgent) StartRetrievableSubscribe(ctx context.Context, topicName string, batchSize, flushInterval uint32) (chan pubsub.RetrievableSubscriptionResults, error)
func (*RetrievablePubSubAgent) StartWithServer ¶
func (s *RetrievablePubSubAgent) StartWithServer() error
Click to show internal directories.
Click to hide internal directories.