cwl

Mar 1, 2021

Changes in this version

+ func NewCWLChan(ctx *dsl.Ctx, o interface{}) (dsl.Chan, error)

+ type CWLChan struct

+ func (c *CWLChan) Close(ctx *dsl.Ctx) error

+ func (c *CWLChan) Consume(ctx *dsl.Ctx)

+ func (c *CWLChan) DocSpec() *dsl.DocSpec

+ func (c *CWLChan) Kill(ctx *dsl.Ctx) error

+ func (c *CWLChan) Kind() dsl.ChanKind

+ func (c *CWLChan) Open(ctx *dsl.Ctx) error

+ func (c *CWLChan) Pub(ctx *dsl.Ctx, m dsl.Msg) error

+ func (c *CWLChan) Recv(ctx *dsl.Ctx) chan dsl.Msg

+ func (c *CWLChan) Sub(ctx *dsl.Ctx, topic string) error

+ func (c *CWLChan) To(ctx *dsl.Ctx, m dsl.Msg) error

+ type CWLOpts struct

+ FilterPattern string

+ GroupName string

+ PollInterval *int64

+ Region *string

+ StartTimePadding *int64

+ StreamNamePrefix *string

+ func (opts CWLOpts) String() string