providers

Documentation

Index

• type AmqpConf
• type AmqpProvider
  • func NewAmqpProvider(conf *AmqpConf) *AmqpProvider
  • func (p *AmqpProvider) GetCh() <-chan barkserver.Message
  • func (p *AmqpProvider) GetName() string
  • func (p *AmqpProvider) Start()
  • func (p *AmqpProvider) Stop()
• type TimeProvider
  • func NewTimeProvider(body, title, devicekey, cron string) *TimeProvider
  • func (p *TimeProvider) GetCh() <-chan barkserver.Message
  • func (p *TimeProvider) GetName() string
  • func (p *TimeProvider) Start()
  • func (p *TimeProvider) Stop()

Types

type AmqpConf

type AmqpConf struct {
	Addr       string
	Exchange   string
	Queue      string
	Topic      string
	RoutingKey string
}

type AmqpProvider

type AmqpProvider struct {
	ProvideCh chan barkserver.Message
	// contains filtered or unexported fields
}

func NewAmqpProvider

func NewAmqpProvider(conf *AmqpConf) *AmqpProvider

func (*AmqpProvider) GetCh

func (p *AmqpProvider) GetCh() <-chan barkserver.Message

func (*AmqpProvider) GetName

func (p *AmqpProvider) GetName() string

func (*AmqpProvider) Start

func (p *AmqpProvider) Start()

func (*AmqpProvider) Stop

func (p *AmqpProvider) Stop()

type TimeProvider

type TimeProvider struct {
	ProvideCh chan barkserver.Message
	// contains filtered or unexported fields
}

func NewTimeProvider

func NewTimeProvider(body, title, devicekey, cron string) *TimeProvider

func (*TimeProvider) GetCh

func (p *TimeProvider) GetCh() <-chan barkserver.Message

func (*TimeProvider) GetName

func (p *TimeProvider) GetName() string

func (*TimeProvider) Start

func (p *TimeProvider) Start()

func (*TimeProvider) Stop

func (p *TimeProvider) Stop()