oplog

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

type OpMetadata struct {
	ID             int64
	FlowID         int64
	Modno          int64
	OriginalID     int64
	OriginalFlowID int64
}

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)
	// 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
	// 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
	SnapshotID     *string
	FlowID         *int64
	InstanceID     *string
	OriginalID     *int64
	OriginalFlowID *int64

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

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