storage

Documentation

Index

• Variables
• func NewPeers(kv Storage) peers.Storage
• func NewSession(kv Storage, login bool) telegram.SessionStorage
• func NewState(kv Storage) updates.StateStorage
• type Peers
  • func (p *Peers) Find(ctx context.Context, key peers.Key) (peers.Value, bool, error)
  • func (p *Peers) FindPhone(ctx context.Context, phone string) (peers.Key, peers.Value, bool, error)
  • func (p *Peers) GetContactsHash(ctx context.Context) (int64, error)
  • func (p *Peers) Save(ctx context.Context, key peers.Key, value peers.Value) error
  • func (p *Peers) SaveContactsHash(ctx context.Context, hash int64) error
  • func (p *Peers) SavePhone(ctx context.Context, phone string, _key peers.Key) error
• type Session
  • func (s *Session) LoadSession(ctx context.Context) ([]byte, error)
  • func (s *Session) StoreSession(ctx context.Context, data []byte) error
• type State
  • func (s *State) ForEachChannels(ctx context.Context, userID int64, ...) error
  • func (s *State) Get(ctx context.Context, key string, v interface{}) error
  • func (s *State) GetChannelPts(ctx context.Context, userID, channelID int64) (int, bool, error)
  • func (s *State) GetState(ctx context.Context, userID int64) (updates.State, bool, error)
  • func (s *State) Set(ctx context.Context, key string, v interface{}) error
  • func (s *State) SetChannelPts(ctx context.Context, userID, channelID int64, pts int) error
  • func (s *State) SetDate(ctx context.Context, userID int64, date int) error
  • func (s *State) SetDateSeq(ctx context.Context, userID int64, date, seq int) error
  • func (s *State) SetPts(ctx context.Context, userID int64, pts int) error
  • func (s *State) SetQts(ctx context.Context, userID int64, qts int) error
  • func (s *State) SetSeq(ctx context.Context, userID int64, seq int) error
  • func (s *State) SetState(ctx context.Context, userID int64, state updates.State) error
• type Storage

Variables

var ErrNotFound = errors.New("key not found")

Functions

func NewPeers

func NewPeers(kv Storage) peers.Storage

func NewSession

func NewSession(kv Storage, login bool) telegram.SessionStorage

func NewState

func NewState(kv Storage) updates.StateStorage

Types

type Peers

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

func (*Peers) Find

func (p *Peers) Find(ctx context.Context, key peers.Key) (peers.Value, bool, error)

func (*Peers) FindPhone

func (p *Peers) FindPhone(ctx context.Context, phone string) (peers.Key, peers.Value, bool, error)

func (*Peers) GetContactsHash

func (p *Peers) GetContactsHash(ctx context.Context) (int64, error)

func (*Peers) Save

func (p *Peers) Save(ctx context.Context, key peers.Key, value peers.Value) error

func (*Peers) SaveContactsHash

func (p *Peers) SaveContactsHash(ctx context.Context, hash int64) error

func (*Peers) SavePhone

func (p *Peers) SavePhone(ctx context.Context, phone string, _key peers.Key) error

type Session

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

func (*Session) LoadSession

func (s *Session) LoadSession(ctx context.Context) ([]byte, error)

func (*Session) StoreSession

func (s *Session) StoreSession(ctx context.Context, data []byte) error

type State

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

func (*State) ForEachChannels

func (s *State) ForEachChannels(ctx context.Context, userID int64, f func(ctx context.Context, channelID int64, pts int) error) error

func (*State) Get

func (s *State) Get(ctx context.Context, key string, v interface{}) error

func (*State) GetChannelPts

func (s *State) GetChannelPts(ctx context.Context, userID, channelID int64) (int, bool, error)

func (*State) GetState

func (s *State) GetState(ctx context.Context, userID int64) (updates.State, bool, error)

func (*State) Set

func (s *State) Set(ctx context.Context, key string, v interface{}) error

func (*State) SetChannelPts

func (s *State) SetChannelPts(ctx context.Context, userID, channelID int64, pts int) error

func (*State) SetDate

func (s *State) SetDate(ctx context.Context, userID int64, date int) error

func (*State) SetDateSeq

func (s *State) SetDateSeq(ctx context.Context, userID int64, date, seq int) error

func (*State) SetPts

func (s *State) SetPts(ctx context.Context, userID int64, pts int) error

func (*State) SetQts

func (s *State) SetQts(ctx context.Context, userID int64, qts int) error

func (*State) SetSeq

func (s *State) SetSeq(ctx context.Context, userID int64, seq int) error

func (*State) SetState

func (s *State) SetState(ctx context.Context, userID int64, state updates.State) error

type Storage

type Storage interface {
	Get(ctx context.Context, key string) ([]byte, error)
	Set(ctx context.Context, key string, value []byte) error
	Delete(ctx context.Context, key string) error
}