oplog

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

type OpMetadata struct {
	ID             int64
	FlowID         int64
	Modno          int64
	OriginalID     int64
	OriginalFlowID int64
	Status         v1.OperationStatus
	RepoID         string
	RepoGUID       string
	PlanID         string
}

type OpStore interface {
	// Query returns all operations that match the query.
	Query(q Query, f func(*v1.Operation) error) error
	// QueryMetadata is like Query, but only returns metadata about the operations.
	// this is useful for very high performance scans that don't deserialize the operation itself.
	QueryMetadata(q Query, f func(OpMetadata) error) error
	// Get returns the operation with the given ID.
	Get(opID int64) (*v1.Operation, error)
	// GetHighestOpIDAndModno returns the highest operation ID and modno in the store, used for synchronization.
	GetHighestOpIDAndModno(q Query) (int64, int64, error)
	// Add adds the given operations to the store.
	Add(op ...*v1.Operation) error
	// Update updates the given operations in the store.
	Update(op ...*v1.Operation) error
	// Set inserts or updates operations. Zero-valued fields (Id, Modno, FlowId) are
	// allocated automatically (like Add/Update), but non-zero values provided by the
	// caller are preserved. If Id is non-zero, it updates; if Id is zero, it inserts.
	Set(opts SetOptions, op ...*v1.Operation) error
	// Delete removes the operations with the given IDs from the store, and returns the removed operations.
	Delete(opID ...int64) ([]*v1.Operation, error)
	// Transform applies the given function to each operation that matches the query.
	Transform(q Query, f func(*v1.Operation) (*v1.Operation, error)) error
	// Version returns the current data version
	Version() (int64, error)
	// SetVersion sets the data version
	SetVersion(version int64) error
}

type OperationEvent int

type Query struct {
	// Filter by fields
	OpIDs                 []int64
	PlanID                *string
	RepoGUID              *string
	DeprecatedRepoID      *string // Deprecated: use RepoGUID instead
	SnapshotID            *string
	FlowID                *int64
	InstanceID            *string
	OriginalInstanceKeyid *string
	OriginalID            *int64
	OriginalFlowID        *int64
	ModnoGte              *int64

	// Pagination
	Limit    int
	Offset   int
	Reversed bool
	// contains filtered or unexported fields
}

type SetOptions struct {
	InsertOnly bool // If true, only insert; fail if the operation already exists (Id != 0).
	UpdateOnly bool // If true, only update; fail if the operation does not exist (Id == 0).
	AllocateID bool // If true, allocate a new Id for operations with Id == 0.
}

type Subscription = func(ops []*v1.Operation, event OperationEvent)