backtests

Documentation

Index

• type Adapter
  • func New(c config.NATS) (*Adapter, error)
  • func (a *Adapter) Close(ctx context.Context)
  • func (a *Adapter) Publish(ctx context.Context, backtestID uuid.UUID, evt event.Event) error
  • func (a *Adapter) Subscribe(ctx context.Context, backtestID uuid.UUID) (<-chan event.Event, 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) Publish

func (a *Adapter) Publish(ctx context.Context, backtestID uuid.UUID, evt event.Event) error

func (*Adapter) Subscribe

func (a *Adapter) Subscribe(ctx context.Context, backtestID uuid.UUID) (<-chan event.Event, error)