Documentation
¶
Index ¶
- Constants
- type LockerMessage
- func (l *LockerMessage) LockGlobalMessage(ctx context.Context, clientMsgID string) (err error)
- func (l *LockerMessage) LockMessageTypeKey(ctx context.Context, clientMsgID, typeKey string) (err error)
- func (l *LockerMessage) UnLockGlobalMessage(ctx context.Context, clientMsgID string) error
- func (l *LockerMessage) UnLockMessageTypeKey(ctx context.Context, clientMsgID string, typeKey string) error
- type MessageLocker
Constants ¶
View Source
const GlOBALLOCK = "GLOBAL_LOCK"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LockerMessage ¶
type LockerMessage struct {
// contains filtered or unexported fields
}
func NewLockerMessage ¶
func NewLockerMessage(cache cache.MsgModel) *LockerMessage
func (*LockerMessage) LockGlobalMessage ¶
func (l *LockerMessage) LockGlobalMessage(ctx context.Context, clientMsgID string) (err error)
func (*LockerMessage) LockMessageTypeKey ¶
func (l *LockerMessage) LockMessageTypeKey(ctx context.Context, clientMsgID, typeKey string) (err error)
func (*LockerMessage) UnLockGlobalMessage ¶
func (l *LockerMessage) UnLockGlobalMessage(ctx context.Context, clientMsgID string) error
func (*LockerMessage) UnLockMessageTypeKey ¶
type MessageLocker ¶
type MessageLocker interface {
LockMessageTypeKey(ctx context.Context, clientMsgID, typeKey string) (err error)
UnLockMessageTypeKey(ctx context.Context, clientMsgID string, typeKey string) error
LockGlobalMessage(ctx context.Context, clientMsgID string) (err error)
UnLockGlobalMessage(ctx context.Context, clientMsgID string) (err error)
}
Click to show internal directories.
Click to hide internal directories.