Documentation ¶
Index ¶
- type Message
- type MessageParams
- type Operator
- func (o *Operator) Append(ctx context.Context, s cadata.Store, x State, mp MessageParams) (*State, error)
- func (o *Operator) Merge(ctx context.Context, s cadata.Store, xs []State) (*State, error)
- func (o *Operator) NewEmpty(ctx context.Context, s cadata.Store) (*State, error)
- func (o *Operator) Read(ctx context.Context, s cadata.Store, x State, begin Path, buf []Message) (int, error)
- func (o *Operator) Sync(ctx context.Context, src cadata.Getter, dst cadata.Store, x State) error
- func (o *Operator) Validate(ctx context.Context, s cadata.Getter, consult owldag.ConsultFunc, x State) error
- func (o *Operator) ValidateStep(ctx context.Context, s cadata.Getter, consult owldag.ConsultFunc, ...) error
- type Path
- type Scheme
- func (p *Scheme) CanRead(ctx context.Context, s cadata.Getter, x State, peer owldag.PeerID) (bool, error)
- func (p *Scheme) ListPeers(ctx context.Context, s cadata.Getter, x State) ([]owldag.PeerID, error)
- func (p *Scheme) Merge(ctx context.Context, s cadata.Store, xs []State) (*State, error)
- func (p *Scheme) Sync(ctx context.Context, src cadata.Getter, dst cadata.Store, x State) error
- func (p *Scheme) Validate(ctx context.Context, s cadata.Getter, consult owldag.ConsultFunc, x State) error
- func (p *Scheme) ValidateStep(ctx context.Context, s cadata.Getter, consult owldag.ConsultFunc, ...) error
- type State
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageParams ¶
type MessageParams struct { Author owldag.PeerID Timestamp tai64.TAI64N Type string Body json.RawMessage }
type Operator ¶
type Operator struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.