Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Conf ¶
type Conf struct { DB struct { Host string `yaml:"host"` Port string `yaml:"port"` User string `yaml:"user"` Password string `yaml:"password"` DBName string `yaml:"dbname"` } MSG struct { Host string `yaml:"host"` Port string `yaml:"port"` User string `yaml:"user"` Password string `yaml:"password"` } SDL struct { Cron string `yaml:"cron"` } }
type EncodeService ¶
func NewJsonEncoder ¶
func NewJsonEncoder() *EncodeService
type JsonEncoder ¶
type JsonEncoder struct { }
func (*JsonEncoder) Encode ¶
func (j *JsonEncoder) Encode(item interface{}) (string, error)
type MqImpl ¶
type Publisher ¶
type Publisher interface {
Publish() error
}
func NewPublisher ¶
func NewPublisher(conf *Conf, encoder *EncodeService) *Publisher
type SourceService ¶
func NewSourceService ¶
func NewSourceService(config *Conf) *SourceService
Click to show internal directories.
Click to hide internal directories.