notify

Documentation

Index

• type Notify
  • func NewNotify(s metastore.NotificationRecorder) *Notify
  • func (n *Notify) CommitSyncedEvent(ctx context.Context, deviceID string, sequence int64) error
  • func (n *Notify) GetLatestSequence(ctx context.Context) (int64, error)
  • func (n *Notify) ListNotifications(ctx context.Context) ([]types.Notification, error)
  • func (n *Notify) ListUnSyncedEvent(ctx context.Context, sequence int64) ([]types.Event, error)
  • func (n *Notify) MarkRead(ctx context.Context, nid string) error
  • func (n *Notify) RecordInfo(ctx context.Context, title, message, source string) error
  • func (n *Notify) RecordWarn(ctx context.Context, title, message, source string) error

Types

type Notify

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

func NewNotify

func NewNotify(s metastore.NotificationRecorder) *Notify

func (*Notify) CommitSyncedEvent

func (n *Notify) CommitSyncedEvent(ctx context.Context, deviceID string, sequence int64) error

func (*Notify) GetLatestSequence

func (n *Notify) GetLatestSequence(ctx context.Context) (int64, error)

func (*Notify) ListNotifications

func (n *Notify) ListNotifications(ctx context.Context) ([]types.Notification, error)

func (*Notify) ListUnSyncedEvent

func (n *Notify) ListUnSyncedEvent(ctx context.Context, sequence int64) ([]types.Event, error)

func (*Notify) MarkRead

func (n *Notify) MarkRead(ctx context.Context, nid string) error

func (*Notify) RecordInfo

func (n *Notify) RecordInfo(ctx context.Context, title, message, source string) error

func (*Notify) RecordWarn

func (n *Notify) RecordWarn(ctx context.Context, title, message, source string) error