clienttest

type Capture struct {
	Epoch      protocol.EpochID
	Watermark  uint64
	Committed  uint64
	AnchorHash protocol.Hash
	Summary    protocol.SummaryParams
}

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

type Episode struct {
	ID             string
	DedupKey       string
	State          string
	FirstSeen      uint64
	LastTransition uint64
	EvalTime       uint64
	Count          uint64
	Seq            uint64
}

type StateQueryResult struct {
	Source    string   `json:"source"`
	Resources []string `json:"resources"`
	Truncated bool     `json:"truncated"`
}

type Writer struct {
	Store *client.MemStore
	Clock *Clock
	// AnchorMutator, when set, alters the state written into replay anchors.
	AnchorMutator func(*protocol.State)
	// OnBundle, when set, is called for every bundle.available.
	OnBundle func(protocol.BundleAvailableParams)
	// contains filtered or unexported fields
}