service

Documentation

Index

• Constants
• Variables
• type Broadcaster
  • func (b *Broadcaster) Broadcast(upd model.Update) (subscribersNotified int)
  • func (b *Broadcaster) Close(ctx context.Context) (err error)
  • func (b *Broadcaster) Ping(ctx context.Context) (err error)
  • func (b *Broadcaster) Start(ctx context.Context) (err error)
  • func (b *Broadcaster) StartWriters(ctx context.Context) (err error)
  • func (b *Broadcaster) Subscribe(ctx context.Context, name string) (chan model.Update, error)

Constants

const DefaultChannelBuffer = 100

const (
	DefaultSubscriptionChannelChannelDepth = 10
)

Variables

var (
	DuplicateSubscriberError = errors.New("duplicate subscriber")
	NoWritersError           = errors.New("no writers defined")
	NoReadersError           = errors.New("no readers defined")
)

Types

type Broadcaster

type Broadcaster struct {
	FigiName    map[string]string
	FigiChannel map[string]string

	Cord    chan model.Update
	Readers []reader.StocksReader
	Writers []writer.StocksWriter
	// contains filtered or unexported fields
}

func (*Broadcaster) Broadcast

func (b *Broadcaster) Broadcast(upd model.Update) (subscribersNotified int)

func (*Broadcaster) Close

func (b *Broadcaster) Close(ctx context.Context) (err error)

func (*Broadcaster) Ping

func (b *Broadcaster) Ping(ctx context.Context) (err error)

func (*Broadcaster) Start

func (b *Broadcaster) Start(ctx context.Context) (err error)

func (*Broadcaster) StartWriters

func (b *Broadcaster) StartWriters(ctx context.Context) (err error)

func (*Broadcaster) Subscribe

func (b *Broadcaster) Subscribe(ctx context.Context, name string) (chan model.Update, error)