submission

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 11, 2026 License: MIT Imports: 15 Imported by: 0

Documentation

Overview

Package submission preserves immutable manual uploads across CLI invocations.

Index

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 Resolve

func Resolve(ctx context.Context, endpoint, token string) (*Destination, error)

func (*Destination) Current

func (target *Destination) Current(ctx context.Context, id string) (bool, error)

func (*Destination) Deliver

func (target *Destination) Deliver(ctx context.Context, request ingestion.Request) (result ingestion.Receipt, failure error)

func (*Destination) SuppressInitialEmpty

func (target *Destination) SuppressInitialEmpty(ctx context.Context, request ingestion.Request) (bool, error)

type Outbox

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

func Open

func Open(ctx context.Context, root, route string) (*Outbox, error)

func (*Outbox) Acknowledge

func (box *Outbox) Acknowledge(request ingestion.Request, fingerprint, stateID, contextID string) error

func (*Outbox) Acknowledgement

func (box *Outbox) Acknowledgement(request ingestion.Request) (Acknowledgement, error)

func (*Outbox) Close

func (box *Outbox) Close() error

func (*Outbox) Pending

func (box *Outbox) Pending() ([]Pending, error)

func (*Outbox) Remove

func (box *Outbox) Remove(id string) error

func (*Outbox) Save

func (box *Outbox) Save(pending Pending) error

type Pending

type Pending struct {
	Request ingestion.Request `json:"request"`
	StateID string            `json:"stateId,omitempty"`
}

type Target

type Target struct{ Destination, Identity, SourceID string }

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL