kdspub

Documentation

Index

• func NewKDSPubChan(ctx *dsl.Ctx, o interface{}) (dsl.Chan, error)
• type KDSOpts
• type KDSPubChan
  • func (c *KDSPubChan) Close(ctx *dsl.Ctx) error
  • func (c *KDSPubChan) DocSpec() *dsl.DocSpec
  • func (c *KDSPubChan) Kill(ctx *dsl.Ctx) error
  • func (c *KDSPubChan) Kind() dsl.ChanKind
  • func (c *KDSPubChan) Open(ctx *dsl.Ctx) error
  • func (c *KDSPubChan) Pub(ctx *dsl.Ctx, m dsl.Msg) error
  • func (c *KDSPubChan) Recv(ctx *dsl.Ctx) chan dsl.Msg
  • func (c *KDSPubChan) Sub(ctx *dsl.Ctx, topic string) error
  • func (c *KDSPubChan) To(ctx *dsl.Ctx, m dsl.Msg) error

Functions

func NewKDSPubChan

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

Types

type KDSOpts

type KDSOpts struct {
	// StreamName is of course the name of the KDS.
	StreamName string

	// BufferSize is the size of the underlying channel buffer.
	// Defaults to DefaultChanBufferSize.
	BufferSize int
}

KDSOpts is a configuration for a Kinesis consumer for a given stream.

type KDSPubChan

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

KDSPubChan is a basic Kinesis stream consumer.

This channel consumes messages from a Kinesis stream.

func (*KDSPubChan) Close

func (c *KDSPubChan) Close(ctx *dsl.Ctx) error

func (*KDSPubChan) DocSpec

func (c *KDSPubChan) DocSpec() *dsl.DocSpec

func (*KDSPubChan) Kill

func (c *KDSPubChan) Kill(ctx *dsl.Ctx) error

func (*KDSPubChan) Kind

func (c *KDSPubChan) Kind() dsl.ChanKind

func (*KDSPubChan) Open

func (c *KDSPubChan) Open(ctx *dsl.Ctx) error

func (*KDSPubChan) Pub

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

func (*KDSPubChan) Recv

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

func (*KDSPubChan) Sub

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

func (*KDSPubChan) To

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