api

Documentation

Index

• type ConsumeFlags
  • func DefaultConsumeFlags() ConsumeFlags
• type ConsumerGroup
• type KafkaDataSource
• type Message
• type MessageHandlerFunc

Types

type ConsumeFlags

type ConsumeFlags struct {
	Follow     bool
	Tail       int32
	OffsetFlag string
}

func DefaultConsumeFlags

func DefaultConsumeFlags() ConsumeFlags

type ConsumerGroup

type ConsumerGroup struct {
	Name      string
	State     string
	Consumers int
}

type KafkaDataSource

type KafkaDataSource interface {
	Init()
	GetTopics() ([]string, error)
	GetContexts() ([]string, error)
	GetContext() string
	SetContext(contextName string) error
	GetConsumerGroups() ([]ConsumerGroup, error)
	ConsumeTopic(ctx context.Context, topicName string, flags ConsumeFlags, handleMessage MessageHandlerFunc) error
}

type Message

type Message struct {
	Key    string
	Value  string
	Offset int64
}

type MessageHandlerFunc

type MessageHandlerFunc func(msg Message)