kafka

Documentation

Index

• Variables
• func TopicName(topicPrefix, topicDataType string) string
• type ClusterAdmin
  • func NewClusterAdmin(ctx context.Context, url, username, password string) (*ClusterAdmin, error)
  • func (c *ClusterAdmin) CreateTopic(topicName string, detail *sarama.TopicDetail) error
• type Producer
  • func NewProducer(ctx context.Context, project, url, userName, password string) (*Producer, error)
• type XDGSCRAMClient
  • func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)
  • func (x *XDGSCRAMClient) Done() bool
  • func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)

Variables

var SHA256 scram.HashGeneratorFcn = func() hash.Hash { return sha256.New() }

var SHA512 scram.HashGeneratorFcn = func() hash.Hash { return sha512.New() }

Functions

func TopicName

func TopicName(topicPrefix, topicDataType string) string

Types

type ClusterAdmin

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

func NewClusterAdmin

func NewClusterAdmin(
	ctx context.Context,
	url,
	username,
	password string,
) (*ClusterAdmin, error)

func (*ClusterAdmin) CreateTopic

func (c *ClusterAdmin) CreateTopic(topicName string, detail *sarama.TopicDetail) error

type Producer

type Producer struct {
	sarama.SyncProducer
}

func NewProducer

func NewProducer(
	ctx context.Context,
	project,
	url,
	userName,
	password string,
) (*Producer, error)

type XDGSCRAMClient

type XDGSCRAMClient struct {
	*scram.Client
	*scram.ClientConversation
	scram.HashGeneratorFcn
}

func (*XDGSCRAMClient) Begin

func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)

func (*XDGSCRAMClient) Done

func (x *XDGSCRAMClient) Done() bool

func (*XDGSCRAMClient) Step

func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)