kafkaoutbox

Documentation

Index

• type Config
• type Kafkaoutbox
  • func NewKafkaoutbox(config Config) (*Kafkaoutbox, error)
  • func (g *Kafkaoutbox) Generate(ctx context.Context) error
  • func (g *Kafkaoutbox) Init(_ context.Context) error

Types

type Config

type Config struct {
	ValidateProto     bool
	StorageConfigPath string
}

type Kafkaoutbox

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

func NewKafkaoutbox

func NewKafkaoutbox(config Config) (*Kafkaoutbox, error)

func (*Kafkaoutbox) Generate

func (g *Kafkaoutbox) Generate(ctx context.Context) error

func (*Kafkaoutbox) Init

func (g *Kafkaoutbox) Init(_ context.Context) error