extensions

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

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

type AuthorizeSubscription func(Peer, replica.Manifest) error

type ClientConfig struct {
	Header          http.Header
	HTTPClient      *http.Client
	Policy          crdt.ProtocolPolicy
	MaxMessageBytes int
	MaxActorBytes   int
	// EnableBatches offers BatchSubprotocol in addition to Subprotocol. It
	// remains false by default so an existing client keeps its v1 contract.
	EnableBatches bool
	// MaxBatchChanges is a local publication and receive bound when
	// EnableBatches is true. It must not exceed the relay's configured bound;
	// both sides default to 16. It is ignored for a v1-only connection.
	MaxBatchChanges  int
	HandshakeTimeout time.Duration
	WriteTimeout     time.Duration
	OnChange         func(replica.Change) error
}

type Config struct {
	Features              Feature
	Groups                []*Group
	Authenticate          Authenticate
	Authorize             Authorize
	AuthorizeSubscription AuthorizeSubscription
	// OriginPatterns lists case-insensitive host patterns permitted to make
	// browser-originated cross-origin requests, for example "app.example" or
	// "*.example.internal". It uses path.Match syntax, so "*" is rejected.
	// The request host is always permitted. These are host patterns rather than
	// URL strings so HTTP and WebSocket apply the same rule.
	OriginPatterns    []string
	MaxMessageBytes   int
	MaxActorBytes     int
	MaxQueuedMessages int
	MaxQueuedBytes    int
	// MaxBatchChanges bounds independently identified changes in one
	// crdt-sync-v2 WebSocket message. It is relevant only when
	// FeatureWebSocketBatch is enabled and cannot exceed MaxQueuedMessages,
	// so v1 and SSE peers can be queued atomically or disconnected.
	MaxBatchChanges  int
	HandshakeTimeout time.Duration
	WriteTimeout     time.Duration
}

type Feature uint8

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
}

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

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

type Peer struct {
	ID string
}

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