remote

Apr 27, 2026

Changes in this version

type HTTPStatusError

+ func (e *HTTPStatusError) IsRepairable() bool

Apr 24, 2026

Changes in this version

+ type HTTPStatusError struct

+ Body string

+ ErrorClass string

+ ErrorCode string

+ Operation string

+ StatusCode int

+ func (e *HTTPStatusError) Error() string

+ func (e *HTTPStatusError) IsAuthFailure() bool

+ func (e *HTTPStatusError) IsPolicyFailure() bool

+ func (e *HTTPStatusError) IsRepairableMigrationFailure() bool

type MutationEntry

+ Project string

+ type MutationTransport struct

+ func NewMutationTransport(baseURL, token string) (*MutationTransport, error)

+ func (mt *MutationTransport) PullMutations(sinceSeq int64, limit int) (*PullMutationsResponse, error)

+ func (mt *MutationTransport) PushMutations(entries []MutationEntry) ([]int64, error)

type PullMutationsResponse

+ LatestSeq int64

+ type PulledMutation struct

+ Entity string

+ EntityKey string

+ OccurredAt string

+ Op string

+ Payload json.RawMessage

+ Seq int64

type PushMutationsResult

+ AcceptedSeqs []int64

Mar 7, 2026

Changes in this version

+ type MutationEntry struct

+ Entity string

+ EntityKey string

+ Op string

+ Payload json.RawMessage

+ type PullMutationResult struct

+ Entity string

+ EntityKey string

+ OccurredAt string

+ Op string

+ Payload json.RawMessage

+ Seq int64

+ type PullMutationsResponse struct

+ HasMore bool

+ Mutations []PullMutationResult

+ type PushMutationsResult struct

+ Accepted int

+ LastSeq int64

+ type RemoteTransport struct

+ func NewRemoteTransport(baseURL, token string) (*RemoteTransport, error)

+ func (rt *RemoteTransport) PullMutations(sinceSeq int64, limit int) (*PullMutationsResponse, error)

+ func (rt *RemoteTransport) PushMutations(mutations []MutationEntry) (*PushMutationsResult, error)

+ func (rt *RemoteTransport) ReadChunk(chunkID string) ([]byte, error)

+ func (rt *RemoteTransport) ReadManifest() (*engramsync.Manifest, error)

+ func (rt *RemoteTransport) SetTokenRefresher(refreshToken string, onTokenRefresh func(string) error)

+ func (rt *RemoteTransport) WriteChunk(chunkID string, data []byte, entry engramsync.ChunkEntry) error

+ func (rt *RemoteTransport) WriteManifest(_ *engramsync.Manifest) error