Documentation
¶
Index ¶
- type DBSub
- type Store
- func (s *Store) IncrementSubscriptionSequenceNumber(ctx context.Context, subscriptionID string) (uint64, error)
- func (s *Store) LoadSubscriptions(ctx context.Context, query store.SubscriptionQuery, ...) error
- func (s *Store) PopSubscription(ctx context.Context, subscriptionID string) (sub store.Subscription, err error)
- func (s *Store) SaveSubscription(ctx context.Context, sub store.Subscription) error
- func (s *Store) SetInitialized(ctx context.Context, subscriptionID string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DBSub ¶
type DBSub struct {
ID string `bson:"_id"`
URL string
CorrelationID string // uuid
Type store.Type
Accept []string
EventTypes events.EventTypes
DeviceID string `bson:"deviceid"`
Href string `bson:"href"`
SequenceNumber uint64 `bson:"sequencenumber"`
SigningSecret string
Initialized bool `bson:"initialized"`
AccessToken string
}
type Store ¶
func (*Store) IncrementSubscriptionSequenceNumber ¶
func (*Store) LoadSubscriptions ¶
func (s *Store) LoadSubscriptions(ctx context.Context, query store.SubscriptionQuery, h store.SubscriptionHandler) error
func (*Store) PopSubscription ¶
func (*Store) SaveSubscription ¶
Click to show internal directories.
Click to hide internal directories.