connect

type Call struct {
	InstanceID  string          `json:"instance_id"`
	Service     string          `json:"service"`
	Method      string          `json:"method"`
	SessionID   string          `json:"session_id,omitempty"`
	Expected    Expected        `json:"expected"`
	OperationID string          `json:"operation_id,omitempty"`
	Args        json.RawMessage `json:"args"`
}

type Endpoint interface {
	Invoke(context.Context, string, json.RawMessage) (json.RawMessage, error)
	Close() error
}

type Error struct {
	Kind string `json:"kind"`
}

type Event struct {
	Cursor string          `json:"cursor"`
	Data   json.RawMessage `json:"data"`
}

type Expected struct {
	Generation string `json:"registration_generation"`
	Revision   string `json:"session_revision"`
}

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

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

type Model struct {
	ID       string   `json:"id"`
	Provider string   `json:"provider"`
	Name     string   `json:"name"`
	Thinking []string `json:"thinking,omitempty"`
}

type Principal struct {
	PeerID  string  `json:"peer_id"`
	Subject Subject `json:"subject"`
}

type Receipt struct {
	InstanceID  string          `json:"instance_id"`
	SessionID   string          `json:"session_id,omitempty"`
	Method      string          `json:"method"`
	Expected    Expected        `json:"expected"`
	AcceptedAt  int64           `json:"accepted_at"`
	OperationID string          `json:"operation_id"`
	Status      string          `json:"status"`
	Result      json.RawMessage `json:"result,omitempty"`
	Error       string          `json:"error,omitempty"`
	Digest      string          `json:"digest"`
}

type Request struct {
	PageLimit  int       `json:"page_limit,omitempty"`
	Principal  Principal `json:"principal"`
	Generation string    `json:"generation"`
	Call       Call      `json:"call"`
}

type Snapshot struct {
	Cursor string  `json:"cursor"`
	Events []Event `json:"events"`
}

type Store interface {
	Load() ([]byte, error)
	Save([]byte) error
}

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

type Subject struct {
	Kind       string `json:"kind"`
	InstanceID string `json:"instance_id,omitempty"`
}