biz

README

Biz

Documentation

Index

• Variables
• type Config
  • func GetConfigData() *Config
  • func (l *Config) GetReceivers(route string) (*conf.Receiver, bool)
  • func (l *Config) GetTemplates(temp string) string
  • func (l *Config) Set(_ context.Context, params *bo.CacheConfigParams)
• type ConfigBiz
  • func NewConfigBiz(c *rabbitconf.Bootstrap) *ConfigBiz
  • func (b *ConfigBiz) CacheConfig(ctx context.Context, params *bo.CacheConfigParams)
  • func (b *ConfigBiz) LoadConfig(ctx context.Context)
• type HeartbeatBiz
  • func NewHeartbeatBiz(heartbeatRepository repository.Heartbeat) *HeartbeatBiz
  • func (b *HeartbeatBiz) Heartbeat(ctx context.Context, in *api.HeartbeatRequest) error
• type MsgBiz
  • func NewMsgBiz(c *rabbitconf.Bootstrap, data *data.Data) *MsgBiz
  • func (b *MsgBiz) SendMsg(ctx context.Context, msg *bo.SendMsgParams) error

Variables

var ProviderSetBiz = wire.NewSet(
	NewMsgBiz,
	NewConfigBiz,
	NewHeartbeatBiz,
)

ProviderSetBiz is biz providers.

Types

type Config

type Config struct {
	Receivers *sync.Map `json:"receivers"`
	Templates *sync.Map `json:"templates"`
}

Config 配置数据

func GetConfigData

func GetConfigData() *Config

GetConfigData 获取配置数据

func (*Config) GetReceivers

func (l *Config) GetReceivers(route string) (*conf.Receiver, bool)

GetReceivers 获取接收人

func (*Config) GetTemplates

func (l *Config) GetTemplates(temp string) string

GetTemplates 获取模板

func (*Config) Set

func (l *Config) Set(_ context.Context, params *bo.CacheConfigParams)

Set 设置接收人

type ConfigBiz

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

ConfigBiz 配置业务

func NewConfigBiz

func NewConfigBiz(c *rabbitconf.Bootstrap) *ConfigBiz

NewConfigBiz 创建配置业务

func (*ConfigBiz) CacheConfig

func (b *ConfigBiz) CacheConfig(ctx context.Context, params *bo.CacheConfigParams)

CacheConfig 缓存配置

func (*ConfigBiz) LoadConfig

func (b *ConfigBiz) LoadConfig(ctx context.Context)

LoadConfig 加载配置

type HeartbeatBiz

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

HeartbeatBiz .

func NewHeartbeatBiz

func NewHeartbeatBiz(heartbeatRepository repository.Heartbeat) *HeartbeatBiz

func (*HeartbeatBiz) Heartbeat

func (b *HeartbeatBiz) Heartbeat(ctx context.Context, in *api.HeartbeatRequest) error

Heartbeat 心跳包

type MsgBiz

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

MsgBiz 消息业务

func NewMsgBiz

func NewMsgBiz(c *rabbitconf.Bootstrap, data *data.Data) *MsgBiz

NewMsgBiz 创建消息业务

func (*MsgBiz) SendMsg

func (b *MsgBiz) SendMsg(ctx context.Context, msg *bo.SendMsgParams) error

SendMsg 发送消息