submission

type Acknowledgement struct {
	Fingerprint string    `json:"fingerprint"`
	StateID     string    `json:"stateId"`
	ContextID   string    `json:"contextId"`
	At          time.Time `json:"at"`
}

type Destination struct {
	Target          Target
	Endpoint, Token string

	Progress func(ingestion.Job)
	// contains filtered or unexported fields
}

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

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

type SyncOptions struct {
	StateDir, Server, Token string
	Fresh                   *ingestion.Request
	// Fingerprint identifies content plus the metadata that must still upload.
	Fingerprint func(ingestion.Request) string
	Progress    func(string)
}

type SyncResult struct {
	Uploaded, Unchanged int
	Failures            []error
	// Empty means no retained or fresh submission was eligible for upload.
	Empty bool
}

type Target struct{ Destination, Identity, SourceID string }