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() error
  • func (c *Client) State(cli gregor1.IncomingInterface) (gregor.State, error)
  • func (c *Client) StateMachineConsumeMessage(m gregor1.Message) error
  • func (c *Client) StateMachineInBandMessagesSince(t time.Time) ([]gregor.InBandMessage, error)
  • func (c *Client) StateMachineLatestCTime() *time.Time
  • func (c *Client) StateMachineState(t gregor.TimeOrOffset) (gregor.State, error)
  • func (c *Client) Sync(cli gregor1.IncomingInterface) ([]gregor.InBandMessage, error)
  • func (c *Client) SyncFromTime(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() error

func (*Client) State

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

func (*Client) StateMachineConsumeMessage

func (c *Client) StateMachineConsumeMessage(m gregor1.Message) error

func (*Client) StateMachineInBandMessagesSince

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

func (*Client) StateMachineLatestCTime

func (c *Client) StateMachineLatestCTime() *time.Time

func (*Client) StateMachineState

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

func (*Client) Sync

func (c *Client) Sync(cli gregor1.IncomingInterface) ([]gregor.InBandMessage, error)

func (*Client) SyncFromTime

func (c *Client) SyncFromTime(cli gregor1.IncomingInterface, t *time.Time) (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)
}