stream_context

Documentation

Index

• type Context
  • func CreateContext(pipelineId int64) *Context
  • func (c *Context) GetContext() context.Context
  • func (c *Context) OffsetStorage() offset_storage.OffsetStorage
  • func (c *Context) PipelineId() int64
  • func (c *Context) SetMetrics(mtr metrics.Metrics)
  • func (c *Context) SetOffsetStorage(ofsSt offset_storage.OffsetStorage)

Types

type Context

type Context struct {
	Metrics metrics.Metrics
	Logger  *log.Logger
	// contains filtered or unexported fields
}

func CreateContext

func CreateContext(pipelineId int64) *Context

func (*Context) GetContext

func (c *Context) GetContext() context.Context

func (*Context) OffsetStorage

func (c *Context) OffsetStorage() offset_storage.OffsetStorage

func (*Context) PipelineId

func (c *Context) PipelineId() int64

func (*Context) SetMetrics

func (c *Context) SetMetrics(mtr metrics.Metrics)

func (*Context) SetOffsetStorage

func (c *Context) SetOffsetStorage(ofsSt offset_storage.OffsetStorage)