Versions in this module Expand all Collapse all v1 v1.0.18 Oct 26, 2016 Changes in this version + func URLAddParseTime(s string) (string, error) + type Body interface + Bytes func() []byte + type Category interface + String func() string + type DeviceID interface + Bytes func() []byte + String func() string + type Dismissal interface + MsgIDsToDismiss func() []MsgID + RangesToDismiss func() []MsgRange + type FastLookupState struct + func NewFastLookupState(state State, table map[string]Item) FastLookupState + func (fs FastLookupState) Export() (ProtocolState, error) + func (fs FastLookupState) GetItem(msgID MsgID) (Item, bool) + func (fs FastLookupState) Hash() ([]byte, error) + func (fs FastLookupState) Items() (Item, bool) + func (fs FastLookupState) ItemsInCategory(c Category) ([]Item, error) + func (fs FastLookupState) ItemsWithCategoryPrefix(c Category) ([]Item, error) + func (fs FastLookupState) Marshal() ([]byte, error) + type InBandMessage interface + Merge func(m1 InBandMessage) error + ToStateSyncMessage func() StateSyncMessage + ToStateUpdateMessage func() StateUpdateMessage + type InBandMsgType int + const InBandMsgTypeNone + const InBandMsgTypeSync + const InBandMsgTypeUpdate + type Item interface + Body func() Body + Category func() Category + DTime func() TimeOrOffset + RemindTimes func() []TimeOrOffset + type MainLoopServer interface + ListenLoop func(n net.Listener) error + type Message interface + ToInBandMessage func() InBandMessage + ToOutOfBandMessage func() OutOfBandMessage + type MessageConsumer interface + ConsumeMessage func(m Message) (time.Time, error) + type MessageWithMetadata interface + Metadata func() Metadata + type Metadata interface + CTime func() time.Time + DeviceID func() DeviceID + InBandMsgType func() InBandMsgType + MsgID func() MsgID + UID func() UID + type MsgID interface + Bytes func() []byte + String func() string + type MsgRange interface + Category func() Category + EndTime func() TimeOrOffset + type ObjFactory interface + MakeBody func(b []byte) (Body, error) + MakeCategory func(s string) (Category, error) + MakeDeviceID func(b []byte) (DeviceID, error) + MakeDismissalByIDs func(uid UID, msgid MsgID, devid DeviceID, ctime time.Time, d []MsgID) (InBandMessage, error) + MakeDismissalByRange func(uid UID, msgid MsgID, devid DeviceID, ctime time.Time, c Category, d time.Time) (InBandMessage, error) + MakeInBandMessageFromItem func(i Item) (InBandMessage, error) + MakeItem func(u UID, msgid MsgID, deviceid DeviceID, ctime time.Time, c Category, ...) (Item, error) + MakeMessageFromInBandMessage func(i InBandMessage) (Message, error) + MakeMetadata func(uid UID, msgid MsgID, devid DeviceID, ctime time.Time, i InBandMsgType) (Metadata, error) + MakeMsgID func(b []byte) (MsgID, error) + MakeReminder func(i Item, seqno int, t time.Time) (Reminder, error) + MakeReminderID func(u UID, msgid MsgID, seqno int) (ReminderID, error) + MakeReminderSetFromReminders func([]Reminder, bool) (ReminderSet, error) + MakeState func(i []Item) (State, error) + MakeStateSyncMessage func(uid UID, msgid MsgID, devid DeviceID, ctime time.Time) (InBandMessage, error) + MakeStateWithLookupTable func(i []Item, table map[string]Item) (State, error) + MakeTimeOrOffsetFromOffset func(d time.Duration) (TimeOrOffset, error) + MakeTimeOrOffsetFromTime func(t time.Time) (TimeOrOffset, error) + MakeUID func(b []byte) (UID, error) + UnmarshalState func([]byte) (State, error) + type OutOfBandMessage interface + Body func() Body + System func() System + UID func() UID + type ProtocolState interface + ProtocolName func() string + type Reminder interface + Item func() Item + RemindTime func() time.Time + Seqno func() int + type ReminderID interface + MsgID func() MsgID + Seqno func() int + UID func() UID + type ReminderSet interface + MoreRemindersReady func() bool + Reminders func() []Reminder + type State interface + Export func() (ProtocolState, error) + GetItem func(msgID MsgID) (Item, bool) + Hash func() ([]byte, error) + Items func() ([]Item, error) + ItemsInCategory func(c Category) ([]Item, error) + ItemsWithCategoryPrefix func(c Category) ([]Item, error) + Marshal func() ([]byte, error) + type StateMachine interface + Clear func() error + Clock func() clockwork.Clock + DeleteReminder func(r ReminderID) error + InBandMessagesSince func(u UID, d DeviceID, t time.Time) ([]InBandMessage, error) + InitState func(s State) error + IsEphemeral func() bool + LatestCTime func(u UID, d DeviceID) *time.Time + ObjFactory func() ObjFactory + ReminderLockDuration func() time.Duration + Reminders func(maxReminders int) (ReminderSet, error) + State func(u UID, d DeviceID, t TimeOrOffset) (State, error) + StateByCategoryPrefix func(u UID, d DeviceID, t TimeOrOffset, cp Category) (State, error) + type StateSyncMessage interface + type StateUpdateMessage interface + Creation func() Item + Dismissal func() Dismissal + type System interface + String func() string + type TimeOrOffset interface + Before func(t time.Time) bool + Offset func() *time.Duration + Time func() *time.Time + type UID interface + Bytes func() []byte + String func() string + func UIDFromMessage(m Message) UID