topics

Documentation

Index

• Variables
• type Controller
  • func NewController() Controller
  • func (ctl Controller) Create(batchID string) error
  • func (ctl Controller) Delete(batchID string) error
• type Topic
  • func New(title string) Topic
  • func (t Topic) GetName(batchID string) string
  • func (t Topic) GetRegex() string

Variables

var KafkaURL, _ = os.LookupEnv("KAFKA_BOOTSTRAP_SERVERS")

Types

type Controller

type Controller struct {
	Kadmin    *kafka.AdminClient
	Batch     Topic
	Extract   Topic
	Transform Topic
	Load      Topic
}

func NewController

func NewController() Controller

func (Controller) Create

func (ctl Controller) Create(batchID string) error

Create creates topics in Kafka for the current batch

func (Controller) Delete

func (ctl Controller) Delete(batchID string) error

type Topic

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

func New

func New(title string) Topic

func (Topic) GetName

func (t Topic) GetName(batchID string) string

func (Topic) GetRegex

func (t Topic) GetRegex() string