types

Documentation

Index

• type AdminClientInterface
• type AdminClientType

Types

type AdminClientInterface

type AdminClientInterface interface {
	CreateTopic(context.Context, string, *sarama.TopicDetail) *sarama.TopicError
	DeleteTopic(context.Context, string) *sarama.TopicError
	Close() error
}

Sarama ClusterAdmin Wrapping Interface To Facilitate Other Implementations (e.g. Azure EventHubs)

type AdminClientType

type AdminClientType int

AdminClient Type Enumeration

const (
	Kafka AdminClientType = iota
	EventHub
	Custom
	Unknown
)