entgaps

Documentation

Index

• type State
  • func New(client *ent.Client, traceProvider trace.TracerProvider) *State
  • func (s *State) ForEachChannels(ctx context.Context, userID int64, ...) error
  • func (s *State) GetChannelPts(ctx context.Context, userID, channelID int64) (int, bool, error)
  • func (s *State) GetState(ctx context.Context, userID int64) (state updates.State, found bool, err 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

Types

type State

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

func New

func New(client *ent.Client, traceProvider trace.TracerProvider) *State

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) 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) (state updates.State, found bool, err 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