dts

Documentation

Index

• type Ctx
  • func (c *Ctx) Stop()
• type ShardRecord

Types

type Ctx

type Ctx struct {
	HealthcheckPort   int32
	Region            string
	Context           context.Context
	KillSignal        chan int8
	StreamARN         string
	Log               *zap.SugaredLogger
	SubscriptionNames []string
	Subscriptions     map[string]*stomp.Subscription
	Username          string
	Password          string
	Host              string
	Port              string
	InjestChan        chan *ShardRecord
}

func (*Ctx) Stop

func (c *Ctx) Stop()

type ShardRecord

type ShardRecord struct {
	Shard   string
	Records *[][]byte
}