storage

Documentation

Index

• type Client
  • func NewClient(user gregor.UID, device gregor.DeviceID, sm gregor.StateMachine, ...) *Client
  • func (c *Client) InBandMessagesFromState(s gregor.State) ([]gregor.InBandMessage, error)
  • func (c *Client) Restore() error
  • func (c *Client) Save(ctx context.Context) error
  • func (c *Client) State(cli gregor1.IncomingInterface) (res gregor.State, err error)
  • func (c *Client) StateMachineConsumeMessage(ctx context.Context, m gregor1.Message) error
  • func (c *Client) StateMachineInBandMessagesSince(ctx context.Context, t time.Time) ([]gregor.InBandMessage, error)
  • func (c *Client) StateMachineLatestCTime(ctx context.Context) *time.Time
  • func (c *Client) StateMachineState(ctx context.Context, t gregor.TimeOrOffset) (gregor.State, error)
  • func (c *Client) Sync(ctx context.Context, cli gregor1.IncomingInterface, ...) (res []gregor.InBandMessage, err error)
  • func (c *Client) SyncFromTime(ctx context.Context, cli gregor1.IncomingInterface, t *time.Time, ...) (msgs []gregor.InBandMessage, err error)
• type ErrHashMismatch
  • func (e ErrHashMismatch) Error() string
• type LocalStorageEngine

Types

type Client

type Client struct {
	User    gregor.UID
	Device  gregor.DeviceID
	Sm      gregor.StateMachine
	Storage LocalStorageEngine
	Log     rpc.LogOutput

	SaveTimer <-chan time.Time
}

func NewClient

func NewClient(user gregor.UID, device gregor.DeviceID, sm gregor.StateMachine,
	storage LocalStorageEngine, saveInterval time.Duration, log rpc.LogOutput) *Client

func (*Client) InBandMessagesFromState

func (c *Client) InBandMessagesFromState(s gregor.State) ([]gregor.InBandMessage, error)

func (*Client) Restore

func (c *Client) Restore() error

func (*Client) Save

func (c *Client) Save(ctx context.Context) error

func (*Client) State

func (c *Client) State(cli gregor1.IncomingInterface) (res gregor.State, err error)

func (*Client) StateMachineConsumeMessage

func (c *Client) StateMachineConsumeMessage(ctx context.Context, m gregor1.Message) error

func (*Client) StateMachineInBandMessagesSince

func (c *Client) StateMachineInBandMessagesSince(ctx context.Context, t time.Time) ([]gregor.InBandMessage, error)

func (*Client) StateMachineLatestCTime

func (c *Client) StateMachineLatestCTime(ctx context.Context) *time.Time

func (*Client) StateMachineState

func (c *Client) StateMachineState(ctx context.Context, t gregor.TimeOrOffset) (gregor.State, error)

func (*Client) Sync

func (c *Client) Sync(ctx context.Context, cli gregor1.IncomingInterface,
	syncRes *chat1.SyncAllNotificationRes) (res []gregor.InBandMessage, err error)

func (*Client) SyncFromTime

func (c *Client) SyncFromTime(ctx context.Context, cli gregor1.IncomingInterface, t *time.Time,
	syncResult *gregor1.SyncResult) (msgs []gregor.InBandMessage, err error)

type ErrHashMismatch

type ErrHashMismatch struct{}

func (ErrHashMismatch) Error

func (e ErrHashMismatch) Error() string

type LocalStorageEngine

type LocalStorageEngine interface {
	Store(gregor.UID, []byte) error
	Load(gregor.UID) ([]byte, error)
}