storage

Documentation

Index

• type Action
• type ActionType
• type InstanceObj
  • func NewStorage(opts Options) (*InstanceObj, error)
  • func (o *InstanceObj) AddNewbieMessages(ctx context.Context, chatID int64, userID int) error
  • func (o *InstanceObj) AddToActionPool(ctx context.Context, act Action, delay time.Duration) error
  • func (o *InstanceObj) DelKicked(ctx context.Context, chatID int64, userID int64) error
  • func (o *InstanceObj) GetFromActionPool(ctx context.Context) ([]Action, error)
  • func (o *InstanceObj) GetNewbieMessages(ctx context.Context, chatID int64, userID int) (int, error)
  • func (o *InstanceObj) GetTokenData(ctx context.Context, token string) (TokenData, error)
  • func (o *InstanceObj) IsKicked(ctx context.Context, chatID int64, userID int) (bool, error)
  • func (o *InstanceObj) NewToken(ctx context.Context, chatID int64) (string, error)
  • func (o *InstanceObj) SetKicked(ctx context.Context, chatID int64, userID int, ttl time.Duration) error
  • func (o *InstanceObj) Stop() error
• type Options
• type TokenData

Types

type Action

type Action struct {
	ChatID    int64
	MessageID int
	Type      ActionType
	UserID    int
}

type ActionType

type ActionType string

const (
	ActionTypeDelete ActionType = "del"
	ActionTypeKick   ActionType = "kick"
)

type InstanceObj

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

func NewStorage

func NewStorage(opts Options) (*InstanceObj, error)

func (*InstanceObj) AddNewbieMessages

func (o *InstanceObj) AddNewbieMessages(ctx context.Context, chatID int64, userID int) error

func (*InstanceObj) AddToActionPool

func (o *InstanceObj) AddToActionPool(ctx context.Context, act Action, delay time.Duration) error

func (*InstanceObj) DelKicked

func (o *InstanceObj) DelKicked(ctx context.Context, chatID int64, userID int64) error

func (*InstanceObj) GetFromActionPool

func (o *InstanceObj) GetFromActionPool(ctx context.Context) ([]Action, error)

func (*InstanceObj) GetNewbieMessages

func (o *InstanceObj) GetNewbieMessages(ctx context.Context, chatID int64, userID int) (int, error)

func (*InstanceObj) GetTokenData

func (o *InstanceObj) GetTokenData(ctx context.Context, token string) (TokenData, error)

func (*InstanceObj) IsKicked

func (o *InstanceObj) IsKicked(ctx context.Context, chatID int64, userID int) (bool, error)

func (*InstanceObj) NewToken

func (o *InstanceObj) NewToken(ctx context.Context, chatID int64) (string, error)

func (*InstanceObj) SetKicked

func (o *InstanceObj) SetKicked(ctx context.Context, chatID int64, userID int, ttl time.Duration) error

func (*InstanceObj) Stop

func (o *InstanceObj) Stop() error

type Options

type Options struct {
	Log    *zap.SugaredLogger
	Config config.Stor
}

type TokenData

type TokenData struct {
	ChatID int64
	TTL    time.Duration
}