common

type Call interface {
	Complete() <-chan any
}

type ClientConfig struct {
	ServiceAddr         string
	Namespace           string
	BatchLinger         time.Duration
	MaxRequestsPerBatch int
	RequestTimeout      time.Duration
}

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

type Input interface {
	Unmarshal(b []byte) (Query, error)
}

type OutputError struct {
	Err string `json:"error,omitempty"`
}

type OutputVersion struct {
	VersionId          int64     `json:"version_id"`
	CreatedTimestamp   time.Time `json:"created_timestamp"`
	ModifiedTimestamp  time.Time `json:"modified_timestamp"`
	ModificationsCount int64     `json:"modifications_count"`
	Ephemeral          bool      `json:"ephemeral"`
	ClientIdentity     string    `json:"client_identity"`
}

type Query interface {
	Perform(client oxia.AsyncClient) Call
}

type QueryQueue interface {
	Add(query Query)
}