nats

Documentation

Index

• type Adapter
  • func New(c config.NATS) (*Adapter, error)
  • func (a *Adapter) Close(ctx context.Context)
  • func (a *Adapter) PublishTick(ctx context.Context, tick tick.Tick) error
  • func (a *Adapter) SubscribeToTicks(ctx context.Context, sub event.PricesSubscription) (<-chan tick.Tick, error)

Types

type Adapter

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

func New

func New(c config.NATS) (*Adapter, error)

func (*Adapter) Close

func (a *Adapter) Close(ctx context.Context)

func (*Adapter) PublishTick

func (a *Adapter) PublishTick(ctx context.Context, tick tick.Tick) error

func (*Adapter) SubscribeToTicks

func (a *Adapter) SubscribeToTicks(ctx context.Context, sub event.PricesSubscription) (<-chan tick.Tick, error)