Help us shape the future of Go! Take the 2026 Go Developer Survey

write

package
v0.1.58 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 26, 2026 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const WriterDatlyResourceNamespace = "datly_run_write_writer"

DatlyResourceNamespace identifies this package's generated resource filesystem.

Variables

View Source 
var (
	LifecycleHooks = new(Lifecycle)
	LifecycleDatly = LifecycleDatlyType()
)
View Source 
var WriterDatly = new(WriterComponent)

The public value supports explicit component wiring.

View Source 
var WriterDatlyResources embed.FS

Functions

func LifecycleDatlyType 

func LifecycleDatlyType() reflect.Type

func WriterDatlyType 

func WriterDatlyType() reflect.Type

WriterDatlyType returns the public component type.

func WriterHandlerCurrentWriterIndexByAgentIdKey 

func WriterHandlerCurrentWriterIndexByAgentIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByAttemptKey 

func WriterHandlerCurrentWriterIndexByAttemptKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByAuthAudienceKey 

func WriterHandlerCurrentWriterIndexByAuthAudienceKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByAuthAuthorityKey 

func WriterHandlerCurrentWriterIndexByAuthAuthorityKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByCheckpointDataKey 

func WriterHandlerCurrentWriterIndexByCheckpointDataKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByCheckpointMessageIdKey 

func WriterHandlerCurrentWriterIndexByCheckpointMessageIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByCheckpointResponseIdKey 

func WriterHandlerCurrentWriterIndexByCheckpointResponseIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByCompletedAtKey 

func WriterHandlerCurrentWriterIndexByCompletedAtKey(value *CurrentWriterView) (time.Time, bool)

func WriterHandlerCurrentWriterIndexByConditionKey 

func WriterHandlerCurrentWriterIndexByConditionKey(value *CurrentWriterView) (predicate.RunPatchCondition, bool)

func WriterHandlerCurrentWriterIndexByConversationIdKey 

func WriterHandlerCurrentWriterIndexByConversationIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByConversationKindKey 

func WriterHandlerCurrentWriterIndexByConversationKindKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByCreatedAtKey 

func WriterHandlerCurrentWriterIndexByCreatedAtKey(value *CurrentWriterView) (time.Time, bool)

func WriterHandlerCurrentWriterIndexByEffectiveUserIdKey 

func WriterHandlerCurrentWriterIndexByEffectiveUserIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByErrorCodeKey 

func WriterHandlerCurrentWriterIndexByErrorCodeKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByErrorMessageKey 

func WriterHandlerCurrentWriterIndexByErrorMessageKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByHeartbeatIntervalSecKey 

func WriterHandlerCurrentWriterIndexByHeartbeatIntervalSecKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByIdKey 

func WriterHandlerCurrentWriterIndexByIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByIterationKey 

func WriterHandlerCurrentWriterIndexByIterationKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByLastHeartbeatAtKey 

func WriterHandlerCurrentWriterIndexByLastHeartbeatAtKey(value *CurrentWriterView) (time.Time, bool)

func WriterHandlerCurrentWriterIndexByLeaseOwnerKey 

func WriterHandlerCurrentWriterIndexByLeaseOwnerKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByLeaseUntilKey 

func WriterHandlerCurrentWriterIndexByLeaseUntilKey(value *CurrentWriterView) (time.Time, bool)

func WriterHandlerCurrentWriterIndexByMaxIterationsKey 

func WriterHandlerCurrentWriterIndexByMaxIterationsKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByModelKey 

func WriterHandlerCurrentWriterIndexByModelKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByModelProviderKey 

func WriterHandlerCurrentWriterIndexByModelProviderKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByPreconditionPassedKey 

func WriterHandlerCurrentWriterIndexByPreconditionPassedKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByPreconditionRanAtKey 

func WriterHandlerCurrentWriterIndexByPreconditionRanAtKey(value *CurrentWriterView) (time.Time, bool)

func WriterHandlerCurrentWriterIndexByPreconditionResultKey 

func WriterHandlerCurrentWriterIndexByPreconditionResultKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByProtocolClientMessageIdKey 

func WriterHandlerCurrentWriterIndexByProtocolClientMessageIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByProtocolInitialTurnKeyKey 

func WriterHandlerCurrentWriterIndexByProtocolInitialTurnKeyKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByProtocolInputHashKey 

func WriterHandlerCurrentWriterIndexByProtocolInputHashKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByProtocolInputJsonKey 

func WriterHandlerCurrentWriterIndexByProtocolInputJsonKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByProtocolKeyKey 

func WriterHandlerCurrentWriterIndexByProtocolKeyKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByProtocolLastSequenceKey 

func WriterHandlerCurrentWriterIndexByProtocolLastSequenceKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByProtocolLeaseOwnerKey 

func WriterHandlerCurrentWriterIndexByProtocolLeaseOwnerKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByProtocolLeaseRevisionKey 

func WriterHandlerCurrentWriterIndexByProtocolLeaseRevisionKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByProtocolLeaseUntilKey 

func WriterHandlerCurrentWriterIndexByProtocolLeaseUntilKey(value *CurrentWriterView) (time.Time, bool)

func WriterHandlerCurrentWriterIndexByProtocolParentRunIdKey 

func WriterHandlerCurrentWriterIndexByProtocolParentRunIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByProtocolPendingJsonKey 

func WriterHandlerCurrentWriterIndexByProtocolPendingJsonKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByProtocolPriorRunIdKey 

func WriterHandlerCurrentWriterIndexByProtocolPriorRunIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByProtocolResumedByRunIdKey 

func WriterHandlerCurrentWriterIndexByProtocolResumedByRunIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByProtocolRevisionKey 

func WriterHandlerCurrentWriterIndexByProtocolRevisionKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByProtocolRunIdKey 

func WriterHandlerCurrentWriterIndexByProtocolRunIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByProtocolSourceKeyKey 

func WriterHandlerCurrentWriterIndexByProtocolSourceKeyKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByProtocolStatusKey 

func WriterHandlerCurrentWriterIndexByProtocolStatusKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByProtocolTurnIdKey 

func WriterHandlerCurrentWriterIndexByProtocolTurnIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByResumedFromRunIdKey 

func WriterHandlerCurrentWriterIndexByResumedFromRunIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByRunKindKey 

func WriterHandlerCurrentWriterIndexByRunKindKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByScheduleIdKey 

func WriterHandlerCurrentWriterIndexByScheduleIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByScheduledForKey 

func WriterHandlerCurrentWriterIndexByScheduledForKey(value *CurrentWriterView) (time.Time, bool)

func WriterHandlerCurrentWriterIndexBySecurityContextKey 

func WriterHandlerCurrentWriterIndexBySecurityContextKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByStartedAtKey 

func WriterHandlerCurrentWriterIndexByStartedAtKey(value *CurrentWriterView) (time.Time, bool)

func WriterHandlerCurrentWriterIndexByStatusKey 

func WriterHandlerCurrentWriterIndexByStatusKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByTurnIdKey 

func WriterHandlerCurrentWriterIndexByTurnIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByUpdatedAtKey 

func WriterHandlerCurrentWriterIndexByUpdatedAtKey(value *CurrentWriterView) (time.Time, bool)

func WriterHandlerCurrentWriterIndexByUsageCompletionTokensKey 

func WriterHandlerCurrentWriterIndexByUsageCompletionTokensKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByUsageCostKey 

func WriterHandlerCurrentWriterIndexByUsageCostKey(value *CurrentWriterView) (float64, bool)

func WriterHandlerCurrentWriterIndexByUsagePromptTokensKey 

func WriterHandlerCurrentWriterIndexByUsagePromptTokensKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByUsageTotalTokensKey 

func WriterHandlerCurrentWriterIndexByUsageTotalTokensKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByUserCredUrlKey 

func WriterHandlerCurrentWriterIndexByUserCredUrlKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByWorkerHostKey 

func WriterHandlerCurrentWriterIndexByWorkerHostKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByWorkerIdKey 

func WriterHandlerCurrentWriterIndexByWorkerIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByWorkerPidKey 

func WriterHandlerCurrentWriterIndexByWorkerPidKey(value *CurrentWriterView) (int, bool)

Types

type CurrentWriterView 

type CurrentWriterView struct {
	Condition               *predicate.RunPatchCondition `sqlx:"condition" json:"condition,omitempty"`
	Id                      string                       `validate:"required" sqlx:"id,primaryKey" json:"id"`
	RunKind                 string                       `sqlx:"run_kind,required=true" json:"runKind,omitempty"`
	Status                  string                       `validate:"required" json:"status" sqlx:"status,required=true"`
	UsageCost               *float64                     `sqlx:"usage_cost" json:"usageCost,omitempty"`
	ProtocolKey             *string                      `sqlx:"protocol_key" json:"protocolKey,omitempty"`
	ProtocolStatus          *string                      `sqlx:"protocol_status" json:"protocolStatus,omitempty"`
	ProtocolTurnId          *string                      `sqlx:"protocol_turn_id" json:"protocolTurnId,omitempty"`
	ProtocolRunId           *string                      `sqlx:"protocol_run_id" json:"protocolRunId,omitempty"`
	ProtocolParentRunId     *string                      `sqlx:"protocol_parent_run_id" json:"protocolParentRunId,omitempty"`
	ProtocolPriorRunId      *string                      `sqlx:"protocol_prior_run_id" json:"protocolPriorRunId,omitempty"`
	ProtocolClientMessageId *string                      `sqlx:"protocol_client_message_id" json:"protocolClientMessageId,omitempty"`
	ProtocolResumedByRunId  *string                      `sqlx:"protocol_resumed_by_run_id" json:"protocolResumedByRunId,omitempty"`
	ProtocolSourceKey       *string                      `sqlx:"protocol_source_key" json:"protocolSourceKey,omitempty"`
	ProtocolInitialTurnKey  *string                      `sqlx:"protocol_initial_turn_key" json:"protocolInitialTurnKey,omitempty"`
	ProtocolInputHash       *string                      `sqlx:"protocol_input_hash" json:"protocolInputHash,omitempty"`
	ProtocolInputJson       *string                      `sqlx:"protocol_input_json" json:"protocolInputJson,omitempty"`
	ProtocolPendingJson     *string                      `sqlx:"protocol_pending_json" json:"protocolPendingJson,omitempty"`
	ProtocolRevision        *int                         `sqlx:"protocol_revision,required=true" json:"protocolRevision,omitempty"`
	ProtocolLastSequence    *int                         `sqlx:"protocol_last_sequence,required=true" json:"protocolLastSequence,omitempty"`
	ProtocolLeaseOwner      *string                      `sqlx:"protocol_lease_owner" json:"protocolLeaseOwner,omitempty"`
	ProtocolLeaseUntil      *time.Time                   `sqlx:"protocol_lease_until" json:"protocolLeaseUntil,omitempty"`
	ProtocolLeaseRevision   *int                         `sqlx:"protocol_lease_revision,required=true" json:"protocolLeaseRevision,omitempty"`
	TurnId                  *string                      `sqlx:"turn_id,refTable=turn,refColumn=id" json:"turnId,omitempty"`
	ScheduleId              *string                      `sqlx:"schedule_id,refTable=schedule,refColumn=id" json:"scheduleId,omitempty"`
	ConversationId          *string                      `sqlx:"conversation_id,refTable=conversation,refColumn=id" json:"conversationId,omitempty"`
	ConversationKind        *string                      `sqlx:"conversation_kind,required=true" json:"conversationKind,omitempty"`
	Attempt                 *int                         `sqlx:"attempt,required=true" json:"attempt,omitempty"`
	ResumedFromRunId        *string                      `sqlx:"resumed_from_run_id" json:"resumedFromRunId,omitempty"`
	ErrorCode               *string                      `sqlx:"error_code" json:"errorCode,omitempty"`
	ErrorMessage            *string                      `sqlx:"error_message" json:"errorMessage,omitempty"`
	Iteration               *int                         `sqlx:"iteration,required=true" json:"iteration,omitempty"`
	MaxIterations           *int                         `sqlx:"max_iterations" json:"maxIterations,omitempty"`
	CheckpointResponseId    *string                      `sqlx:"checkpoint_response_id" json:"checkpointResponseId,omitempty"`
	CheckpointMessageId     *string                      `sqlx:"checkpoint_message_id" json:"checkpointMessageId,omitempty"`
	CheckpointData          *string                      `sqlx:"checkpoint_data" json:"checkpointData,omitempty"`
	AgentId                 *string                      `sqlx:"agent_id" json:"agentId,omitempty"`
	ModelProvider           *string                      `sqlx:"model_provider" json:"modelProvider,omitempty"`
	Model                   *string                      `sqlx:"model" json:"model,omitempty"`
	WorkerId                *string                      `sqlx:"worker_id" json:"workerId,omitempty"`
	WorkerPid               *int                         `sqlx:"worker_pid" json:"workerPid,omitempty"`
	WorkerHost              *string                      `sqlx:"worker_host" json:"workerHost,omitempty"`
	LeaseOwner              *string                      `sqlx:"lease_owner" json:"leaseOwner,omitempty"`
	LeaseUntil              *time.Time                   `sqlx:"lease_until" json:"leaseUntil,omitempty"`
	LastHeartbeatAt         *time.Time                   `sqlx:"last_heartbeat_at" json:"lastHeartbeatAt,omitempty"`
	SecurityContext         *string                      `sqlx:"security_context" json:"securityContext,omitempty"`
	EffectiveUserId         *string                      `sqlx:"effective_user_id" json:"effectiveUserId,omitempty"`
	AuthAuthority           *string                      `sqlx:"auth_authority" json:"authAuthority,omitempty"`
	AuthAudience            *string                      `sqlx:"auth_audience" json:"authAudience,omitempty"`
	UserCredUrl             *string                      `sqlx:"user_cred_url" json:"userCredUrl,omitempty"`
	HeartbeatIntervalSec    *int                         `sqlx:"heartbeat_interval_sec" json:"heartbeatIntervalSec,omitempty"`
	ScheduledFor            *time.Time                   `sqlx:"scheduled_for" json:"scheduledFor,omitempty"`
	PreconditionRanAt       *time.Time                   `sqlx:"precondition_ran_at" json:"preconditionRanAt,omitempty"`
	PreconditionPassed      *int                         `sqlx:"precondition_passed" json:"preconditionPassed,omitempty"`
	PreconditionResult      *string                      `sqlx:"precondition_result" json:"preconditionResult,omitempty"`
	UsagePromptTokens       *int                         `sqlx:"usage_prompt_tokens" json:"usagePromptTokens,omitempty"`
	UsageCompletionTokens   *int                         `sqlx:"usage_completion_tokens" json:"usageCompletionTokens,omitempty"`
	UsageTotalTokens        *int                         `sqlx:"usage_total_tokens" json:"usageTotalTokens,omitempty"`
	CreatedAt               *time.Time                   `sqlx:"created_at,required=true" json:"createdAt,omitempty"`
	UpdatedAt               *time.Time                   `sqlx:"updated_at" json:"updatedAt,omitempty"`
	StartedAt               *time.Time                   `sqlx:"started_at" json:"startedAt,omitempty"`
	CompletedAt             *time.Time                   `sqlx:"completed_at" json:"completedAt,omitempty"`
}

CurrentWriterView is generated canonical view metadata for writer.

type Input 

type Input struct {
	ExecutionRunOnly bool                     `` /* 188-byte string literal not displayed */
	OrphanDetach     bool                     `parameter:"OrphanDetach,kind=orphandetach,in=enabledDetach,dataType=bool,required=false"`
	OrphanColumn     string                   `parameter:"OrphanColumn,kind=orphandetach,in=column,dataType=string,required=false"`
	LeaseMode        string                   `parameter:"LeaseMode,kind=query,in=leaseMode,dataType=string,required=false"`
	LeaseOwner       string                   `parameter:"LeaseOwner,kind=query,in=leaseOwner,dataType=string,required=false"`
	LeaseNow         time.Time                `parameter:"LeaseNow,kind=query,in=leaseNow,dataType=time.Time,required=false"`
	Expectations     []*predicate.RunExpected `` /* 200-byte string literal not displayed */
	Runs             []*MutableRunView        `` /* 219-byte string literal not displayed */
	WriterKeys       []WriterKeysRow          `parameter:"WriterKeys,kind=param,in=Runs,cardinality=Many" codec:"structql,'uri=datly_run_write_writer:sql/writer_keys.sql'"`
	CurrentWriter    []*CurrentWriterView     `` /* 156-byte string literal not displayed */

	Has *InputHas `setMarker:"true" typeName:"InputHas" json:"-" sqlx:"-"`
	// contains filtered or unexported fields
}

Input is the generated input scaffold for writer.

func (*Input) Init 

func (input *Input) Init(ctx context.Context) error

func (*Input) PrepareReadIndexes 

func (input *Input) PrepareReadIndexes(ctx context.Context) error

func (*Input) ReadIndexes 

func (input *Input) ReadIndexes(ctx context.Context) (*WriterHandlerReadIndexes, error)

func (*Input) SetCurrentWriter 

func (input *Input) SetCurrentWriter(value []*CurrentWriterView)

func (*Input) SetExecutionRunOnly 

func (input *Input) SetExecutionRunOnly(value bool)

func (*Input) SetExpectations 

func (input *Input) SetExpectations(value []*predicate.RunExpected)

func (*Input) SetLeaseMode 

func (input *Input) SetLeaseMode(value string)

func (*Input) SetLeaseNow 

func (input *Input) SetLeaseNow(value time.Time)

func (*Input) SetLeaseOwner 

func (input *Input) SetLeaseOwner(value string)

func (*Input) SetOrphanColumn 

func (input *Input) SetOrphanColumn(value string)

func (*Input) SetOrphanDetach 

func (input *Input) SetOrphanDetach(value bool)

func (*Input) SetRuns 

func (input *Input) SetRuns(value []*MutableRunView)

func (*Input) SetWriterKeys 

func (input *Input) SetWriterKeys(value []WriterKeysRow)

type InputHas 

type InputHas struct {
	ExecutionRunOnly bool
	OrphanDetach     bool
	OrphanColumn     bool
	LeaseMode        bool
	LeaseOwner       bool
	LeaseNow         bool
	Expectations     bool
	Runs             bool
	WriterKeys       bool
	CurrentWriter    bool
}

type Lifecycle 

type Lifecycle struct {
	Input   *Input                 `bind:"kind=input"`
	Invoker dexec.ComponentInvoker `bind:"kind=component_invoker"`
}

Lifecycle customizes role Input.Runs.

func (*Lifecycle) AfterQueue 

func (hooks *Lifecycle) AfterQueue(ctx context.Context, entity *MutableRunView, state xhandler.LifecycleContext[MutableRunView, xhandler.NoParent, Output]) error

func (*Lifecycle) AfterSequence 

func (hooks *Lifecycle) AfterSequence(ctx context.Context, entity *MutableRunView, state xhandler.LifecycleContext[MutableRunView, xhandler.NoParent, Output]) error

func (*Lifecycle) Finalize 

func (hooks *Lifecycle) Finalize(ctx context.Context, input *Input, output *Output, outcome xhandler.Outcome) error

func (*Lifecycle) Init 

func (hooks *Lifecycle) Init(ctx context.Context, entity *MutableRunView, state xhandler.LifecycleContext[MutableRunView, xhandler.NoParent, Output]) error

func (*Lifecycle) Recover 

func (hooks *Lifecycle) Recover(ctx context.Context, input *Input, out *Output, outcome rhandler.MutationOutcome) (rhandler.Recovery, error)

func (*Lifecycle) Validate 

func (hooks *Lifecycle) Validate(ctx context.Context, entity *MutableRunView, state xhandler.LifecycleContext[MutableRunView, xhandler.NoParent, Output]) error

type MutableRunView 

type MutableRunView struct {
	ShouldDelete            bool                         `sqlx:"-" writer:"delete" json:"shouldDelete,omitempty"`
	Condition               *predicate.RunPatchCondition `sqlx:"-" json:"condition,omitempty"`
	Id                      string                       `validate:"required" sqlx:"id,primaryKey" json:"id"`
	RunKind                 string                       `sqlx:"run_kind,required=true" json:"runKind,omitempty"`
	Status                  string                       `validate:"required" json:"status" sqlx:"status,required=true"`
	UsageCost               *float64                     `sqlx:"usage_cost" json:"usageCost,omitempty"`
	ProtocolKey             *string                      `sqlx:"protocol_key" json:"protocolKey,omitempty"`
	ProtocolStatus          *string                      `sqlx:"protocol_status" json:"protocolStatus,omitempty"`
	ProtocolTurnId          *string                      `sqlx:"protocol_turn_id" json:"protocolTurnId,omitempty"`
	ProtocolRunId           *string                      `sqlx:"protocol_run_id" json:"protocolRunId,omitempty"`
	ProtocolParentRunId     *string                      `sqlx:"protocol_parent_run_id" json:"protocolParentRunId,omitempty"`
	ProtocolPriorRunId      *string                      `sqlx:"protocol_prior_run_id" json:"protocolPriorRunId,omitempty"`
	ProtocolClientMessageId *string                      `sqlx:"protocol_client_message_id" json:"protocolClientMessageId,omitempty"`
	ProtocolResumedByRunId  *string                      `sqlx:"protocol_resumed_by_run_id" json:"protocolResumedByRunId,omitempty"`
	ProtocolSourceKey       *string                      `sqlx:"protocol_source_key" json:"protocolSourceKey,omitempty"`
	ProtocolInitialTurnKey  *string                      `sqlx:"protocol_initial_turn_key" json:"protocolInitialTurnKey,omitempty"`
	ProtocolInputHash       *string                      `sqlx:"protocol_input_hash" json:"protocolInputHash,omitempty"`
	ProtocolInputJson       *string                      `sqlx:"protocol_input_json" json:"protocolInputJson,omitempty"`
	ProtocolPendingJson     *string                      `sqlx:"protocol_pending_json" json:"protocolPendingJson,omitempty"`
	ProtocolRevision        *int                         `sqlx:"protocol_revision,required=true" json:"protocolRevision,omitempty"`
	ProtocolLastSequence    *int                         `sqlx:"protocol_last_sequence,required=true" json:"protocolLastSequence,omitempty"`
	ProtocolLeaseOwner      *string                      `sqlx:"protocol_lease_owner" json:"protocolLeaseOwner,omitempty"`
	ProtocolLeaseUntil      *time.Time                   `sqlx:"protocol_lease_until" json:"protocolLeaseUntil,omitempty"`
	ProtocolLeaseRevision   *int                         `sqlx:"protocol_lease_revision,required=true" json:"protocolLeaseRevision,omitempty"`
	TurnId                  *string                      `sqlx:"turn_id,refTable=turn,refColumn=id" json:"turnId,omitempty"`
	ScheduleId              *string                      `sqlx:"schedule_id,refTable=schedule,refColumn=id" json:"scheduleId,omitempty"`
	ConversationId          *string                      `sqlx:"conversation_id,refTable=conversation,refColumn=id" json:"conversationId,omitempty"`
	ConversationKind        *string                      `sqlx:"conversation_kind,required=true" json:"conversationKind,omitempty"`
	Attempt                 *int                         `sqlx:"attempt,required=true" json:"attempt,omitempty"`
	ResumedFromRunId        *string                      `sqlx:"resumed_from_run_id" json:"resumedFromRunId,omitempty"`
	ErrorCode               *string                      `sqlx:"error_code" json:"errorCode,omitempty"`
	ErrorMessage            *string                      `sqlx:"error_message" json:"errorMessage,omitempty"`
	Iteration               *int                         `sqlx:"iteration,required=true" json:"iteration,omitempty"`
	MaxIterations           *int                         `sqlx:"max_iterations" json:"maxIterations,omitempty"`
	CheckpointResponseId    *string                      `sqlx:"checkpoint_response_id" json:"checkpointResponseId,omitempty"`
	CheckpointMessageId     *string                      `sqlx:"checkpoint_message_id" json:"checkpointMessageId,omitempty"`
	CheckpointData          *string                      `sqlx:"checkpoint_data" json:"checkpointData,omitempty"`
	AgentId                 *string                      `sqlx:"agent_id" json:"agentId,omitempty"`
	ModelProvider           *string                      `sqlx:"model_provider" json:"modelProvider,omitempty"`
	Model                   *string                      `sqlx:"model" json:"model,omitempty"`
	WorkerId                *string                      `sqlx:"worker_id" json:"workerId,omitempty"`
	WorkerPid               *int                         `sqlx:"worker_pid" json:"workerPid,omitempty"`
	WorkerHost              *string                      `sqlx:"worker_host" json:"workerHost,omitempty"`
	LeaseOwner              *string                      `sqlx:"lease_owner" json:"leaseOwner,omitempty"`
	LeaseUntil              *time.Time                   `sqlx:"lease_until" json:"leaseUntil,omitempty"`
	LastHeartbeatAt         *time.Time                   `sqlx:"last_heartbeat_at" json:"lastHeartbeatAt,omitempty"`
	SecurityContext         *string                      `sqlx:"security_context" json:"securityContext,omitempty"`
	EffectiveUserId         *string                      `sqlx:"effective_user_id" json:"effectiveUserId,omitempty"`
	AuthAuthority           *string                      `sqlx:"auth_authority" json:"authAuthority,omitempty"`
	AuthAudience            *string                      `sqlx:"auth_audience" json:"authAudience,omitempty"`
	UserCredUrl             *string                      `sqlx:"user_cred_url" json:"userCredUrl,omitempty"`
	HeartbeatIntervalSec    *int                         `sqlx:"heartbeat_interval_sec" json:"heartbeatIntervalSec,omitempty"`
	ScheduledFor            *time.Time                   `sqlx:"scheduled_for" json:"scheduledFor,omitempty"`
	PreconditionRanAt       *time.Time                   `sqlx:"precondition_ran_at" json:"preconditionRanAt,omitempty"`
	PreconditionPassed      *int                         `sqlx:"precondition_passed" json:"preconditionPassed,omitempty"`
	PreconditionResult      *string                      `sqlx:"precondition_result" json:"preconditionResult,omitempty"`
	UsagePromptTokens       *int                         `sqlx:"usage_prompt_tokens" json:"usagePromptTokens,omitempty"`
	UsageCompletionTokens   *int                         `sqlx:"usage_completion_tokens" json:"usageCompletionTokens,omitempty"`
	UsageTotalTokens        *int                         `sqlx:"usage_total_tokens" json:"usageTotalTokens,omitempty"`
	CreatedAt               *time.Time                   `sqlx:"created_at,required=true" json:"createdAt,omitempty"`
	UpdatedAt               *time.Time                   `sqlx:"updated_at" json:"updatedAt,omitempty"`
	StartedAt               *time.Time                   `sqlx:"started_at" json:"startedAt,omitempty"`
	CompletedAt             *time.Time                   `sqlx:"completed_at" json:"completedAt,omitempty"`
	Has                     *MutableRunViewHas           `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-" typeName:"MutableRunViewHas"`
}

MutableRunView is generated canonical view metadata for writer.

func (*MutableRunView) GetAgentId 

func (entity *MutableRunView) GetAgentId() *string

func (*MutableRunView) GetAttempt 

func (entity *MutableRunView) GetAttempt() *int

func (*MutableRunView) GetAuthAudience 

func (entity *MutableRunView) GetAuthAudience() *string

func (*MutableRunView) GetAuthAuthority 

func (entity *MutableRunView) GetAuthAuthority() *string

func (*MutableRunView) GetCheckpointData 

func (entity *MutableRunView) GetCheckpointData() *string

func (*MutableRunView) GetCheckpointMessageId 

func (entity *MutableRunView) GetCheckpointMessageId() *string

func (*MutableRunView) GetCheckpointResponseId 

func (entity *MutableRunView) GetCheckpointResponseId() *string

func (*MutableRunView) GetCompletedAt 

func (entity *MutableRunView) GetCompletedAt() *time.Time

func (*MutableRunView) GetCondition 

func (entity *MutableRunView) GetCondition() *predicate.RunPatchCondition

func (*MutableRunView) GetConversationId 

func (entity *MutableRunView) GetConversationId() *string

func (*MutableRunView) GetConversationKind 

func (entity *MutableRunView) GetConversationKind() *string

func (*MutableRunView) GetCreatedAt 

func (entity *MutableRunView) GetCreatedAt() *time.Time

func (*MutableRunView) GetEffectiveUserId 

func (entity *MutableRunView) GetEffectiveUserId() *string

func (*MutableRunView) GetErrorCode 

func (entity *MutableRunView) GetErrorCode() *string

func (*MutableRunView) GetErrorMessage 

func (entity *MutableRunView) GetErrorMessage() *string

func (*MutableRunView) GetHeartbeatIntervalSec 

func (entity *MutableRunView) GetHeartbeatIntervalSec() *int

func (*MutableRunView) GetId 

func (entity *MutableRunView) GetId() string

func (*MutableRunView) GetIteration 

func (entity *MutableRunView) GetIteration() *int

func (*MutableRunView) GetLastHeartbeatAt 

func (entity *MutableRunView) GetLastHeartbeatAt() *time.Time

func (*MutableRunView) GetLeaseOwner 

func (entity *MutableRunView) GetLeaseOwner() *string

func (*MutableRunView) GetLeaseUntil 

func (entity *MutableRunView) GetLeaseUntil() *time.Time

func (*MutableRunView) GetMaxIterations 

func (entity *MutableRunView) GetMaxIterations() *int

func (*MutableRunView) GetModel 

func (entity *MutableRunView) GetModel() *string

func (*MutableRunView) GetModelProvider 

func (entity *MutableRunView) GetModelProvider() *string

func (*MutableRunView) GetPreconditionPassed 

func (entity *MutableRunView) GetPreconditionPassed() *int

func (*MutableRunView) GetPreconditionRanAt 

func (entity *MutableRunView) GetPreconditionRanAt() *time.Time

func (*MutableRunView) GetPreconditionResult 

func (entity *MutableRunView) GetPreconditionResult() *string

func (*MutableRunView) GetProtocolClientMessageId 

func (entity *MutableRunView) GetProtocolClientMessageId() *string

func (*MutableRunView) GetProtocolInitialTurnKey 

func (entity *MutableRunView) GetProtocolInitialTurnKey() *string

func (*MutableRunView) GetProtocolInputHash 

func (entity *MutableRunView) GetProtocolInputHash() *string

func (*MutableRunView) GetProtocolInputJson 

func (entity *MutableRunView) GetProtocolInputJson() *string

func (*MutableRunView) GetProtocolKey 

func (entity *MutableRunView) GetProtocolKey() *string

func (*MutableRunView) GetProtocolLastSequence 

func (entity *MutableRunView) GetProtocolLastSequence() *int

func (*MutableRunView) GetProtocolLeaseOwner 

func (entity *MutableRunView) GetProtocolLeaseOwner() *string

func (*MutableRunView) GetProtocolLeaseRevision 

func (entity *MutableRunView) GetProtocolLeaseRevision() *int

func (*MutableRunView) GetProtocolLeaseUntil 

func (entity *MutableRunView) GetProtocolLeaseUntil() *time.Time

func (*MutableRunView) GetProtocolParentRunId 

func (entity *MutableRunView) GetProtocolParentRunId() *string

func (*MutableRunView) GetProtocolPendingJson 

func (entity *MutableRunView) GetProtocolPendingJson() *string

func (*MutableRunView) GetProtocolPriorRunId 

func (entity *MutableRunView) GetProtocolPriorRunId() *string

func (*MutableRunView) GetProtocolResumedByRunId 

func (entity *MutableRunView) GetProtocolResumedByRunId() *string

func (*MutableRunView) GetProtocolRevision 

func (entity *MutableRunView) GetProtocolRevision() *int

func (*MutableRunView) GetProtocolRunId 

func (entity *MutableRunView) GetProtocolRunId() *string

func (*MutableRunView) GetProtocolSourceKey 

func (entity *MutableRunView) GetProtocolSourceKey() *string

func (*MutableRunView) GetProtocolStatus 

func (entity *MutableRunView) GetProtocolStatus() *string

func (*MutableRunView) GetProtocolTurnId 

func (entity *MutableRunView) GetProtocolTurnId() *string

func (*MutableRunView) GetResumedFromRunId 

func (entity *MutableRunView) GetResumedFromRunId() *string

func (*MutableRunView) GetRunKind 

func (entity *MutableRunView) GetRunKind() string

func (*MutableRunView) GetScheduleId 

func (entity *MutableRunView) GetScheduleId() *string

func (*MutableRunView) GetScheduledFor 

func (entity *MutableRunView) GetScheduledFor() *time.Time

func (*MutableRunView) GetSecurityContext 

func (entity *MutableRunView) GetSecurityContext() *string

func (*MutableRunView) GetShouldDelete 

func (entity *MutableRunView) GetShouldDelete() bool

func (*MutableRunView) GetStartedAt 

func (entity *MutableRunView) GetStartedAt() *time.Time

func (*MutableRunView) GetStatus 

func (entity *MutableRunView) GetStatus() string

func (*MutableRunView) GetTurnId 

func (entity *MutableRunView) GetTurnId() *string

func (*MutableRunView) GetUpdatedAt 

func (entity *MutableRunView) GetUpdatedAt() *time.Time

func (*MutableRunView) GetUsageCompletionTokens 

func (entity *MutableRunView) GetUsageCompletionTokens() *int

func (*MutableRunView) GetUsageCost 

func (entity *MutableRunView) GetUsageCost() *float64

func (*MutableRunView) GetUsagePromptTokens 

func (entity *MutableRunView) GetUsagePromptTokens() *int

func (*MutableRunView) GetUsageTotalTokens 

func (entity *MutableRunView) GetUsageTotalTokens() *int

func (*MutableRunView) GetUserCredUrl 

func (entity *MutableRunView) GetUserCredUrl() *string

func (*MutableRunView) GetWorkerHost 

func (entity *MutableRunView) GetWorkerHost() *string

func (*MutableRunView) GetWorkerId 

func (entity *MutableRunView) GetWorkerId() *string

func (*MutableRunView) GetWorkerPid 

func (entity *MutableRunView) GetWorkerPid() *int

func (*MutableRunView) SetAgentId 

func (entity *MutableRunView) SetAgentId(value *string)

func (*MutableRunView) SetAttempt 

func (entity *MutableRunView) SetAttempt(value *int)

func (*MutableRunView) SetAuthAudience 

func (entity *MutableRunView) SetAuthAudience(value *string)

func (*MutableRunView) SetAuthAuthority 

func (entity *MutableRunView) SetAuthAuthority(value *string)

func (*MutableRunView) SetCheckpointData 

func (entity *MutableRunView) SetCheckpointData(value *string)

func (*MutableRunView) SetCheckpointMessageId 

func (entity *MutableRunView) SetCheckpointMessageId(value *string)

func (*MutableRunView) SetCheckpointResponseId 

func (entity *MutableRunView) SetCheckpointResponseId(value *string)

func (*MutableRunView) SetCompletedAt 

func (entity *MutableRunView) SetCompletedAt(value *time.Time)

func (*MutableRunView) SetCondition 

func (entity *MutableRunView) SetCondition(value *predicate.RunPatchCondition)

func (*MutableRunView) SetConversationId 

func (entity *MutableRunView) SetConversationId(value *string)

func (*MutableRunView) SetConversationKind 

func (entity *MutableRunView) SetConversationKind(value *string)

func (*MutableRunView) SetCreatedAt 

func (entity *MutableRunView) SetCreatedAt(value *time.Time)

func (*MutableRunView) SetEffectiveUserId 

func (entity *MutableRunView) SetEffectiveUserId(value *string)

func (*MutableRunView) SetErrorCode 

func (entity *MutableRunView) SetErrorCode(value *string)

func (*MutableRunView) SetErrorMessage 

func (entity *MutableRunView) SetErrorMessage(value *string)

func (*MutableRunView) SetHeartbeatIntervalSec 

func (entity *MutableRunView) SetHeartbeatIntervalSec(value *int)

func (*MutableRunView) SetId 

func (entity *MutableRunView) SetId(value string)

func (*MutableRunView) SetIteration 

func (entity *MutableRunView) SetIteration(value *int)

func (*MutableRunView) SetLastHeartbeatAt 

func (entity *MutableRunView) SetLastHeartbeatAt(value *time.Time)

func (*MutableRunView) SetLeaseOwner 

func (entity *MutableRunView) SetLeaseOwner(value *string)

func (*MutableRunView) SetLeaseUntil 

func (entity *MutableRunView) SetLeaseUntil(value *time.Time)

func (*MutableRunView) SetMaxIterations 

func (entity *MutableRunView) SetMaxIterations(value *int)

func (*MutableRunView) SetModel 

func (entity *MutableRunView) SetModel(value *string)

func (*MutableRunView) SetModelProvider 

func (entity *MutableRunView) SetModelProvider(value *string)

func (*MutableRunView) SetPreconditionPassed 

func (entity *MutableRunView) SetPreconditionPassed(value *int)

func (*MutableRunView) SetPreconditionRanAt 

func (entity *MutableRunView) SetPreconditionRanAt(value *time.Time)

func (*MutableRunView) SetPreconditionResult 

func (entity *MutableRunView) SetPreconditionResult(value *string)

func (*MutableRunView) SetProtocolClientMessageId 

func (entity *MutableRunView) SetProtocolClientMessageId(value *string)

func (*MutableRunView) SetProtocolInitialTurnKey 

func (entity *MutableRunView) SetProtocolInitialTurnKey(value *string)

func (*MutableRunView) SetProtocolInputHash 

func (entity *MutableRunView) SetProtocolInputHash(value *string)

func (*MutableRunView) SetProtocolInputJson 

func (entity *MutableRunView) SetProtocolInputJson(value *string)

func (*MutableRunView) SetProtocolKey 

func (entity *MutableRunView) SetProtocolKey(value *string)

func (*MutableRunView) SetProtocolLastSequence 

func (entity *MutableRunView) SetProtocolLastSequence(value *int)

func (*MutableRunView) SetProtocolLeaseOwner 

func (entity *MutableRunView) SetProtocolLeaseOwner(value *string)

func (*MutableRunView) SetProtocolLeaseRevision 

func (entity *MutableRunView) SetProtocolLeaseRevision(value *int)

func (*MutableRunView) SetProtocolLeaseUntil 

func (entity *MutableRunView) SetProtocolLeaseUntil(value *time.Time)

func (*MutableRunView) SetProtocolParentRunId 

func (entity *MutableRunView) SetProtocolParentRunId(value *string)

func (*MutableRunView) SetProtocolPendingJson 

func (entity *MutableRunView) SetProtocolPendingJson(value *string)

func (*MutableRunView) SetProtocolPriorRunId 

func (entity *MutableRunView) SetProtocolPriorRunId(value *string)

func (*MutableRunView) SetProtocolResumedByRunId 

func (entity *MutableRunView) SetProtocolResumedByRunId(value *string)

func (*MutableRunView) SetProtocolRevision 

func (entity *MutableRunView) SetProtocolRevision(value *int)

func (*MutableRunView) SetProtocolRunId 

func (entity *MutableRunView) SetProtocolRunId(value *string)

func (*MutableRunView) SetProtocolSourceKey 

func (entity *MutableRunView) SetProtocolSourceKey(value *string)

func (*MutableRunView) SetProtocolStatus 

func (entity *MutableRunView) SetProtocolStatus(value *string)

func (*MutableRunView) SetProtocolTurnId 

func (entity *MutableRunView) SetProtocolTurnId(value *string)

func (*MutableRunView) SetResumedFromRunId 

func (entity *MutableRunView) SetResumedFromRunId(value *string)

func (*MutableRunView) SetRunKind 

func (entity *MutableRunView) SetRunKind(value string)

func (*MutableRunView) SetScheduleId 

func (entity *MutableRunView) SetScheduleId(value *string)

func (*MutableRunView) SetScheduledFor 

func (entity *MutableRunView) SetScheduledFor(value *time.Time)

func (*MutableRunView) SetSecurityContext 

func (entity *MutableRunView) SetSecurityContext(value *string)

func (*MutableRunView) SetShouldDelete 

func (entity *MutableRunView) SetShouldDelete(value bool)

func (*MutableRunView) SetStartedAt 

func (entity *MutableRunView) SetStartedAt(value *time.Time)

func (*MutableRunView) SetStatus 

func (entity *MutableRunView) SetStatus(value string)

func (*MutableRunView) SetTurnId 

func (entity *MutableRunView) SetTurnId(value *string)

func (*MutableRunView) SetUpdatedAt 

func (entity *MutableRunView) SetUpdatedAt(value *time.Time)

func (*MutableRunView) SetUsageCompletionTokens 

func (entity *MutableRunView) SetUsageCompletionTokens(value *int)

func (*MutableRunView) SetUsageCost 

func (entity *MutableRunView) SetUsageCost(value *float64)

func (*MutableRunView) SetUsagePromptTokens 

func (entity *MutableRunView) SetUsagePromptTokens(value *int)

func (*MutableRunView) SetUsageTotalTokens 

func (entity *MutableRunView) SetUsageTotalTokens(value *int)

func (*MutableRunView) SetUserCredUrl 

func (entity *MutableRunView) SetUserCredUrl(value *string)

func (*MutableRunView) SetWorkerHost 

func (entity *MutableRunView) SetWorkerHost(value *string)

func (*MutableRunView) SetWorkerId 

func (entity *MutableRunView) SetWorkerId(value *string)

func (*MutableRunView) SetWorkerPid 

func (entity *MutableRunView) SetWorkerPid(value *int)

type MutableRunViewHas 

type MutableRunViewHas struct {
	ShouldDelete            bool
	Condition               bool
	Id                      bool
	RunKind                 bool
	Status                  bool
	UsageCost               bool
	ProtocolKey             bool
	ProtocolStatus          bool
	ProtocolTurnId          bool
	ProtocolRunId           bool
	ProtocolParentRunId     bool
	ProtocolPriorRunId      bool
	ProtocolClientMessageId bool
	ProtocolResumedByRunId  bool
	ProtocolSourceKey       bool
	ProtocolInitialTurnKey  bool
	ProtocolInputHash       bool
	ProtocolInputJson       bool
	ProtocolPendingJson     bool
	ProtocolRevision        bool
	ProtocolLastSequence    bool
	ProtocolLeaseOwner      bool
	ProtocolLeaseUntil      bool
	ProtocolLeaseRevision   bool
	TurnId                  bool
	ScheduleId              bool
	ConversationId          bool
	ConversationKind        bool
	Attempt                 bool
	ResumedFromRunId        bool
	ErrorCode               bool
	ErrorMessage            bool
	Iteration               bool
	MaxIterations           bool
	CheckpointResponseId    bool
	CheckpointMessageId     bool
	CheckpointData          bool
	AgentId                 bool
	ModelProvider           bool
	Model                   bool
	WorkerId                bool
	WorkerPid               bool
	WorkerHost              bool
	LeaseOwner              bool
	LeaseUntil              bool
	LastHeartbeatAt         bool
	SecurityContext         bool
	EffectiveUserId         bool
	AuthAuthority           bool
	AuthAudience            bool
	UserCredUrl             bool
	HeartbeatIntervalSec    bool
	ScheduledFor            bool
	PreconditionRanAt       bool
	PreconditionPassed      bool
	PreconditionResult      bool
	UsagePromptTokens       bool
	UsageCompletionTokens   bool
	UsageTotalTokens        bool
	CreatedAt               bool
	UpdatedAt               bool
	StartedAt               bool
	CompletedAt             bool
}

type Output 

type Output struct {
	LeaseResult bool              `parameter:"LeaseResult,kind=output,in=leaseResult,dataType=bool" json:"leaseResult,omitempty"`
	Data        []*MutableRunView `parameter:"Data,kind=output,in=body,dataType=[]*MutableRunView" json:"data,omitempty"`
}

Output is the generated output scaffold for writer.

type WriterComponent 

type WriterComponent struct {
	Contract xdatly.Component[Input, Output] "" /* 195-byte string literal not displayed */
}

Component is the generated component scaffold for writer.

func (WriterComponent) EmbedFS 

func (WriterComponent) EmbedFS() *embed.FS

func (WriterComponent) EmbedNamespace 

func (WriterComponent) EmbedNamespace() string

type WriterHandlerCurrentWriterGroupedByAgentId 

type WriterHandlerCurrentWriterGroupedByAgentId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByAgentId) Has 

func (index WriterHandlerCurrentWriterGroupedByAgentId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByAttempt 

type WriterHandlerCurrentWriterGroupedByAttempt map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByAttempt) Has 

func (index WriterHandlerCurrentWriterGroupedByAttempt) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByAuthAudience 

type WriterHandlerCurrentWriterGroupedByAuthAudience map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByAuthAudience) Has 

func (index WriterHandlerCurrentWriterGroupedByAuthAudience) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByAuthAuthority 

type WriterHandlerCurrentWriterGroupedByAuthAuthority map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByAuthAuthority) Has 

func (index WriterHandlerCurrentWriterGroupedByAuthAuthority) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByCheckpointData 

type WriterHandlerCurrentWriterGroupedByCheckpointData map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByCheckpointData) Has 

func (index WriterHandlerCurrentWriterGroupedByCheckpointData) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByCheckpointMessageId 

type WriterHandlerCurrentWriterGroupedByCheckpointMessageId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByCheckpointMessageId) Has 

func (index WriterHandlerCurrentWriterGroupedByCheckpointMessageId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByCheckpointResponseId 

type WriterHandlerCurrentWriterGroupedByCheckpointResponseId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByCheckpointResponseId) Has 

func (index WriterHandlerCurrentWriterGroupedByCheckpointResponseId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByCompletedAt 

type WriterHandlerCurrentWriterGroupedByCompletedAt map[time.Time][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByCompletedAt) Has 

func (index WriterHandlerCurrentWriterGroupedByCompletedAt) Has(key time.Time) bool

type WriterHandlerCurrentWriterGroupedByCondition 

type WriterHandlerCurrentWriterGroupedByCondition map[predicate.RunPatchCondition][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByCondition) Has 

func (index WriterHandlerCurrentWriterGroupedByCondition) Has(key predicate.RunPatchCondition) bool

type WriterHandlerCurrentWriterGroupedByConversationId 

type WriterHandlerCurrentWriterGroupedByConversationId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByConversationId) Has 

func (index WriterHandlerCurrentWriterGroupedByConversationId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByConversationKind 

type WriterHandlerCurrentWriterGroupedByConversationKind map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByConversationKind) Has 

func (index WriterHandlerCurrentWriterGroupedByConversationKind) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByCreatedAt 

type WriterHandlerCurrentWriterGroupedByCreatedAt map[time.Time][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByCreatedAt) Has 

func (index WriterHandlerCurrentWriterGroupedByCreatedAt) Has(key time.Time) bool

type WriterHandlerCurrentWriterGroupedByEffectiveUserId 

type WriterHandlerCurrentWriterGroupedByEffectiveUserId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByEffectiveUserId) Has 

func (index WriterHandlerCurrentWriterGroupedByEffectiveUserId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByErrorCode 

type WriterHandlerCurrentWriterGroupedByErrorCode map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByErrorCode) Has 

func (index WriterHandlerCurrentWriterGroupedByErrorCode) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByErrorMessage 

type WriterHandlerCurrentWriterGroupedByErrorMessage map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByErrorMessage) Has 

func (index WriterHandlerCurrentWriterGroupedByErrorMessage) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByHeartbeatIntervalSec 

type WriterHandlerCurrentWriterGroupedByHeartbeatIntervalSec map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByHeartbeatIntervalSec) Has 

func (index WriterHandlerCurrentWriterGroupedByHeartbeatIntervalSec) Has(key int) bool

type WriterHandlerCurrentWriterGroupedById 

type WriterHandlerCurrentWriterGroupedById map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedById) Has 

func (index WriterHandlerCurrentWriterGroupedById) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByIteration 

type WriterHandlerCurrentWriterGroupedByIteration map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByIteration) Has 

func (index WriterHandlerCurrentWriterGroupedByIteration) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByLastHeartbeatAt 

type WriterHandlerCurrentWriterGroupedByLastHeartbeatAt map[time.Time][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByLastHeartbeatAt) Has 

func (index WriterHandlerCurrentWriterGroupedByLastHeartbeatAt) Has(key time.Time) bool

type WriterHandlerCurrentWriterGroupedByLeaseOwner 

type WriterHandlerCurrentWriterGroupedByLeaseOwner map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByLeaseOwner) Has 

func (index WriterHandlerCurrentWriterGroupedByLeaseOwner) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByLeaseUntil 

type WriterHandlerCurrentWriterGroupedByLeaseUntil map[time.Time][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByLeaseUntil) Has 

func (index WriterHandlerCurrentWriterGroupedByLeaseUntil) Has(key time.Time) bool

type WriterHandlerCurrentWriterGroupedByMaxIterations 

type WriterHandlerCurrentWriterGroupedByMaxIterations map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByMaxIterations) Has 

func (index WriterHandlerCurrentWriterGroupedByMaxIterations) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByModel 

type WriterHandlerCurrentWriterGroupedByModel map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByModel) Has 

func (index WriterHandlerCurrentWriterGroupedByModel) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByModelProvider 

type WriterHandlerCurrentWriterGroupedByModelProvider map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByModelProvider) Has 

func (index WriterHandlerCurrentWriterGroupedByModelProvider) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByPreconditionPassed 

type WriterHandlerCurrentWriterGroupedByPreconditionPassed map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByPreconditionPassed) Has 

func (index WriterHandlerCurrentWriterGroupedByPreconditionPassed) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByPreconditionRanAt 

type WriterHandlerCurrentWriterGroupedByPreconditionRanAt map[time.Time][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByPreconditionRanAt) Has 

func (index WriterHandlerCurrentWriterGroupedByPreconditionRanAt) Has(key time.Time) bool

type WriterHandlerCurrentWriterGroupedByPreconditionResult 

type WriterHandlerCurrentWriterGroupedByPreconditionResult map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByPreconditionResult) Has 

func (index WriterHandlerCurrentWriterGroupedByPreconditionResult) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByProtocolClientMessageId 

type WriterHandlerCurrentWriterGroupedByProtocolClientMessageId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProtocolClientMessageId) Has 

func (index WriterHandlerCurrentWriterGroupedByProtocolClientMessageId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByProtocolInitialTurnKey 

type WriterHandlerCurrentWriterGroupedByProtocolInitialTurnKey map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProtocolInitialTurnKey) Has 

func (index WriterHandlerCurrentWriterGroupedByProtocolInitialTurnKey) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByProtocolInputHash 

type WriterHandlerCurrentWriterGroupedByProtocolInputHash map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProtocolInputHash) Has 

func (index WriterHandlerCurrentWriterGroupedByProtocolInputHash) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByProtocolInputJson 

type WriterHandlerCurrentWriterGroupedByProtocolInputJson map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProtocolInputJson) Has 

func (index WriterHandlerCurrentWriterGroupedByProtocolInputJson) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByProtocolKey 

type WriterHandlerCurrentWriterGroupedByProtocolKey map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProtocolKey) Has 

func (index WriterHandlerCurrentWriterGroupedByProtocolKey) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByProtocolLastSequence 

type WriterHandlerCurrentWriterGroupedByProtocolLastSequence map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProtocolLastSequence) Has 

func (index WriterHandlerCurrentWriterGroupedByProtocolLastSequence) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByProtocolLeaseOwner 

type WriterHandlerCurrentWriterGroupedByProtocolLeaseOwner map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProtocolLeaseOwner) Has 

func (index WriterHandlerCurrentWriterGroupedByProtocolLeaseOwner) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByProtocolLeaseRevision 

type WriterHandlerCurrentWriterGroupedByProtocolLeaseRevision map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProtocolLeaseRevision) Has 

func (index WriterHandlerCurrentWriterGroupedByProtocolLeaseRevision) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByProtocolLeaseUntil 

type WriterHandlerCurrentWriterGroupedByProtocolLeaseUntil map[time.Time][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProtocolLeaseUntil) Has 

func (index WriterHandlerCurrentWriterGroupedByProtocolLeaseUntil) Has(key time.Time) bool

type WriterHandlerCurrentWriterGroupedByProtocolParentRunId 

type WriterHandlerCurrentWriterGroupedByProtocolParentRunId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProtocolParentRunId) Has 

func (index WriterHandlerCurrentWriterGroupedByProtocolParentRunId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByProtocolPendingJson 

type WriterHandlerCurrentWriterGroupedByProtocolPendingJson map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProtocolPendingJson) Has 

func (index WriterHandlerCurrentWriterGroupedByProtocolPendingJson) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByProtocolPriorRunId 

type WriterHandlerCurrentWriterGroupedByProtocolPriorRunId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProtocolPriorRunId) Has 

func (index WriterHandlerCurrentWriterGroupedByProtocolPriorRunId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByProtocolResumedByRunId 

type WriterHandlerCurrentWriterGroupedByProtocolResumedByRunId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProtocolResumedByRunId) Has 

func (index WriterHandlerCurrentWriterGroupedByProtocolResumedByRunId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByProtocolRevision 

type WriterHandlerCurrentWriterGroupedByProtocolRevision map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProtocolRevision) Has 

func (index WriterHandlerCurrentWriterGroupedByProtocolRevision) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByProtocolRunId 

type WriterHandlerCurrentWriterGroupedByProtocolRunId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProtocolRunId) Has 

func (index WriterHandlerCurrentWriterGroupedByProtocolRunId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByProtocolSourceKey 

type WriterHandlerCurrentWriterGroupedByProtocolSourceKey map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProtocolSourceKey) Has 

func (index WriterHandlerCurrentWriterGroupedByProtocolSourceKey) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByProtocolStatus 

type WriterHandlerCurrentWriterGroupedByProtocolStatus map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProtocolStatus) Has 

func (index WriterHandlerCurrentWriterGroupedByProtocolStatus) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByProtocolTurnId 

type WriterHandlerCurrentWriterGroupedByProtocolTurnId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProtocolTurnId) Has 

func (index WriterHandlerCurrentWriterGroupedByProtocolTurnId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByResumedFromRunId 

type WriterHandlerCurrentWriterGroupedByResumedFromRunId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByResumedFromRunId) Has 

func (index WriterHandlerCurrentWriterGroupedByResumedFromRunId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByRunKind 

type WriterHandlerCurrentWriterGroupedByRunKind map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByRunKind) Has 

func (index WriterHandlerCurrentWriterGroupedByRunKind) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByScheduleId 

type WriterHandlerCurrentWriterGroupedByScheduleId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByScheduleId) Has 

func (index WriterHandlerCurrentWriterGroupedByScheduleId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByScheduledFor 

type WriterHandlerCurrentWriterGroupedByScheduledFor map[time.Time][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByScheduledFor) Has 

func (index WriterHandlerCurrentWriterGroupedByScheduledFor) Has(key time.Time) bool

type WriterHandlerCurrentWriterGroupedBySecurityContext 

type WriterHandlerCurrentWriterGroupedBySecurityContext map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedBySecurityContext) Has 

func (index WriterHandlerCurrentWriterGroupedBySecurityContext) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByStartedAt 

type WriterHandlerCurrentWriterGroupedByStartedAt map[time.Time][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByStartedAt) Has 

func (index WriterHandlerCurrentWriterGroupedByStartedAt) Has(key time.Time) bool

type WriterHandlerCurrentWriterGroupedByStatus 

type WriterHandlerCurrentWriterGroupedByStatus map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByStatus) Has 

func (index WriterHandlerCurrentWriterGroupedByStatus) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByTurnId 

type WriterHandlerCurrentWriterGroupedByTurnId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByTurnId) Has 

func (index WriterHandlerCurrentWriterGroupedByTurnId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByUpdatedAt 

type WriterHandlerCurrentWriterGroupedByUpdatedAt map[time.Time][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByUpdatedAt) Has 

func (index WriterHandlerCurrentWriterGroupedByUpdatedAt) Has(key time.Time) bool

type WriterHandlerCurrentWriterGroupedByUsageCompletionTokens 

type WriterHandlerCurrentWriterGroupedByUsageCompletionTokens map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByUsageCompletionTokens) Has 

func (index WriterHandlerCurrentWriterGroupedByUsageCompletionTokens) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByUsageCost 

type WriterHandlerCurrentWriterGroupedByUsageCost map[float64][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByUsageCost) Has 

func (index WriterHandlerCurrentWriterGroupedByUsageCost) Has(key float64) bool

type WriterHandlerCurrentWriterGroupedByUsagePromptTokens 

type WriterHandlerCurrentWriterGroupedByUsagePromptTokens map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByUsagePromptTokens) Has 

func (index WriterHandlerCurrentWriterGroupedByUsagePromptTokens) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByUsageTotalTokens 

type WriterHandlerCurrentWriterGroupedByUsageTotalTokens map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByUsageTotalTokens) Has 

func (index WriterHandlerCurrentWriterGroupedByUsageTotalTokens) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByUserCredUrl 

type WriterHandlerCurrentWriterGroupedByUserCredUrl map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByUserCredUrl) Has 

func (index WriterHandlerCurrentWriterGroupedByUserCredUrl) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByWorkerHost 

type WriterHandlerCurrentWriterGroupedByWorkerHost map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByWorkerHost) Has 

func (index WriterHandlerCurrentWriterGroupedByWorkerHost) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByWorkerId 

type WriterHandlerCurrentWriterGroupedByWorkerId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByWorkerId) Has 

func (index WriterHandlerCurrentWriterGroupedByWorkerId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByWorkerPid 

type WriterHandlerCurrentWriterGroupedByWorkerPid map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByWorkerPid) Has 

func (index WriterHandlerCurrentWriterGroupedByWorkerPid) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByAgentId 

type WriterHandlerCurrentWriterIndexedByAgentId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByAgentId) Has 

func (index WriterHandlerCurrentWriterIndexedByAgentId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByAttempt 

type WriterHandlerCurrentWriterIndexedByAttempt map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByAttempt) Has 

func (index WriterHandlerCurrentWriterIndexedByAttempt) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByAuthAudience 

type WriterHandlerCurrentWriterIndexedByAuthAudience map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByAuthAudience) Has 

func (index WriterHandlerCurrentWriterIndexedByAuthAudience) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByAuthAuthority 

type WriterHandlerCurrentWriterIndexedByAuthAuthority map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByAuthAuthority) Has 

func (index WriterHandlerCurrentWriterIndexedByAuthAuthority) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByCheckpointData 

type WriterHandlerCurrentWriterIndexedByCheckpointData map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCheckpointData) Has 

func (index WriterHandlerCurrentWriterIndexedByCheckpointData) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByCheckpointMessageId 

type WriterHandlerCurrentWriterIndexedByCheckpointMessageId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCheckpointMessageId) Has 

func (index WriterHandlerCurrentWriterIndexedByCheckpointMessageId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByCheckpointResponseId 

type WriterHandlerCurrentWriterIndexedByCheckpointResponseId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCheckpointResponseId) Has 

func (index WriterHandlerCurrentWriterIndexedByCheckpointResponseId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByCompletedAt 

type WriterHandlerCurrentWriterIndexedByCompletedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCompletedAt) Has 

func (index WriterHandlerCurrentWriterIndexedByCompletedAt) Has(key time.Time) bool

type WriterHandlerCurrentWriterIndexedByCondition 

type WriterHandlerCurrentWriterIndexedByCondition map[predicate.RunPatchCondition]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCondition) Has 

func (index WriterHandlerCurrentWriterIndexedByCondition) Has(key predicate.RunPatchCondition) bool

type WriterHandlerCurrentWriterIndexedByConversationId 

type WriterHandlerCurrentWriterIndexedByConversationId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByConversationId) Has 

func (index WriterHandlerCurrentWriterIndexedByConversationId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByConversationKind 

type WriterHandlerCurrentWriterIndexedByConversationKind map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByConversationKind) Has 

func (index WriterHandlerCurrentWriterIndexedByConversationKind) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByCreatedAt 

type WriterHandlerCurrentWriterIndexedByCreatedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCreatedAt) Has 

func (index WriterHandlerCurrentWriterIndexedByCreatedAt) Has(key time.Time) bool

type WriterHandlerCurrentWriterIndexedByEffectiveUserId 

type WriterHandlerCurrentWriterIndexedByEffectiveUserId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByEffectiveUserId) Has 

func (index WriterHandlerCurrentWriterIndexedByEffectiveUserId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByErrorCode 

type WriterHandlerCurrentWriterIndexedByErrorCode map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByErrorCode) Has 

func (index WriterHandlerCurrentWriterIndexedByErrorCode) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByErrorMessage 

type WriterHandlerCurrentWriterIndexedByErrorMessage map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByErrorMessage) Has 

func (index WriterHandlerCurrentWriterIndexedByErrorMessage) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByHeartbeatIntervalSec 

type WriterHandlerCurrentWriterIndexedByHeartbeatIntervalSec map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByHeartbeatIntervalSec) Has 

func (index WriterHandlerCurrentWriterIndexedByHeartbeatIntervalSec) Has(key int) bool

type WriterHandlerCurrentWriterIndexedById 

type WriterHandlerCurrentWriterIndexedById map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedById) Has 

func (index WriterHandlerCurrentWriterIndexedById) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByIteration 

type WriterHandlerCurrentWriterIndexedByIteration map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByIteration) Has 

func (index WriterHandlerCurrentWriterIndexedByIteration) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByLastHeartbeatAt 

type WriterHandlerCurrentWriterIndexedByLastHeartbeatAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByLastHeartbeatAt) Has 

func (index WriterHandlerCurrentWriterIndexedByLastHeartbeatAt) Has(key time.Time) bool

type WriterHandlerCurrentWriterIndexedByLeaseOwner 

type WriterHandlerCurrentWriterIndexedByLeaseOwner map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByLeaseOwner) Has 

func (index WriterHandlerCurrentWriterIndexedByLeaseOwner) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByLeaseUntil 

type WriterHandlerCurrentWriterIndexedByLeaseUntil map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByLeaseUntil) Has 

func (index WriterHandlerCurrentWriterIndexedByLeaseUntil) Has(key time.Time) bool

type WriterHandlerCurrentWriterIndexedByMaxIterations 

type WriterHandlerCurrentWriterIndexedByMaxIterations map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByMaxIterations) Has 

func (index WriterHandlerCurrentWriterIndexedByMaxIterations) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByModel 

type WriterHandlerCurrentWriterIndexedByModel map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByModel) Has 

func (index WriterHandlerCurrentWriterIndexedByModel) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByModelProvider 

type WriterHandlerCurrentWriterIndexedByModelProvider map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByModelProvider) Has 

func (index WriterHandlerCurrentWriterIndexedByModelProvider) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByPreconditionPassed 

type WriterHandlerCurrentWriterIndexedByPreconditionPassed map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByPreconditionPassed) Has 

func (index WriterHandlerCurrentWriterIndexedByPreconditionPassed) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByPreconditionRanAt 

type WriterHandlerCurrentWriterIndexedByPreconditionRanAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByPreconditionRanAt) Has 

func (index WriterHandlerCurrentWriterIndexedByPreconditionRanAt) Has(key time.Time) bool

type WriterHandlerCurrentWriterIndexedByPreconditionResult 

type WriterHandlerCurrentWriterIndexedByPreconditionResult map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByPreconditionResult) Has 

func (index WriterHandlerCurrentWriterIndexedByPreconditionResult) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByProtocolClientMessageId 

type WriterHandlerCurrentWriterIndexedByProtocolClientMessageId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProtocolClientMessageId) Has 

func (index WriterHandlerCurrentWriterIndexedByProtocolClientMessageId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByProtocolInitialTurnKey 

type WriterHandlerCurrentWriterIndexedByProtocolInitialTurnKey map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProtocolInitialTurnKey) Has 

func (index WriterHandlerCurrentWriterIndexedByProtocolInitialTurnKey) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByProtocolInputHash 

type WriterHandlerCurrentWriterIndexedByProtocolInputHash map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProtocolInputHash) Has 

func (index WriterHandlerCurrentWriterIndexedByProtocolInputHash) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByProtocolInputJson 

type WriterHandlerCurrentWriterIndexedByProtocolInputJson map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProtocolInputJson) Has 

func (index WriterHandlerCurrentWriterIndexedByProtocolInputJson) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByProtocolKey 

type WriterHandlerCurrentWriterIndexedByProtocolKey map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProtocolKey) Has 

func (index WriterHandlerCurrentWriterIndexedByProtocolKey) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByProtocolLastSequence 

type WriterHandlerCurrentWriterIndexedByProtocolLastSequence map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProtocolLastSequence) Has 

func (index WriterHandlerCurrentWriterIndexedByProtocolLastSequence) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByProtocolLeaseOwner 

type WriterHandlerCurrentWriterIndexedByProtocolLeaseOwner map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProtocolLeaseOwner) Has 

func (index WriterHandlerCurrentWriterIndexedByProtocolLeaseOwner) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByProtocolLeaseRevision 

type WriterHandlerCurrentWriterIndexedByProtocolLeaseRevision map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProtocolLeaseRevision) Has 

func (index WriterHandlerCurrentWriterIndexedByProtocolLeaseRevision) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByProtocolLeaseUntil 

type WriterHandlerCurrentWriterIndexedByProtocolLeaseUntil map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProtocolLeaseUntil) Has 

func (index WriterHandlerCurrentWriterIndexedByProtocolLeaseUntil) Has(key time.Time) bool

type WriterHandlerCurrentWriterIndexedByProtocolParentRunId 

type WriterHandlerCurrentWriterIndexedByProtocolParentRunId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProtocolParentRunId) Has 

func (index WriterHandlerCurrentWriterIndexedByProtocolParentRunId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByProtocolPendingJson 

type WriterHandlerCurrentWriterIndexedByProtocolPendingJson map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProtocolPendingJson) Has 

func (index WriterHandlerCurrentWriterIndexedByProtocolPendingJson) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByProtocolPriorRunId 

type WriterHandlerCurrentWriterIndexedByProtocolPriorRunId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProtocolPriorRunId) Has 

func (index WriterHandlerCurrentWriterIndexedByProtocolPriorRunId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByProtocolResumedByRunId 

type WriterHandlerCurrentWriterIndexedByProtocolResumedByRunId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProtocolResumedByRunId) Has 

func (index WriterHandlerCurrentWriterIndexedByProtocolResumedByRunId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByProtocolRevision 

type WriterHandlerCurrentWriterIndexedByProtocolRevision map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProtocolRevision) Has 

func (index WriterHandlerCurrentWriterIndexedByProtocolRevision) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByProtocolRunId 

type WriterHandlerCurrentWriterIndexedByProtocolRunId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProtocolRunId) Has 

func (index WriterHandlerCurrentWriterIndexedByProtocolRunId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByProtocolSourceKey 

type WriterHandlerCurrentWriterIndexedByProtocolSourceKey map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProtocolSourceKey) Has 

func (index WriterHandlerCurrentWriterIndexedByProtocolSourceKey) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByProtocolStatus 

type WriterHandlerCurrentWriterIndexedByProtocolStatus map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProtocolStatus) Has 

func (index WriterHandlerCurrentWriterIndexedByProtocolStatus) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByProtocolTurnId 

type WriterHandlerCurrentWriterIndexedByProtocolTurnId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProtocolTurnId) Has 

func (index WriterHandlerCurrentWriterIndexedByProtocolTurnId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByResumedFromRunId 

type WriterHandlerCurrentWriterIndexedByResumedFromRunId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByResumedFromRunId) Has 

func (index WriterHandlerCurrentWriterIndexedByResumedFromRunId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByRunKind 

type WriterHandlerCurrentWriterIndexedByRunKind map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByRunKind) Has 

func (index WriterHandlerCurrentWriterIndexedByRunKind) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByScheduleId 

type WriterHandlerCurrentWriterIndexedByScheduleId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByScheduleId) Has 

func (index WriterHandlerCurrentWriterIndexedByScheduleId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByScheduledFor 

type WriterHandlerCurrentWriterIndexedByScheduledFor map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByScheduledFor) Has 

func (index WriterHandlerCurrentWriterIndexedByScheduledFor) Has(key time.Time) bool

type WriterHandlerCurrentWriterIndexedBySecurityContext 

type WriterHandlerCurrentWriterIndexedBySecurityContext map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedBySecurityContext) Has 

func (index WriterHandlerCurrentWriterIndexedBySecurityContext) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByStartedAt 

type WriterHandlerCurrentWriterIndexedByStartedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByStartedAt) Has 

func (index WriterHandlerCurrentWriterIndexedByStartedAt) Has(key time.Time) bool

type WriterHandlerCurrentWriterIndexedByStatus 

type WriterHandlerCurrentWriterIndexedByStatus map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByStatus) Has 

func (index WriterHandlerCurrentWriterIndexedByStatus) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByTurnId 

type WriterHandlerCurrentWriterIndexedByTurnId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByTurnId) Has 

func (index WriterHandlerCurrentWriterIndexedByTurnId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByUpdatedAt 

type WriterHandlerCurrentWriterIndexedByUpdatedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByUpdatedAt) Has 

func (index WriterHandlerCurrentWriterIndexedByUpdatedAt) Has(key time.Time) bool

type WriterHandlerCurrentWriterIndexedByUsageCompletionTokens 

type WriterHandlerCurrentWriterIndexedByUsageCompletionTokens map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByUsageCompletionTokens) Has 

func (index WriterHandlerCurrentWriterIndexedByUsageCompletionTokens) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByUsageCost 

type WriterHandlerCurrentWriterIndexedByUsageCost map[float64]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByUsageCost) Has 

func (index WriterHandlerCurrentWriterIndexedByUsageCost) Has(key float64) bool

type WriterHandlerCurrentWriterIndexedByUsagePromptTokens 

type WriterHandlerCurrentWriterIndexedByUsagePromptTokens map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByUsagePromptTokens) Has 

func (index WriterHandlerCurrentWriterIndexedByUsagePromptTokens) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByUsageTotalTokens 

type WriterHandlerCurrentWriterIndexedByUsageTotalTokens map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByUsageTotalTokens) Has 

func (index WriterHandlerCurrentWriterIndexedByUsageTotalTokens) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByUserCredUrl 

type WriterHandlerCurrentWriterIndexedByUserCredUrl map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByUserCredUrl) Has 

func (index WriterHandlerCurrentWriterIndexedByUserCredUrl) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByWorkerHost 

type WriterHandlerCurrentWriterIndexedByWorkerHost map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByWorkerHost) Has 

func (index WriterHandlerCurrentWriterIndexedByWorkerHost) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByWorkerId 

type WriterHandlerCurrentWriterIndexedByWorkerId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByWorkerId) Has 

func (index WriterHandlerCurrentWriterIndexedByWorkerId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByWorkerPid 

type WriterHandlerCurrentWriterIndexedByWorkerPid map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByWorkerPid) Has 

func (index WriterHandlerCurrentWriterIndexedByWorkerPid) Has(key int) bool

type WriterHandlerCurrentWriterSlice 

type WriterHandlerCurrentWriterSlice []*CurrentWriterView

func (WriterHandlerCurrentWriterSlice) GroupByAgentId 

func (rows WriterHandlerCurrentWriterSlice) GroupByAgentId() WriterHandlerCurrentWriterGroupedByAgentId

func (WriterHandlerCurrentWriterSlice) GroupByAttempt 

func (rows WriterHandlerCurrentWriterSlice) GroupByAttempt() WriterHandlerCurrentWriterGroupedByAttempt

func (WriterHandlerCurrentWriterSlice) GroupByAuthAudience 

func (rows WriterHandlerCurrentWriterSlice) GroupByAuthAudience() WriterHandlerCurrentWriterGroupedByAuthAudience

func (WriterHandlerCurrentWriterSlice) GroupByAuthAuthority 

func (rows WriterHandlerCurrentWriterSlice) GroupByAuthAuthority() WriterHandlerCurrentWriterGroupedByAuthAuthority

func (WriterHandlerCurrentWriterSlice) GroupByCheckpointData 

func (rows WriterHandlerCurrentWriterSlice) GroupByCheckpointData() WriterHandlerCurrentWriterGroupedByCheckpointData

func (WriterHandlerCurrentWriterSlice) GroupByCheckpointMessageId 

func (rows WriterHandlerCurrentWriterSlice) GroupByCheckpointMessageId() WriterHandlerCurrentWriterGroupedByCheckpointMessageId

func (WriterHandlerCurrentWriterSlice) GroupByCheckpointResponseId 

func (rows WriterHandlerCurrentWriterSlice) GroupByCheckpointResponseId() WriterHandlerCurrentWriterGroupedByCheckpointResponseId

func (WriterHandlerCurrentWriterSlice) GroupByCompletedAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByCompletedAt() WriterHandlerCurrentWriterGroupedByCompletedAt

func (WriterHandlerCurrentWriterSlice) GroupByCondition 

func (rows WriterHandlerCurrentWriterSlice) GroupByCondition() WriterHandlerCurrentWriterGroupedByCondition

func (WriterHandlerCurrentWriterSlice) GroupByConversationId 

func (rows WriterHandlerCurrentWriterSlice) GroupByConversationId() WriterHandlerCurrentWriterGroupedByConversationId

func (WriterHandlerCurrentWriterSlice) GroupByConversationKind 

func (rows WriterHandlerCurrentWriterSlice) GroupByConversationKind() WriterHandlerCurrentWriterGroupedByConversationKind

func (WriterHandlerCurrentWriterSlice) GroupByCreatedAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByCreatedAt() WriterHandlerCurrentWriterGroupedByCreatedAt

func (WriterHandlerCurrentWriterSlice) GroupByEffectiveUserId 

func (rows WriterHandlerCurrentWriterSlice) GroupByEffectiveUserId() WriterHandlerCurrentWriterGroupedByEffectiveUserId

func (WriterHandlerCurrentWriterSlice) GroupByErrorCode 

func (rows WriterHandlerCurrentWriterSlice) GroupByErrorCode() WriterHandlerCurrentWriterGroupedByErrorCode

func (WriterHandlerCurrentWriterSlice) GroupByErrorMessage 

func (rows WriterHandlerCurrentWriterSlice) GroupByErrorMessage() WriterHandlerCurrentWriterGroupedByErrorMessage

func (WriterHandlerCurrentWriterSlice) GroupByHeartbeatIntervalSec 

func (rows WriterHandlerCurrentWriterSlice) GroupByHeartbeatIntervalSec() WriterHandlerCurrentWriterGroupedByHeartbeatIntervalSec

func (WriterHandlerCurrentWriterSlice) GroupById 

func (rows WriterHandlerCurrentWriterSlice) GroupById() WriterHandlerCurrentWriterGroupedById

func (WriterHandlerCurrentWriterSlice) GroupByIteration 

func (rows WriterHandlerCurrentWriterSlice) GroupByIteration() WriterHandlerCurrentWriterGroupedByIteration

func (WriterHandlerCurrentWriterSlice) GroupByLastHeartbeatAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByLastHeartbeatAt() WriterHandlerCurrentWriterGroupedByLastHeartbeatAt

func (WriterHandlerCurrentWriterSlice) GroupByLeaseOwner 

func (rows WriterHandlerCurrentWriterSlice) GroupByLeaseOwner() WriterHandlerCurrentWriterGroupedByLeaseOwner

func (WriterHandlerCurrentWriterSlice) GroupByLeaseUntil 

func (rows WriterHandlerCurrentWriterSlice) GroupByLeaseUntil() WriterHandlerCurrentWriterGroupedByLeaseUntil

func (WriterHandlerCurrentWriterSlice) GroupByMaxIterations 

func (rows WriterHandlerCurrentWriterSlice) GroupByMaxIterations() WriterHandlerCurrentWriterGroupedByMaxIterations

func (WriterHandlerCurrentWriterSlice) GroupByModel 

func (rows WriterHandlerCurrentWriterSlice) GroupByModel() WriterHandlerCurrentWriterGroupedByModel

func (WriterHandlerCurrentWriterSlice) GroupByModelProvider 

func (rows WriterHandlerCurrentWriterSlice) GroupByModelProvider() WriterHandlerCurrentWriterGroupedByModelProvider

func (WriterHandlerCurrentWriterSlice) GroupByPreconditionPassed 

func (rows WriterHandlerCurrentWriterSlice) GroupByPreconditionPassed() WriterHandlerCurrentWriterGroupedByPreconditionPassed

func (WriterHandlerCurrentWriterSlice) GroupByPreconditionRanAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByPreconditionRanAt() WriterHandlerCurrentWriterGroupedByPreconditionRanAt

func (WriterHandlerCurrentWriterSlice) GroupByPreconditionResult 

func (rows WriterHandlerCurrentWriterSlice) GroupByPreconditionResult() WriterHandlerCurrentWriterGroupedByPreconditionResult

func (WriterHandlerCurrentWriterSlice) GroupByProtocolClientMessageId 

func (rows WriterHandlerCurrentWriterSlice) GroupByProtocolClientMessageId() WriterHandlerCurrentWriterGroupedByProtocolClientMessageId

func (WriterHandlerCurrentWriterSlice) GroupByProtocolInitialTurnKey 

func (rows WriterHandlerCurrentWriterSlice) GroupByProtocolInitialTurnKey() WriterHandlerCurrentWriterGroupedByProtocolInitialTurnKey

func (WriterHandlerCurrentWriterSlice) GroupByProtocolInputHash 

func (rows WriterHandlerCurrentWriterSlice) GroupByProtocolInputHash() WriterHandlerCurrentWriterGroupedByProtocolInputHash

func (WriterHandlerCurrentWriterSlice) GroupByProtocolInputJson 

func (rows WriterHandlerCurrentWriterSlice) GroupByProtocolInputJson() WriterHandlerCurrentWriterGroupedByProtocolInputJson

func (WriterHandlerCurrentWriterSlice) GroupByProtocolKey 

func (rows WriterHandlerCurrentWriterSlice) GroupByProtocolKey() WriterHandlerCurrentWriterGroupedByProtocolKey

func (WriterHandlerCurrentWriterSlice) GroupByProtocolLastSequence 

func (rows WriterHandlerCurrentWriterSlice) GroupByProtocolLastSequence() WriterHandlerCurrentWriterGroupedByProtocolLastSequence

func (WriterHandlerCurrentWriterSlice) GroupByProtocolLeaseOwner 

func (rows WriterHandlerCurrentWriterSlice) GroupByProtocolLeaseOwner() WriterHandlerCurrentWriterGroupedByProtocolLeaseOwner

func (WriterHandlerCurrentWriterSlice) GroupByProtocolLeaseRevision 

func (rows WriterHandlerCurrentWriterSlice) GroupByProtocolLeaseRevision() WriterHandlerCurrentWriterGroupedByProtocolLeaseRevision

func (WriterHandlerCurrentWriterSlice) GroupByProtocolLeaseUntil 

func (rows WriterHandlerCurrentWriterSlice) GroupByProtocolLeaseUntil() WriterHandlerCurrentWriterGroupedByProtocolLeaseUntil

func (WriterHandlerCurrentWriterSlice) GroupByProtocolParentRunId 

func (rows WriterHandlerCurrentWriterSlice) GroupByProtocolParentRunId() WriterHandlerCurrentWriterGroupedByProtocolParentRunId

func (WriterHandlerCurrentWriterSlice) GroupByProtocolPendingJson 

func (rows WriterHandlerCurrentWriterSlice) GroupByProtocolPendingJson() WriterHandlerCurrentWriterGroupedByProtocolPendingJson

func (WriterHandlerCurrentWriterSlice) GroupByProtocolPriorRunId 

func (rows WriterHandlerCurrentWriterSlice) GroupByProtocolPriorRunId() WriterHandlerCurrentWriterGroupedByProtocolPriorRunId

func (WriterHandlerCurrentWriterSlice) GroupByProtocolResumedByRunId 

func (rows WriterHandlerCurrentWriterSlice) GroupByProtocolResumedByRunId() WriterHandlerCurrentWriterGroupedByProtocolResumedByRunId

func (WriterHandlerCurrentWriterSlice) GroupByProtocolRevision 

func (rows WriterHandlerCurrentWriterSlice) GroupByProtocolRevision() WriterHandlerCurrentWriterGroupedByProtocolRevision

func (WriterHandlerCurrentWriterSlice) GroupByProtocolRunId 

func (rows WriterHandlerCurrentWriterSlice) GroupByProtocolRunId() WriterHandlerCurrentWriterGroupedByProtocolRunId

func (WriterHandlerCurrentWriterSlice) GroupByProtocolSourceKey 

func (rows WriterHandlerCurrentWriterSlice) GroupByProtocolSourceKey() WriterHandlerCurrentWriterGroupedByProtocolSourceKey

func (WriterHandlerCurrentWriterSlice) GroupByProtocolStatus 

func (rows WriterHandlerCurrentWriterSlice) GroupByProtocolStatus() WriterHandlerCurrentWriterGroupedByProtocolStatus

func (WriterHandlerCurrentWriterSlice) GroupByProtocolTurnId 

func (rows WriterHandlerCurrentWriterSlice) GroupByProtocolTurnId() WriterHandlerCurrentWriterGroupedByProtocolTurnId

func (WriterHandlerCurrentWriterSlice) GroupByResumedFromRunId 

func (rows WriterHandlerCurrentWriterSlice) GroupByResumedFromRunId() WriterHandlerCurrentWriterGroupedByResumedFromRunId

func (WriterHandlerCurrentWriterSlice) GroupByRunKind 

func (rows WriterHandlerCurrentWriterSlice) GroupByRunKind() WriterHandlerCurrentWriterGroupedByRunKind

func (WriterHandlerCurrentWriterSlice) GroupByScheduleId 

func (rows WriterHandlerCurrentWriterSlice) GroupByScheduleId() WriterHandlerCurrentWriterGroupedByScheduleId

func (WriterHandlerCurrentWriterSlice) GroupByScheduledFor 

func (rows WriterHandlerCurrentWriterSlice) GroupByScheduledFor() WriterHandlerCurrentWriterGroupedByScheduledFor

func (WriterHandlerCurrentWriterSlice) GroupBySecurityContext 

func (rows WriterHandlerCurrentWriterSlice) GroupBySecurityContext() WriterHandlerCurrentWriterGroupedBySecurityContext

func (WriterHandlerCurrentWriterSlice) GroupByStartedAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByStartedAt() WriterHandlerCurrentWriterGroupedByStartedAt

func (WriterHandlerCurrentWriterSlice) GroupByStatus 

func (rows WriterHandlerCurrentWriterSlice) GroupByStatus() WriterHandlerCurrentWriterGroupedByStatus

func (WriterHandlerCurrentWriterSlice) GroupByTurnId 

func (rows WriterHandlerCurrentWriterSlice) GroupByTurnId() WriterHandlerCurrentWriterGroupedByTurnId

func (WriterHandlerCurrentWriterSlice) GroupByUpdatedAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByUpdatedAt() WriterHandlerCurrentWriterGroupedByUpdatedAt

func (WriterHandlerCurrentWriterSlice) GroupByUsageCompletionTokens 

func (rows WriterHandlerCurrentWriterSlice) GroupByUsageCompletionTokens() WriterHandlerCurrentWriterGroupedByUsageCompletionTokens

func (WriterHandlerCurrentWriterSlice) GroupByUsageCost 

func (rows WriterHandlerCurrentWriterSlice) GroupByUsageCost() WriterHandlerCurrentWriterGroupedByUsageCost

func (WriterHandlerCurrentWriterSlice) GroupByUsagePromptTokens 

func (rows WriterHandlerCurrentWriterSlice) GroupByUsagePromptTokens() WriterHandlerCurrentWriterGroupedByUsagePromptTokens

func (WriterHandlerCurrentWriterSlice) GroupByUsageTotalTokens 

func (rows WriterHandlerCurrentWriterSlice) GroupByUsageTotalTokens() WriterHandlerCurrentWriterGroupedByUsageTotalTokens

func (WriterHandlerCurrentWriterSlice) GroupByUserCredUrl 

func (rows WriterHandlerCurrentWriterSlice) GroupByUserCredUrl() WriterHandlerCurrentWriterGroupedByUserCredUrl

func (WriterHandlerCurrentWriterSlice) GroupByWorkerHost 

func (rows WriterHandlerCurrentWriterSlice) GroupByWorkerHost() WriterHandlerCurrentWriterGroupedByWorkerHost

func (WriterHandlerCurrentWriterSlice) GroupByWorkerId 

func (rows WriterHandlerCurrentWriterSlice) GroupByWorkerId() WriterHandlerCurrentWriterGroupedByWorkerId

func (WriterHandlerCurrentWriterSlice) GroupByWorkerPid 

func (rows WriterHandlerCurrentWriterSlice) GroupByWorkerPid() WriterHandlerCurrentWriterGroupedByWorkerPid

func (WriterHandlerCurrentWriterSlice) IndexByAgentId 

func (rows WriterHandlerCurrentWriterSlice) IndexByAgentId() (WriterHandlerCurrentWriterIndexedByAgentId, error)

func (WriterHandlerCurrentWriterSlice) IndexByAttempt 

func (rows WriterHandlerCurrentWriterSlice) IndexByAttempt() (WriterHandlerCurrentWriterIndexedByAttempt, error)

func (WriterHandlerCurrentWriterSlice) IndexByAuthAudience 

func (rows WriterHandlerCurrentWriterSlice) IndexByAuthAudience() (WriterHandlerCurrentWriterIndexedByAuthAudience, error)

func (WriterHandlerCurrentWriterSlice) IndexByAuthAuthority 

func (rows WriterHandlerCurrentWriterSlice) IndexByAuthAuthority() (WriterHandlerCurrentWriterIndexedByAuthAuthority, error)

func (WriterHandlerCurrentWriterSlice) IndexByCheckpointData 

func (rows WriterHandlerCurrentWriterSlice) IndexByCheckpointData() (WriterHandlerCurrentWriterIndexedByCheckpointData, error)

func (WriterHandlerCurrentWriterSlice) IndexByCheckpointMessageId 

func (rows WriterHandlerCurrentWriterSlice) IndexByCheckpointMessageId() (WriterHandlerCurrentWriterIndexedByCheckpointMessageId, error)

func (WriterHandlerCurrentWriterSlice) IndexByCheckpointResponseId 

func (rows WriterHandlerCurrentWriterSlice) IndexByCheckpointResponseId() (WriterHandlerCurrentWriterIndexedByCheckpointResponseId, error)

func (WriterHandlerCurrentWriterSlice) IndexByCompletedAt 

func (rows WriterHandlerCurrentWriterSlice) IndexByCompletedAt() (WriterHandlerCurrentWriterIndexedByCompletedAt, error)

func (WriterHandlerCurrentWriterSlice) IndexByCondition 

func (rows WriterHandlerCurrentWriterSlice) IndexByCondition() (WriterHandlerCurrentWriterIndexedByCondition, error)

func (WriterHandlerCurrentWriterSlice) IndexByConversationId 

func (rows WriterHandlerCurrentWriterSlice) IndexByConversationId() (WriterHandlerCurrentWriterIndexedByConversationId, error)

func (WriterHandlerCurrentWriterSlice) IndexByConversationKind 

func (rows WriterHandlerCurrentWriterSlice) IndexByConversationKind() (WriterHandlerCurrentWriterIndexedByConversationKind, error)

func (WriterHandlerCurrentWriterSlice) IndexByCreatedAt 

func (rows WriterHandlerCurrentWriterSlice) IndexByCreatedAt() (WriterHandlerCurrentWriterIndexedByCreatedAt, error)

func (WriterHandlerCurrentWriterSlice) IndexByEffectiveUserId 

func (rows WriterHandlerCurrentWriterSlice) IndexByEffectiveUserId() (WriterHandlerCurrentWriterIndexedByEffectiveUserId, error)

func (WriterHandlerCurrentWriterSlice) IndexByErrorCode 

func (rows WriterHandlerCurrentWriterSlice) IndexByErrorCode() (WriterHandlerCurrentWriterIndexedByErrorCode, error)

func (WriterHandlerCurrentWriterSlice) IndexByErrorMessage 

func (rows WriterHandlerCurrentWriterSlice) IndexByErrorMessage() (WriterHandlerCurrentWriterIndexedByErrorMessage, error)

func (WriterHandlerCurrentWriterSlice) IndexByHeartbeatIntervalSec 

func (rows WriterHandlerCurrentWriterSlice) IndexByHeartbeatIntervalSec() (WriterHandlerCurrentWriterIndexedByHeartbeatIntervalSec, error)

func (WriterHandlerCurrentWriterSlice) IndexById 

func (rows WriterHandlerCurrentWriterSlice) IndexById() (WriterHandlerCurrentWriterIndexedById, error)

func (WriterHandlerCurrentWriterSlice) IndexByIteration 

func (rows WriterHandlerCurrentWriterSlice) IndexByIteration() (WriterHandlerCurrentWriterIndexedByIteration, error)

func (WriterHandlerCurrentWriterSlice) IndexByLastHeartbeatAt 

func (rows WriterHandlerCurrentWriterSlice) IndexByLastHeartbeatAt() (WriterHandlerCurrentWriterIndexedByLastHeartbeatAt, error)

func (WriterHandlerCurrentWriterSlice) IndexByLeaseOwner 

func (rows WriterHandlerCurrentWriterSlice) IndexByLeaseOwner() (WriterHandlerCurrentWriterIndexedByLeaseOwner, error)

func (WriterHandlerCurrentWriterSlice) IndexByLeaseUntil 

func (rows WriterHandlerCurrentWriterSlice) IndexByLeaseUntil() (WriterHandlerCurrentWriterIndexedByLeaseUntil, error)

func (WriterHandlerCurrentWriterSlice) IndexByMaxIterations 

func (rows WriterHandlerCurrentWriterSlice) IndexByMaxIterations() (WriterHandlerCurrentWriterIndexedByMaxIterations, error)

func (WriterHandlerCurrentWriterSlice) IndexByModel 

func (rows WriterHandlerCurrentWriterSlice) IndexByModel() (WriterHandlerCurrentWriterIndexedByModel, error)

func (WriterHandlerCurrentWriterSlice) IndexByModelProvider 

func (rows WriterHandlerCurrentWriterSlice) IndexByModelProvider() (WriterHandlerCurrentWriterIndexedByModelProvider, error)

func (WriterHandlerCurrentWriterSlice) IndexByPreconditionPassed 

func (rows WriterHandlerCurrentWriterSlice) IndexByPreconditionPassed() (WriterHandlerCurrentWriterIndexedByPreconditionPassed, error)

func (WriterHandlerCurrentWriterSlice) IndexByPreconditionRanAt 

func (rows WriterHandlerCurrentWriterSlice) IndexByPreconditionRanAt() (WriterHandlerCurrentWriterIndexedByPreconditionRanAt, error)

func (WriterHandlerCurrentWriterSlice) IndexByPreconditionResult 

func (rows WriterHandlerCurrentWriterSlice) IndexByPreconditionResult() (WriterHandlerCurrentWriterIndexedByPreconditionResult, error)

func (WriterHandlerCurrentWriterSlice) IndexByProtocolClientMessageId 

func (rows WriterHandlerCurrentWriterSlice) IndexByProtocolClientMessageId() (WriterHandlerCurrentWriterIndexedByProtocolClientMessageId, error)

func (WriterHandlerCurrentWriterSlice) IndexByProtocolInitialTurnKey 

func (rows WriterHandlerCurrentWriterSlice) IndexByProtocolInitialTurnKey() (WriterHandlerCurrentWriterIndexedByProtocolInitialTurnKey, error)

func (WriterHandlerCurrentWriterSlice) IndexByProtocolInputHash 

func (rows WriterHandlerCurrentWriterSlice) IndexByProtocolInputHash() (WriterHandlerCurrentWriterIndexedByProtocolInputHash, error)

func (WriterHandlerCurrentWriterSlice) IndexByProtocolInputJson 

func (rows WriterHandlerCurrentWriterSlice) IndexByProtocolInputJson() (WriterHandlerCurrentWriterIndexedByProtocolInputJson, error)

func (WriterHandlerCurrentWriterSlice) IndexByProtocolKey 

func (rows WriterHandlerCurrentWriterSlice) IndexByProtocolKey() (WriterHandlerCurrentWriterIndexedByProtocolKey, error)

func (WriterHandlerCurrentWriterSlice) IndexByProtocolLastSequence 

func (rows WriterHandlerCurrentWriterSlice) IndexByProtocolLastSequence() (WriterHandlerCurrentWriterIndexedByProtocolLastSequence, error)

func (WriterHandlerCurrentWriterSlice) IndexByProtocolLeaseOwner 

func (rows WriterHandlerCurrentWriterSlice) IndexByProtocolLeaseOwner() (WriterHandlerCurrentWriterIndexedByProtocolLeaseOwner, error)

func (WriterHandlerCurrentWriterSlice) IndexByProtocolLeaseRevision 

func (rows WriterHandlerCurrentWriterSlice) IndexByProtocolLeaseRevision() (WriterHandlerCurrentWriterIndexedByProtocolLeaseRevision, error)

func (WriterHandlerCurrentWriterSlice) IndexByProtocolLeaseUntil 

func (rows WriterHandlerCurrentWriterSlice) IndexByProtocolLeaseUntil() (WriterHandlerCurrentWriterIndexedByProtocolLeaseUntil, error)

func (WriterHandlerCurrentWriterSlice) IndexByProtocolParentRunId 

func (rows WriterHandlerCurrentWriterSlice) IndexByProtocolParentRunId() (WriterHandlerCurrentWriterIndexedByProtocolParentRunId, error)

func (WriterHandlerCurrentWriterSlice) IndexByProtocolPendingJson 

func (rows WriterHandlerCurrentWriterSlice) IndexByProtocolPendingJson() (WriterHandlerCurrentWriterIndexedByProtocolPendingJson, error)

func (WriterHandlerCurrentWriterSlice) IndexByProtocolPriorRunId 

func (rows WriterHandlerCurrentWriterSlice) IndexByProtocolPriorRunId() (WriterHandlerCurrentWriterIndexedByProtocolPriorRunId, error)

func (WriterHandlerCurrentWriterSlice) IndexByProtocolResumedByRunId 

func (rows WriterHandlerCurrentWriterSlice) IndexByProtocolResumedByRunId() (WriterHandlerCurrentWriterIndexedByProtocolResumedByRunId, error)

func (WriterHandlerCurrentWriterSlice) IndexByProtocolRevision 

func (rows WriterHandlerCurrentWriterSlice) IndexByProtocolRevision() (WriterHandlerCurrentWriterIndexedByProtocolRevision, error)

func (WriterHandlerCurrentWriterSlice) IndexByProtocolRunId 

func (rows WriterHandlerCurrentWriterSlice) IndexByProtocolRunId() (WriterHandlerCurrentWriterIndexedByProtocolRunId, error)

func (WriterHandlerCurrentWriterSlice) IndexByProtocolSourceKey 

func (rows WriterHandlerCurrentWriterSlice) IndexByProtocolSourceKey() (WriterHandlerCurrentWriterIndexedByProtocolSourceKey, error)

func (WriterHandlerCurrentWriterSlice) IndexByProtocolStatus 

func (rows WriterHandlerCurrentWriterSlice) IndexByProtocolStatus() (WriterHandlerCurrentWriterIndexedByProtocolStatus, error)

func (WriterHandlerCurrentWriterSlice) IndexByProtocolTurnId 

func (rows WriterHandlerCurrentWriterSlice) IndexByProtocolTurnId() (WriterHandlerCurrentWriterIndexedByProtocolTurnId, error)

func (WriterHandlerCurrentWriterSlice) IndexByResumedFromRunId 

func (rows WriterHandlerCurrentWriterSlice) IndexByResumedFromRunId() (WriterHandlerCurrentWriterIndexedByResumedFromRunId, error)

func (WriterHandlerCurrentWriterSlice) IndexByRunKind 

func (rows WriterHandlerCurrentWriterSlice) IndexByRunKind() (WriterHandlerCurrentWriterIndexedByRunKind, error)

func (WriterHandlerCurrentWriterSlice) IndexByScheduleId 

func (rows WriterHandlerCurrentWriterSlice) IndexByScheduleId() (WriterHandlerCurrentWriterIndexedByScheduleId, error)

func (WriterHandlerCurrentWriterSlice) IndexByScheduledFor 

func (rows WriterHandlerCurrentWriterSlice) IndexByScheduledFor() (WriterHandlerCurrentWriterIndexedByScheduledFor, error)

func (WriterHandlerCurrentWriterSlice) IndexBySecurityContext 

func (rows WriterHandlerCurrentWriterSlice) IndexBySecurityContext() (WriterHandlerCurrentWriterIndexedBySecurityContext, error)

func (WriterHandlerCurrentWriterSlice) IndexByStartedAt 

func (rows WriterHandlerCurrentWriterSlice) IndexByStartedAt() (WriterHandlerCurrentWriterIndexedByStartedAt, error)

func (WriterHandlerCurrentWriterSlice) IndexByStatus 

func (rows WriterHandlerCurrentWriterSlice) IndexByStatus() (WriterHandlerCurrentWriterIndexedByStatus, error)

func (WriterHandlerCurrentWriterSlice) IndexByTurnId 

func (rows WriterHandlerCurrentWriterSlice) IndexByTurnId() (WriterHandlerCurrentWriterIndexedByTurnId, error)

func (WriterHandlerCurrentWriterSlice) IndexByUpdatedAt 

func (rows WriterHandlerCurrentWriterSlice) IndexByUpdatedAt() (WriterHandlerCurrentWriterIndexedByUpdatedAt, error)

func (WriterHandlerCurrentWriterSlice) IndexByUsageCompletionTokens 

func (rows WriterHandlerCurrentWriterSlice) IndexByUsageCompletionTokens() (WriterHandlerCurrentWriterIndexedByUsageCompletionTokens, error)

func (WriterHandlerCurrentWriterSlice) IndexByUsageCost 

func (rows WriterHandlerCurrentWriterSlice) IndexByUsageCost() (WriterHandlerCurrentWriterIndexedByUsageCost, error)

func (WriterHandlerCurrentWriterSlice) IndexByUsagePromptTokens 

func (rows WriterHandlerCurrentWriterSlice) IndexByUsagePromptTokens() (WriterHandlerCurrentWriterIndexedByUsagePromptTokens, error)

func (WriterHandlerCurrentWriterSlice) IndexByUsageTotalTokens 

func (rows WriterHandlerCurrentWriterSlice) IndexByUsageTotalTokens() (WriterHandlerCurrentWriterIndexedByUsageTotalTokens, error)

func (WriterHandlerCurrentWriterSlice) IndexByUserCredUrl 

func (rows WriterHandlerCurrentWriterSlice) IndexByUserCredUrl() (WriterHandlerCurrentWriterIndexedByUserCredUrl, error)

func (WriterHandlerCurrentWriterSlice) IndexByWorkerHost 

func (rows WriterHandlerCurrentWriterSlice) IndexByWorkerHost() (WriterHandlerCurrentWriterIndexedByWorkerHost, error)

func (WriterHandlerCurrentWriterSlice) IndexByWorkerId 

func (rows WriterHandlerCurrentWriterSlice) IndexByWorkerId() (WriterHandlerCurrentWriterIndexedByWorkerId, error)

func (WriterHandlerCurrentWriterSlice) IndexByWorkerPid 

func (rows WriterHandlerCurrentWriterSlice) IndexByWorkerPid() (WriterHandlerCurrentWriterIndexedByWorkerPid, error)

type WriterHandlerReadIndexes 

type WriterHandlerReadIndexes struct {
	CurrentWriter     WriterHandlerCurrentWriterSlice
	CurrentWriterById WriterHandlerCurrentWriterIndexedById
}

func BuildWriterHandlerReadIndexes 

func BuildWriterHandlerReadIndexes(ctx context.Context, input *Input) (*WriterHandlerReadIndexes, error)

type WriterKeysRow 

type WriterKeysRow struct {
	Id string `sqlx:"id"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.