Documentation
¶
Index ¶
Constants ¶
View Source
const ( MaxCheckpointBytes = 64 << 10 MaxSourceSnapshotBytes = 64 << 10 MaxErrorSamples = 32 MaxErrorSampleBytes = 2048 MaxActorBytes = 256 )
Variables ¶
This section is empty.
Functions ¶
func AddErrorSample ¶
func NormalizeCheckpoint ¶
func NormalizeCheckpoint(checkpoint []byte) (json.RawMessage, error)
func NormalizeSourceSnapshot ¶
func NormalizeSourceSnapshot(snapshot []byte) (json.RawMessage, error)
Types ¶
type Counts ¶
type Run ¶
type Run struct {
ID shared.ID `json:"id"`
SourceID shared.ID `json:"source_id"`
AdapterType string `json:"adapter_type"`
SourceSnapshot json.RawMessage `json:"source_snapshot,omitempty"`
Mode Mode `json:"mode"`
Trigger string `json:"trigger"`
Actor string `json:"actor"`
ClientIdempotencyKey string `json:"client_idempotency_key,omitempty"`
DurableJobID string `json:"durable_job_id,omitempty"`
Checkpoint json.RawMessage `json:"checkpoint,omitempty"`
Counts Counts `json:"counts"`
ErrorSamples []string `json:"error_samples,omitempty"`
State State `json:"state"`
StartedAt *time.Time `json:"started_at,omitempty"`
FinishedAt *time.Time `json:"finished_at,omitempty"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
Click to show internal directories.
Click to hide internal directories.