Documentation ¶ Index ¶ type Config type Producer func (p *Producer) Close(_ context.Context) error func (p *Producer) Initialize(ctx context.Context, configFile string) func (p *Producer) Produce(ctx context.Context, _ []byte, val []byte, _ any) Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Config ¶ type Config struct { Table string `json:"table"` } type Producer ¶ type Producer struct { // contains filtered or unexported fields } func (*Producer) Close ¶ func (p *Producer) Close(_ context.Context) error func (*Producer) Initialize ¶ func (p *Producer) Initialize(ctx context.Context, configFile string) func (*Producer) Produce ¶ func (p *Producer) Produce(ctx context.Context, _ []byte, val []byte, _ any) Source Files ¶ View all Source files config.goproducer.go Click to show internal directories. Click to hide internal directories.