Versions in this module Expand all Collapse all v0 v0.10.0 Sep 19, 2022 Changes in this version + type Callback func() + type Publisher struct + func NewPublisher(dialect *dialect.Dialect, logger *zap.Logger) *Publisher + func (p *Publisher) Publish() chan struct{} + func (p *Publisher) Subscribe() Subscriber + type Subscriber chan []*indicator.Kline