kafka

package

v0.0.1 Latest Latest Go to latest Published: Jun 7, 2020 License: Apache-2.0 Imports: 16 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Option interface {
	// contains filtered or unexported methods
}

func WithBootstrapServers(s string) Option

func WithConfigMap(configMap kafka.ConfigMap) Option

func WithDefaultTopic(s string) Option

func WithGracePeriod(t time.Duration) Option

func WithTopicMappings(topicMappings config.TopicMappings) Option

func WithWorkers(v int) Option

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

func New(logger log.Logger, _ *prometheus.Registry, opts ...Option) (*Publisher, error)

func (s *Publisher) Close() error

func (s Publisher) Name() string

func (s *Publisher) Publish(ctx context.Context, request *apis.PublishRequest) (*apis.PublishResponse, error)

func (s *Publisher) PublishAsync(_ context.Context, request *apis.PublishRequest, callback apis.PublishCallbackFunc) error

func (s *Publisher) Serve() error

func (s *Publisher) Shutdown(err error)