Documentation
¶
Overview ¶
Package submission preserves immutable manual uploads across CLI invocations.
Index ¶
- type Acknowledgement
- type Destination
- func (target *Destination) Current(ctx context.Context, id string) (bool, error)
- func (target *Destination) Deliver(ctx context.Context, request ingestion.Request) (result ingestion.Receipt, failure error)
- func (target *Destination) SuppressInitialEmpty(ctx context.Context, request ingestion.Request) (bool, error)
- type Outbox
- func (box *Outbox) Acknowledge(request ingestion.Request, fingerprint, stateID, contextID string) error
- func (box *Outbox) Acknowledgement(request ingestion.Request) (Acknowledgement, error)
- func (box *Outbox) Close() error
- func (box *Outbox) Pending() ([]Pending, error)
- func (box *Outbox) Remove(id string) error
- func (box *Outbox) Save(pending Pending) error
- type Pending
- type Target
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Acknowledgement ¶
type Acknowledgement struct {
Fingerprint string `json:"fingerprint"`
StateID string `json:"stateId"`
ContextID string `json:"contextId"`
At time.Time `json:"at"`
}
Acknowledgement permits upload suppression only while its server context remains current. Fingerprints are supplied by the collector composition.
type Destination ¶
type Destination struct {
Target Target
Endpoint, Token string
Progress func(ingestion.Job)
// contains filtered or unexported fields
}
func (*Destination) SuppressInitialEmpty ¶
type Outbox ¶
type Outbox struct {
// contains filtered or unexported fields
}
func (*Outbox) Acknowledge ¶
func (*Outbox) Acknowledgement ¶
func (box *Outbox) Acknowledgement(request ingestion.Request) (Acknowledgement, error)
Click to show internal directories.
Click to hide internal directories.