messagestore

Documentation

Index

• type MessageStore
  • func NewMessageStore(dic *di.Container) *MessageStore
  • func (wp *MessageStore) DeleteMsgId(id string)
  • func (wp *MessageStore) GenAckChan(id string) *MsgAckChan
  • func (wp *MessageStore) LoadMsgChan(id string) (interface{}, bool)
  • func (wp *MessageStore) StoreMsgId(id string, ch string)
  • func (wp *MessageStore) StoreRange()
• type MessageStores
• type MsgAckChan
  • func (mac *MsgAckChan) TryCloseChan()
  • func (mac *MsgAckChan) TrySendDataAndCloseChan(data interface{}) bool

Types

type MessageStore

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

func NewMessageStore

func NewMessageStore(dic *di.Container) *MessageStore

func (*MessageStore) DeleteMsgId

func (wp *MessageStore) DeleteMsgId(id string)

func (*MessageStore) GenAckChan

func (wp *MessageStore) GenAckChan(id string) *MsgAckChan

func (*MessageStore) LoadMsgChan

func (wp *MessageStore) LoadMsgChan(id string) (interface{}, bool)

func (*MessageStore) StoreMsgId

func (wp *MessageStore) StoreMsgId(id string, ch string)

func (*MessageStore) StoreRange

func (wp *MessageStore) StoreRange()

type MessageStores

type MessageStores interface {
	StoreMsgId(id string, ch string)
	LoadMsgChan(id string) (interface{}, bool)
	DeleteMsgId(id string)
	GenAckChan(id string) *MsgAckChan
}

type MsgAckChan

type MsgAckChan struct {
	Mu       sync.Mutex
	Id       string
	IsClosed bool
	DataChan chan interface{}
}

func (*MsgAckChan) TryCloseChan

func (mac *MsgAckChan) TryCloseChan()

func (*MsgAckChan) TrySendDataAndCloseChan

func (mac *MsgAckChan) TrySendDataAndCloseChan(data interface{}) bool