Documentation
¶
Overview ¶
Package events publishes durable domain events and accesses the platformd notification service (ADR-0035).
Index ¶
- func Causation(ctx context.Context) string
- func WithCausation(ctx context.Context, eventID string) context.Context
- type Client
- func (c *Client) List(ctx context.Context, login, after string, limit int) (Page, error)
- func (c *Client) Mutate(ctx context.Context, login, id, action string) (int, error)
- func (c *Client) Publish(ctx context.Context, user auth.User, event Event) error
- func (c *Client) Stream(ctx context.Context, login string, fn func(Notification) error) error
- func (c *Client) Unread(ctx context.Context, login string) (int, error)
- type Event
- type Notification
- type Page
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
type Notification ¶
type Notification struct {
ID string `json:"id,omitempty"`
EventID string `json:"event_id,omitempty"`
Source string `json:"source,omitempty"`
Title string `json:"title"`
Body string `json:"body,omitempty"`
AppSlug string `json:"app_slug,omitempty"`
Path string `json:"path,omitempty"`
URL string `json:"url,omitempty"`
GroupKey string `json:"group_key,omitempty"`
DedupKey string `json:"dedup_key,omitempty"`
CreatedAt string `json:"created_at,omitempty"`
ReadAt *string `json:"read_at"`
DismissedAt *string `json:"dismissed_at"`
Retired bool `json:"source_retired,omitempty"`
}
type Page ¶
type Page struct {
Notifications []Notification `json:"notifications"`
Next string `json:"next"`
}
Click to show internal directories.
Click to hide internal directories.