kline

Documentation

Index

• type Callback
• type Publisher
  • func NewPublisher(dialect *dialect.Dialect, logger *zap.Logger) *Publisher
  • func (p *Publisher) Publish() chan struct{}
  • func (p *Publisher) Subscribe() Subscriber
• type Subscriber

Types

type Callback

type Callback func()

type Publisher

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

func NewPublisher

func NewPublisher(dialect *dialect.Dialect, logger *zap.Logger) *Publisher

func (*Publisher) Publish

func (p *Publisher) Publish() chan struct{}

func (*Publisher) Subscribe

func (p *Publisher) Subscribe() Subscriber

type Subscriber

type Subscriber chan []*indicator.Kline