recording

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

type ArtifactDigest = audit.ArtifactDigest

type CastDigest [sha256.Size]byte

type CastHeader struct {
	Version   int          `json:"version"`
	Terminal  CastTerminal `json:"term"`
	Timestamp int64        `json:"timestamp"`
}

type CastMetadata struct {
	RecordingId  Id                     `json:"recordingId"`
	ConnectionId connection.Id          `json:"connectionId"`
	SessionId    session.Id             `json:"sessionId"`
	OperationId  uuid.UUID              `json:"operationId"`
	Flow         configuration.FlowName `json:"flow"`
	Task         audit.SessionTask      `json:"task"`
	Pty          bool                   `json:"pty"`
	ProducerId   audit.ProducerId       `json:"producerId"`
	StartedAt    time.Time              `json:"startedAt"`
}

type CastResult struct {
	Status  CastStatus `json:"status"`
	EndedAt time.Time  `json:"endedAt"`
	Reason  string     `json:"reason,omitempty"`
}

type CastStatus string

type CastTerminal struct {
	Columns uint32 `json:"cols"`
	Rows    uint32 `json:"rows"`
	Type    string `json:"type,omitempty"`
}

type CastVerification struct {
	Header       CastHeader
	Metadata     CastMetadata
	Result       CastResult
	ExitStatus   *uint32
	EventCount   uint64
	OutputEvents uint64
	ResizeEvents uint64
	MarkerEvents uint64
	Digest       CastDigest
	Fingerprint  string
	Trusted      bool
}

type CastVerifyOptions struct {
	Context            context.Context
	MaximumBytes       int64
	ExpectedProducerId audit.ProducerId
	AllowUntrusted     bool
}

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

type Format string

type Id uuid.UUID

type InspectOptions struct {
	Context               context.Context
	MaximumContainerBytes int64
	MaximumCastBytes      int64
	MaximumChunks         uint64
	ExpectedProducerId    audit.ProducerId
	AllowUntrusted        bool
}

type Inspection struct {
	Format Format
	Cast   *CastVerification
	Native *NativeRecordingVerification
}

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

type LocalRepositoryOptions struct {
	MaximumSpoolBytes uint64
	RecordingOnly     bool
}

type LocalSealedArtifact[Summary any] struct {
	// contains filtered or unexported fields
}

type NativeCastEvent struct {
	Kind       uint8
	Header     CastHeader
	Metadata   CastMetadata
	Elapsed    time.Duration
	Stream     OutputStream
	Data       []byte
	Columns    uint32
	Rows       uint32
	Label      string
	Result     CastResult
	ExitStatus *uint32
}

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

type NativeRecordingChunk = nativeRecordingChunk

type NativeRecordingHead struct {
	Version       uint8    `cbor:"1,keyasint"`
	RecordingId   [16]byte `cbor:"2,keyasint"`
	ProducerId    [32]byte `cbor:"3,keyasint"`
	PrefixBytes   uint64   `cbor:"4,keyasint"`
	ChunkCount    uint64   `cbor:"5,keyasint"`
	LastUnitHash  [32]byte `cbor:"6,keyasint"`
	CastHashState [32]byte `cbor:"7,keyasint"`
	CastHashBytes uint64   `cbor:"8,keyasint"`
	Signature     []byte   `cbor:"9,keyasint"`
}

type NativeRecordingHeader = nativeRecordingHeader

type NativeRecordingRecoveryResult struct {
	Verification  *NativeRecordingVerification
	AlreadySealed bool
	Truncated     bool
	Finalized     bool
}

type NativeRecordingSeal = nativeRecordingSeal

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

type NativeRecordingSummary struct {
	RecordingId          Id
	ProducerId           audit.ProducerId
	RecipientFingerprint string
	Status               CastStatus
	ChunkCount           uint64
	CastBytes            uint64
	Digest               CastDigest
	Bytes                uint64
}

type NativeRecordingUnitCommitter interface {
	io.Writer
	CommitNativeRecordingUnit(frame []byte) error
}

type NativeRecordingVerification struct {
	Header  NativeRecordingHeader
	Seal    NativeRecordingSeal
	Trusted bool
}

type NativeRecordingVerifyOptions struct {
	ExpectedProducerId    audit.ProducerId
	AllowUntrusted        bool
	MaximumContainerBytes int64
	MaximumCastBytes      int64
	MaximumChunks         uint64
	Context               context.Context
}

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

type NativeRecordingWriterLimits struct {
	MaximumContainerBytes int64
	MaximumCastBytes      int64
	MaximumChunks         uint64
}

type NativeRecoveryFile interface {
	RecoveryFile
	io.WriterAt
}

type OutputStream string

type RecoveredNativeRecording struct {
	Summary       NativeRecordingSummary
	Truncated     bool
	AlreadySealed bool
}

type RecoveryFile interface {
	io.ReaderAt
	io.Writer
	io.Seeker
	Truncate(size int64) error
	Sync() error
}

type SealedArtifactLifecyclePreparer interface {
	PrepareLifecycle(context.Context, audit.RemoteArtifact, time.Time, CastDigest, bool) error
	PromoteLifecycle(context.Context, audit.RemoteArtifact) error
}

type SealedArtifactPreparer interface {
	Prepare(context.Context, audit.RemoteArtifact, time.Time) error
	Require(context.Context, audit.RemoteArtifact) error
}

type SealedArtifactQuotaBinder interface {
	BindSealedArtifactQuota(audit.RemoteArtifactReceiptQuota)
}

type SealedArtifactStateCleaner interface {
	CleanupOrphanedSealedArtifactState(context.Context) error
}

type SealedArtifactStateRecoverer interface {
	RecoverSealedArtifactState(context.Context) error
}