notifications

type Binding[M model.Identifiable, K, P any] struct {
	// contains filtered or unexported fields
}

type BulkResult[M any] struct {
	Stored       []ID[M]
	Unconfirmed  []ID[M]
	NotAttempted []ID[M]
}

type Channel[M, P any] struct {
	// contains filtered or unexported fields
}

type ChannelID string

type ChannelStatus struct {
	Channel  ChannelID
	State    State
	Attempts uint32
}

type ClientChannelInfo struct {
	ID       ChannelID           `json:"id"`
	Kind     string              `json:"kind"`
	Payload  contract.Schema     `json:"payload"`
	Realtime *ClientRealtimeInfo `json:"realtime,omitempty"`
}

type ClientNotificationInfo struct {
	Recipient RecipientName       `json:"recipient"`
	Name      Name                `json:"name"`
	Version   Version             `json:"version"`
	Channels  []ClientChannelInfo `json:"channels"`
}

type ClientRealtimeInfo struct {
	Channel websocket.ChannelID `json:"channel"`
	Event   websocket.EventID   `json:"event"`
}

type Config struct {
	Schema    string
	Clock     clock.Clock
	MaxActive int
	Timeout   time.Duration
}

type DatabaseChannel[M, P, D any] struct {
	// contains filtered or unexported fields
}

type Definition[P any] struct {
	// contains filtered or unexported fields
}

type DeliveryContext struct {
	Notification NotificationID
	Delivery     DeliveryID
	Name         Name
	Version      Version
	Channel      ChannelID
}

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

type DeliveryInfo struct {
	ID           DeliveryID     `json:"-"`
	Key          string         `json:"id"`
	Notification NotificationID `json:"notification_id"`
	Channel      ChannelID      `json:"channel"`
	Kind         string         `json:"kind"`
	State        State          `json:"state"`
	Attempts     uint32         `json:"attempts"`
	UpdatedAt    time.Time      `json:"updated_at"`
}

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

type DeliveryRequest struct {
	ID NotificationID `json:"id"`
}

type ID[M any] = model.ID[NotificationOf[M]]

type Inbox[M model.Identifiable, K any] struct {
	// contains filtered or unexported fields
}

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

type Name string

type Notification struct{}

type NotificationID = model.ID[Notification]

type NotificationOf[M any] struct {
	// contains filtered or unexported fields
}

type Outcome uint8

type PendingNotification[M, P any] struct {
	// contains filtered or unexported fields
}

type Realtime[C any, M model.Identifiable, K comparable, D any] struct {
	// contains filtered or unexported fields
}

type RealtimeMessage[D any] struct {
	ID      NotificationID `json:"id"`
	Name    Name           `json:"name"`
	Version Version        `json:"version"`
	Data    D              `json:"data"`
}

type Recipient[M model.Identifiable, K any] struct {
	// contains filtered or unexported fields
}

type RecipientName string

type Record[M any] struct {
	ID        ID[M]
	Name      Name
	Version   Version
	CreatedAt temporal.DateTime
	ReadAt    value.Nullable[temporal.DateTime]
	// contains filtered or unexported fields
}

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

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

type Renderer[M, P, D any] func(context.Context, M, DeliveryContext, P) (D, error)

type Report[M any] struct {
	ID       ID[M]
	Channels []ChannelStatus
}

type Resolution string

type Route struct {
	Email   email.Address `json:"email,omitzero"`
	Address string        `json:"address,omitempty"`
}

type State string

type Transport[D any] interface {
	// Deliver delivers a typed payload with its delivery identifier.
	Deliver(context.Context, DeliveryID, D) (Outcome, error)
}

type Version uint32