kafka

Documentation

Index

• func NewKafka(l logger.Logger) pubsub.PubSub
• type Kafka
  • func (k *Kafka) Close() (err error)
  • func (k *Kafka) Features() []pubsub.Feature
  • func (k *Kafka) Init(metadata pubsub.Metadata) error
  • func (k *Kafka) Publish(req *pubsub.PublishRequest) error
  • func (k *Kafka) Subscribe(req pubsub.SubscribeRequest, handler pubsub.Handler) error
• type OAuthTokenSource
  • func (ts *OAuthTokenSource) Token() (*sarama.AccessToken, error)
• type SaramaLogBridge
  • func (b SaramaLogBridge) Print(v ...interface{})
  • func (b SaramaLogBridge) Printf(format string, v ...interface{})
  • func (b SaramaLogBridge) Println(v ...interface{})

Functions

func NewKafka

func NewKafka(l logger.Logger) pubsub.PubSub

NewKafka returns a new kafka pubsub instance.

Types

type Kafka

type Kafka struct {
	// contains filtered or unexported fields
}

Kafka allows reading/writing to a Kafka consumer group.

func (*Kafka) Close

func (k *Kafka) Close() (err error)

func (*Kafka) Features

func (k *Kafka) Features() []pubsub.Feature

func (*Kafka) Init

func (k *Kafka) Init(metadata pubsub.Metadata) error

Init does metadata parsing and connection establishment.

func (*Kafka) Publish

func (k *Kafka) Publish(req *pubsub.PublishRequest) error

Publish message to Kafka cluster.

func (*Kafka) Subscribe

func (k *Kafka) Subscribe(req pubsub.SubscribeRequest, handler pubsub.Handler) error

Subscribe to topic in the Kafka cluster This call cannot block like its sibling in bindings/kafka because of where this is invoked in runtime.go.

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{})