kafkaop

Documentation

Index

• type ChannelOperator
  • func NewOperator(mem tree.Manager, config sidecars.KafkaConfig) (*ChannelOperator, error)
  • func (c *ChannelOperator) Create(ctx context.Context, context string, channel *meta.Channel) error
  • func (c *ChannelOperator) Delete(ctx context.Context, context string, name string) error
  • func (c *ChannelOperator) Get(ctx context.Context, context string, name string) (*meta.Channel, error)
  • func (c *ChannelOperator) GetAll(ctx context.Context, context string) (ret []*meta.Channel, err error)
  • func (c *ChannelOperator) Update(ctx context.Context, context string, channel *meta.Channel) error

Types

type ChannelOperator

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

ChannelOperator is a client for channel operations on kafka

func NewOperator

func NewOperator(mem tree.Manager, config sidecars.KafkaConfig) (*ChannelOperator, error)

NewOperator returns an initialized operator from the environment variables

func (*ChannelOperator) Create

func (c *ChannelOperator) Create(ctx context.Context, context string, channel *meta.Channel) error

Create creates a channel in kafka

func (*ChannelOperator) Delete

func (c *ChannelOperator) Delete(ctx context.Context, context string, name string) error

Delete deletes a channel from kafka

func (*ChannelOperator) Get

func (c *ChannelOperator) Get(ctx context.Context, context string, name string) (*meta.Channel, error)

Get gets a channel from kafka

func (*ChannelOperator) GetAll

func (c *ChannelOperator) GetAll(ctx context.Context, context string) (ret []*meta.Channel, err error)

GetAll gets all channels from kafka

func (*ChannelOperator) Update

func (c *ChannelOperator) Update(ctx context.Context, context string, channel *meta.Channel) error

Update updates a channel in kafka