provider

type Authenticate func(*http.Request) (Peer, error)

type Authorize func(Peer, replica.Manifest, replica.Dot) error

type AuthorizeAwareness func(Peer, replica.Manifest, awareness.Update) error

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

type ClientConfig struct {
	Header          http.Header
	Policy          crdt.ProtocolPolicy
	MaxMessageBytes int
	MaxActorBytes   int
	// EnableBatches negotiates BatchSubprotocol and allows PublishBatch. Each
	// contained change retains its own Dot; v1 remains the default.
	EnableBatches   bool
	MaxBatchChanges int
	// EnableAwareness requires the opt-in crdt-sync-v3 subprotocol. OnAwareness
	// receives only authenticated, bounded, transient messages; applications
	// should apply them to their own awareness.Store rather than a CRDT inbox.
	EnableAwareness  bool
	AwarenessOptions awareness.Options
	OnAwareness      func(awareness.Update) error
	HandshakeTimeout time.Duration
	WriteTimeout     time.Duration
	OnChange         func(replica.Change) error
}

type Config struct {
	Groups             []*Group
	Authenticate       Authenticate
	Authorize          Authorize
	AuthorizeAwareness AuthorizeAwareness
	OriginPatterns     []string
	MaxMessageBytes    int
	MaxActorBytes      int
	MaxQueuedMessages  int
	MaxBatchChanges    int
	HandshakeTimeout   time.Duration
	WriteTimeout       time.Duration
}

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

type GroupConfig struct {
	Manifest          replica.Manifest
	Frontier          replica.Frontier
	Policy            crdt.ProtocolPolicy
	MaxPendingChanges int
	MaxPendingBytes   int
	Apply             replica.ApplyDelta
	// Awareness is an optional in-memory, short-lived store. Do not restore it
	// from a CRDT checkpoint; clean disconnects should publish a removal and
	// broken connections naturally disappear after its TTL.
	Awareness *awareness.Store
}

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

type Peer struct {
	ID string
}