Documentation
¶
Overview ¶
Package queue defines the durable asynchronous mutation publisher contract.
Index ¶
- func MarshalMutation(mutation Mutation) ([]byte, error)
- func MutationKey(mutation Mutation) ([]byte, error)
- func MutationSize(mutation Mutation) int
- func MutationStore(mutation Mutation) (string, error)
- type Mutation
- type PublishRequest
- type PublishResponse
- type PublishResult
- type PublishStatus
- type Publisher
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MarshalMutation ¶
func MutationKey ¶
func MutationSize ¶
MutationSize includes the queue envelope without allocating its payload.
func MutationStore ¶
Types ¶
type Mutation ¶
type Mutation struct {
Write *sink.WriteOperation
Delete *sink.DeleteOperation
}
func UnmarshalMutation ¶
type PublishRequest ¶
type PublishRequest struct {
Mutations []Mutation
}
type PublishResponse ¶
type PublishResponse struct {
Results []PublishResult
}
type PublishResult ¶
type PublishResult struct {
Status PublishStatus
Err error
}
type PublishStatus ¶
type PublishStatus uint8
const ( PublishStatusUnspecified PublishStatus = iota PublishStatusAccepted PublishStatusFailed )
type Publisher ¶
type Publisher interface {
Publish(ctx context.Context, req PublishRequest) (PublishResponse, error)
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.