stream

type AcknowledgeRequest struct {
	StreamID   string `json:"stream_id"`
	DeliveryID string `json:"delivery_id"`
}

type AppendRequest struct {
	StreamID string    `json:"stream_id"`
	Kind     string    `json:"kind,omitempty"`
	Data     []byte    `json:"data,omitempty"`
	Error    string    `json:"error,omitempty"`
	Now      time.Time `json:"-"`
}

type CloseRequest struct {
	StreamID    string                          `json:"stream_id"`
	Status      Status                          `json:"status,omitempty"`
	FailureCode capability.ExecutionFailureCode `json:"failure_code,omitempty"`
	Reason      string                          `json:"reason,omitempty"`
	Now         time.Time                       `json:"-"`
}

type DeliverRequest struct {
	StreamID  string `json:"stream_id"`
	ReadID    string `json:"read_id"`
	MaxEvents int    `json:"max_events,omitempty"`
	MaxBytes  int64  `json:"max_bytes,omitempty"`
}

type Delivery struct {
	DeliveryID      string  `json:"delivery_id,omitempty"`
	ReadID          string  `json:"read_id"`
	StreamID        string  `json:"stream_id"`
	ThroughSequence uint64  `json:"through_sequence,omitempty"`
	Events          []Event `json:"events,omitempty"`
	Done            bool    `json:"done"`
	TerminalStatus  Status  `json:"terminal_status,omitempty"`
}

type Direction string

type Event struct {
	StreamID string    `json:"stream_id"`
	Sequence uint64    `json:"sequence"`
	Kind     string    `json:"kind"`
	Data     []byte    `json:"data,omitempty"`
	Error    string    `json:"error,omitempty"`
	At       time.Time `json:"at"`
}

type ListRequest struct {
	PluginInstanceID string     `json:"plugin_instance_id,omitempty"`
	Owner            OwnerScope `json:"-"`
	AllOwners        bool       `json:"-"`
}

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

type OwnerScope = capability.ExecutionOwnerScope

type PluginTransitionRequest struct {
	PluginInstanceID string                          `json:"plugin_instance_id"`
	ResourceScope    sessionctx.ResourceScope        `json:"-"`
	Status           Status                          `json:"status"`
	FailureCode      capability.ExecutionFailureCode `json:"failure_code,omitempty"`
	Reason           string                          `json:"reason,omitempty"`
	Now              time.Time                       `json:"-"`
}

type PluginTransitionResult struct {
	Changed int `json:"changed"`
}

type PruneRequest struct {
	Before                      time.Time `json:"before"`
	Limit                       int       `json:"limit,omitempty"`
	MaxTerminalRecordsPerPlugin int       `json:"max_terminal_records_per_plugin,omitempty"`
}

type PruneResult struct {
	Deleted int `json:"deleted"`
}

type Record struct {
	StreamID string `json:"stream_id"`
	capability.ExecutionBinding
	Direction        Direction                       `json:"direction"`
	Status           Status                          `json:"status"`
	FailureCode      capability.ExecutionFailureCode `json:"failure_code,omitempty"`
	Reason           string                          `json:"reason,omitempty"`
	ContentType      string                          `json:"content_type,omitempty"`
	MaxBufferedBytes int64                           `json:"max_buffered_bytes,omitempty"`
	BufferedBytes    int64                           `json:"buffered_bytes,omitempty"`
	CreatedAt        time.Time                       `json:"created_at"`
	UpdatedAt        time.Time                       `json:"updated_at"`
	ClosedAt         *time.Time                      `json:"closed_at,omitempty"`
}

type RegisterRequest struct {
	StreamID         string                      `json:"stream_id"`
	ExecutionBinding capability.ExecutionBinding `json:"execution_binding"`
	Direction        Direction                   `json:"direction,omitempty"`
	ContentType      string                      `json:"content_type,omitempty"`
	MaxBufferedBytes int64                       `json:"max_buffered_bytes,omitempty"`
	Now              time.Time                   `json:"-"`
}

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

type Status string

type Store interface {
	Register(ctx context.Context, req RegisterRequest) (Record, error)
	List(ctx context.Context, req ListRequest) ([]Record, error)
	Get(ctx context.Context, streamID string) (Record, error)
	Append(ctx context.Context, req AppendRequest) (Event, error)
	Wait(ctx context.Context, streamID string) error
	Deliver(ctx context.Context, req DeliverRequest) (Record, Delivery, error)
	Acknowledge(ctx context.Context, req AcknowledgeRequest) (Record, error)
	Close(ctx context.Context, req CloseRequest) (Record, error)
	MarkPluginTransition(ctx context.Context, req PluginTransitionRequest) (PluginTransitionResult, error)
	Prune(ctx context.Context, req PruneRequest) (PruneResult, error)
}