data

Documentation

Index

• Variables
• func GetReadChangeGroupChannel() <-chan uint32
• func GetReadRemoveGroupChannel() <-chan bo.RemoveStrategyGroupBO
• func GetWriteChangeGroupChannel() chan<- uint32
• func GetWriteRemoveGroupChannel() chan<- bo.RemoveStrategyGroupBO
• type Data
  • func NewData(c *conf.Bootstrap, logger log.Logger) (*Data, func(), error)
  • func (d *Data) Cache() cache.GlobalCache
  • func (d *Data) DB() *gorm.DB
  • func (d *Data) Email() email.Interface
  • func (d *Data) Enforcer() *casbin.SyncedEnforcer
  • func (d *Data) Interflow() interflow.ServerInterflow

Variables

var ProviderSetData = wire.NewSet(
	NewData,
	GetReadChangeGroupChannel,
	GetWriteChangeGroupChannel,
	GetReadRemoveGroupChannel,
	GetWriteRemoveGroupChannel,
)

ProviderSetData is data providers.

Functions

func GetReadChangeGroupChannel

func GetReadChangeGroupChannel() <-chan uint32

GetReadChangeGroupChannel 获取changeGroupChannel的读取通道

func GetReadRemoveGroupChannel

func GetReadRemoveGroupChannel() <-chan bo.RemoveStrategyGroupBO

GetReadRemoveGroupChannel 获取removeGroupChannel的读取通道

func GetWriteChangeGroupChannel

func GetWriteChangeGroupChannel() chan<- uint32

GetWriteChangeGroupChannel 获取changeGroupChannel的写入通道

func GetWriteRemoveGroupChannel

func GetWriteRemoveGroupChannel() chan<- bo.RemoveStrategyGroupBO

GetWriteRemoveGroupChannel 获取removeGroupChannel的写入通道

Types

type Data

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

Data .

func NewData

func NewData(c *conf.Bootstrap, logger log.Logger) (*Data, func(), error)

NewData .

func (*Data) Cache

func (d *Data) Cache() cache.GlobalCache

Cache cache

func (*Data) DB

func (d *Data) DB() *gorm.DB

DB gorm DB对象

func (*Data) Email

func (d *Data) Email() email.Interface

Email email

func (*Data) Enforcer

func (d *Data) Enforcer() *casbin.SyncedEnforcer

Enforcer casbin enforcer

func (*Data) Interflow

func (d *Data) Interflow() interflow.ServerInterflow