Documentation
¶
Index ¶
- Variables
- type EventHandler
- type Kafka
- func (k *Kafka) AddTopicHandler(topic string, handler EventHandler)
- func (k *Kafka) Close() (err error)
- func (k *Kafka) GetTopicHandler(topic string) (EventHandler, error)
- func (k *Kafka) Init(metadata map[string]string) error
- func (k *Kafka) Publish(topic string, data []byte, metadata map[string]string) error
- func (k *Kafka) RemoveTopicHandler(topic string)
- func (k *Kafka) Subscribe(ctx context.Context) error
- type NewEvent
- type OAuthTokenSource
- type SaramaLogBridge
- type TopicHandlers
- type XDGSCRAMClient
Constants ¶
This section is empty.
Variables ¶
View Source
var ( SHA256 scram.HashGeneratorFcn = sha256.New SHA512 scram.HashGeneratorFcn = sha512.New )
Functions ¶
This section is empty.
Types ¶
type EventHandler ¶
EventHandler is the handler used to handle the subscribed event.
type Kafka ¶
type Kafka struct {
// The default value should be true for kafka pubsub component and false for kafka binding component
// This default value can be overridden by metadata consumeRetryEnabled
DefaultConsumeRetryEnabled bool
// contains filtered or unexported fields
}
Kafka allows reading/writing to a Kafka consumer group.
func (*Kafka) AddTopicHandler ¶
func (k *Kafka) AddTopicHandler(topic string, handler EventHandler)
AddTopicHandler adds a topic handler
func (*Kafka) GetTopicHandler ¶
func (k *Kafka) GetTopicHandler(topic string) (EventHandler, error)
GetTopicHandler returns the handler for a topic
func (*Kafka) RemoveTopicHandler ¶
RemoveTopicHandler removes a topic handler
type NewEvent ¶
type NewEvent struct {
Data []byte `json:"data"`
Topic string `json:"topic"`
Metadata map[string]string `json:"metadata"`
ContentType *string `json:"contentType,omitempty"`
}
NewEvent is an event arriving from a message bus instance.
type OAuthTokenSource ¶
type OAuthTokenSource struct {
CachedToken oauth2.Token
Extensions map[string]string
TokenEndpoint oauth2.Endpoint
ClientID string
ClientSecret string
Scopes []string
// contains filtered or unexported fields
}
func (*OAuthTokenSource) Token ¶
func (ts *OAuthTokenSource) Token() (*sarama.AccessToken, error)
type SaramaLogBridge ¶
type SaramaLogBridge struct {
// contains filtered or unexported fields
}
func (SaramaLogBridge) Print ¶
func (b SaramaLogBridge) Print(v ...interface{})
func (SaramaLogBridge) Printf ¶
func (b SaramaLogBridge) Printf(format string, v ...interface{})
func (SaramaLogBridge) Println ¶
func (b SaramaLogBridge) Println(v ...interface{})
type TopicHandlers ¶
type TopicHandlers map[string]EventHandler
Map of topics and their handlers
func (TopicHandlers) TopicList ¶
func (th TopicHandlers) TopicList() []string
TopicList returns the list of topics
type XDGSCRAMClient ¶ added in v1.9.0
type XDGSCRAMClient struct {
*scram.Client
*scram.ClientConversation
scram.HashGeneratorFcn
}
func (*XDGSCRAMClient) Begin ¶ added in v1.9.0
func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)
func (*XDGSCRAMClient) Done ¶ added in v1.9.0
func (x *XDGSCRAMClient) Done() bool
Source Files
Click to show internal directories.
Click to hide internal directories.