concern_manager

Documentation

Index

• Variables
• type AtAll
• type AtSomeone
• type GroupConcernAtConfig
  • func (g *GroupConcernAtConfig) CheckAtAll(id interface{}, ctype concern.Type) bool
  • func (g *GroupConcernAtConfig) GetAtSomeoneList(id interface{}, ctype concern.Type) []int64
• type GroupConcernConfig
  • func NewGroupConcernConfigFromString(s string) (*GroupConcernConfig, error)
  • func (g *GroupConcernConfig) ToString() string
• type KeySet
• type StateManager
  • func NewStateManager(keySet KeySet, useEmit bool) *StateManager
  • func (c *StateManager) AddGroupConcern(groupCode int64, id interface{}, ctype concern.Type) (newCtype concern.Type, err error)
  • func (c *StateManager) CheckAndSetAtAllMark(groupCode int64, id interface{}) (result bool)
  • func (c *StateManager) CheckConcern(id interface{}, ctype concern.Type) error
  • func (c *StateManager) CheckGroupConcern(groupCode int64, id interface{}, ctype concern.Type) error
  • func (c *StateManager) EmitFreshCore(name string, fresher func(ctype concern.Type, id interface{}) error)
  • func (c *StateManager) FreshAll()
  • func (c *StateManager) FreshCheck(id interface{}, setTTL bool) (result bool, err error)
  • func (c *StateManager) FreshIndex()
  • func (c *StateManager) GetConcern(id interface{}) (result concern.Type, err error)
  • func (c *StateManager) GetGroupConcern(groupCode int64, id interface{}) (result concern.Type, err error)
  • func (c *StateManager) GetGroupConcernConfig(groupCode int64, id interface{}) (concernConfig *GroupConcernConfig, err error)
  • func (c *StateManager) GroupTypeById(ids []interface{}, types []concern.Type) ([]interface{}, []concern.Type, error)
  • func (c *StateManager) List(filter func(groupCode int64, id interface{}, p concern.Type) bool) (idGroups []int64, ids []interface{}, idTypes []concern.Type, err error)
  • func (c *StateManager) ListByGroup(groupCode int64, filter func(id interface{}, p concern.Type) bool) (ids []interface{}, idTypes []concern.Type, err error)
  • func (c *StateManager) ListIds() (ids []interface{}, err error)
  • func (c *StateManager) OperateGroupConcernConfig(groupCode int64, id interface{}, ...) error
  • func (c *StateManager) RemoveAllByGroupCode(groupCode int64) (err error)
  • func (c *StateManager) RemoveAllById(_id interface{}) (err error)
  • func (c *StateManager) RemoveGroupConcern(groupCode int64, id interface{}, ctype concern.Type) (newCtype concern.Type, err error)
  • func (c *StateManager) Start() error

Variables

var (
	ErrAlreadyExists  = errors.New("already exists")
	ErrLengthMismatch = errors.New("length mismatch")
)

var ErrEmitQNotInit = errors.New("emit queue not enabled")

Types

type AtAll

type AtAll struct {
	Id    json.Number  `json:"id"`
	Ctype concern.Type `json:"ctype"`
}

type AtSomeone

type AtSomeone struct {
	Id     json.Number  `json:"id"`
	Ctype  concern.Type `json:"ctype"`
	AtList []int64      `json:"at_list"`
}

type GroupConcernAtConfig

type GroupConcernAtConfig struct {
	AtAll     []*AtAll     `json:"at_all"`
	AtSomeone []*AtSomeone `json:"at_someone"`
}

func (*GroupConcernAtConfig) CheckAtAll

func (g *GroupConcernAtConfig) CheckAtAll(id interface{}, ctype concern.Type) bool

func (*GroupConcernAtConfig) GetAtSomeoneList

func (g *GroupConcernAtConfig) GetAtSomeoneList(id interface{}, ctype concern.Type) []int64

type GroupConcernConfig

type GroupConcernConfig struct {
	GroupConcernAt GroupConcernAtConfig `json:"group_concern_at"`
}

func NewGroupConcernConfigFromString

func NewGroupConcernConfigFromString(s string) (*GroupConcernConfig, error)

func (*GroupConcernConfig) ToString

func (g *GroupConcernConfig) ToString() string

type KeySet

type KeySet interface {
	GroupConcernStateKey(keys ...interface{}) string
	GroupConcernConfigKey(keys ...interface{}) string
	FreshKey(keys ...interface{}) string
	GroupAtAllMarkKey(keys ...interface{}) string
	ParseGroupConcernStateKey(key string) (groupCode int64, id interface{}, err error)
}

type StateManager

type StateManager struct {
	*localdb.ShortCut
	KeySet
	// contains filtered or unexported fields
}

func NewStateManager

func NewStateManager(keySet KeySet, useEmit bool) *StateManager

func (*StateManager) AddGroupConcern

func (c *StateManager) AddGroupConcern(groupCode int64, id interface{}, ctype concern.Type) (newCtype concern.Type, err error)

func (*StateManager) CheckAndSetAtAllMark

func (c *StateManager) CheckAndSetAtAllMark(groupCode int64, id interface{}) (result bool)

CheckAndSetAtAllMark 检查@全体标记是否过期，已过期返回true，并重置标记，否则返回false。 因为@全体有次数限制，并且较为恼人，故设置标记，两次@全体之间必须有间隔。

func (*StateManager) CheckConcern

func (c *StateManager) CheckConcern(id interface{}, ctype concern.Type) error

func (*StateManager) CheckGroupConcern

func (c *StateManager) CheckGroupConcern(groupCode int64, id interface{}, ctype concern.Type) error

func (*StateManager) EmitFreshCore

func (c *StateManager) EmitFreshCore(name string, fresher func(ctype concern.Type, id interface{}) error)

func (*StateManager) FreshAll

func (c *StateManager) FreshAll()

func (*StateManager) FreshCheck

func (c *StateManager) FreshCheck(id interface{}, setTTL bool) (result bool, err error)

func (*StateManager) FreshIndex

func (c *StateManager) FreshIndex()

func (*StateManager) GetConcern

func (c *StateManager) GetConcern(id interface{}) (result concern.Type, err error)

GetConcern return the concern.Type combined from all group for a id

func (*StateManager) GetGroupConcern

func (c *StateManager) GetGroupConcern(groupCode int64, id interface{}) (result concern.Type, err error)

GetGroupConcern return the concern.Type in specific group for a id

func (*StateManager) GetGroupConcernConfig

func (c *StateManager) GetGroupConcernConfig(groupCode int64, id interface{}) (concernConfig *GroupConcernConfig, err error)

func (*StateManager) GroupTypeById

func (c *StateManager) GroupTypeById(ids []interface{}, types []concern.Type) ([]interface{}, []concern.Type, error)

func (*StateManager) List

func (c *StateManager) List(filter func(groupCode int64, id interface{}, p concern.Type) bool) (idGroups []int64, ids []interface{}, idTypes []concern.Type, err error)

func (*StateManager) ListByGroup

func (c *StateManager) ListByGroup(groupCode int64, filter func(id interface{}, p concern.Type) bool) (ids []interface{}, idTypes []concern.Type, err error)

func (*StateManager) ListIds

func (c *StateManager) ListIds() (ids []interface{}, err error)

func (*StateManager) OperateGroupConcernConfig

func (c *StateManager) OperateGroupConcernConfig(groupCode int64, id interface{}, f func(concernConfig *GroupConcernConfig) bool) error

OperateGroupConcernConfig 在一个rw事务中获取GroupConcernConfig并交给函数，如果返回true，就保存GroupConcernConfig，否则就回滚。

func (*StateManager) RemoveAllByGroupCode

func (c *StateManager) RemoveAllByGroupCode(groupCode int64) (err error)

func (*StateManager) RemoveAllById

func (c *StateManager) RemoveAllById(_id interface{}) (err error)

func (*StateManager) RemoveGroupConcern

func (c *StateManager) RemoveGroupConcern(groupCode int64, id interface{}, ctype concern.Type) (newCtype concern.Type, err error)

func (*StateManager) Start

func (c *StateManager) Start() error