notificator

Documentation

Index

• func CheckTokenMovementLimits(tx *model.DbTransaction, conf conf.TokenMovementConfig, blockID int64)
• func NewQueue() types.Notifications
• func UpdateNotifications(ecosystemID int64, accounts []string)
• func UpdateRolesNotifications(ecosystemID int64, roles []int64)
• type Accounts
• type Queue
  • func (q *Queue) AddAccounts(ecosystem int64, list ...string)
  • func (q *Queue) AddRoles(ecosystem int64, list ...int64)
  • func (q *Queue) Send()
  • func (q *Queue) Size() int
• type Roles

Functions

func CheckTokenMovementLimits

func CheckTokenMovementLimits(tx *model.DbTransaction, conf conf.TokenMovementConfig, blockID int64)

CheckTokenMovementLimits check all limits

func NewQueue

func NewQueue() types.Notifications

func UpdateNotifications

func UpdateNotifications(ecosystemID int64, accounts []string)

UpdateNotifications send stats about unreaded messages to centrifugo for ecosystem

func UpdateRolesNotifications

func UpdateRolesNotifications(ecosystemID int64, roles []int64)

UpdateRolesNotifications send stats about unreaded messages to centrifugo for ecosystem

Types

type Accounts

type Accounts struct {
	Ecosystem int64
	List      []string
}

type Queue

type Queue struct {
	Accounts []*Accounts
	Roles    []*Roles
}

func (*Queue) AddAccounts

func (q *Queue) AddAccounts(ecosystem int64, list ...string)

func (*Queue) AddRoles

func (q *Queue) AddRoles(ecosystem int64, list ...int64)

func (*Queue) Send

func (q *Queue) Send()

func (*Queue) Size

func (q *Queue) Size() int

type Roles

type Roles struct {
	Ecosystem int64
	List      []int64
}