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

write

package
v0.1.57 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: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const WriterDatlyResourceNamespace = "datly_turn_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 WriterHandlerCurrentWriterIndexByAgentConfigUsedIdKey 

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

func WriterHandlerCurrentWriterIndexByAgentIdUsedKey 

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

func WriterHandlerCurrentWriterIndexByConversationIdKey 

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

func WriterHandlerCurrentWriterIndexByCreatedAtKey 

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

func WriterHandlerCurrentWriterIndexByErrorMessageKey 

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

func WriterHandlerCurrentWriterIndexByGoalIdKey 

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

func WriterHandlerCurrentWriterIndexByIdKey 

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

func WriterHandlerCurrentWriterIndexByModelOverrideKey 

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

func WriterHandlerCurrentWriterIndexByModelOverrideProviderKey 

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

func WriterHandlerCurrentWriterIndexByModelParamsOverrideKey 

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

func WriterHandlerCurrentWriterIndexByOriginKey 

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

func WriterHandlerCurrentWriterIndexByQueueSeqKey 

func WriterHandlerCurrentWriterIndexByQueueSeqKey(value *CurrentWriterView) (int64, bool)

func WriterHandlerCurrentWriterIndexByRetryOfKey 

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

func WriterHandlerCurrentWriterIndexByRunIdKey 

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

func WriterHandlerCurrentWriterIndexByStartedByMessageIdKey 

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

func WriterHandlerCurrentWriterIndexByStatusKey 

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

func WriterHandlerCurrentWriterIndexByStatusReasonKey 

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

Types

type CurrentWriterView 

type CurrentWriterView struct {
	Id                    string     `validate:"required" sqlx:"id,primaryKey" json:"id"`
	ConversationId        string     `validate:"required" json:"conversationId" sqlx:"conversation_id,refTable=conversation,refColumn=id,required=true"`
	QueueSeq              *int64     `sqlx:"queue_seq" json:"queueSeq,omitempty"`
	Status                string     `validate:"required" json:"status" sqlx:"status,required=true"`
	CreatedAt             *time.Time `sqlx:"created_at,required=true" json:"createdAt,omitempty"`
	Origin                *string    `sqlx:"origin" json:"origin,omitempty"`
	GoalId                *string    `sqlx:"goal_id" json:"goalId,omitempty"`
	StatusReason          *string    `sqlx:"status_reason" json:"statusReason,omitempty"`
	ErrorMessage          *string    `sqlx:"error_message" json:"errorMessage,omitempty"`
	StartedByMessageId    *string    `sqlx:"started_by_message_id" json:"startedByMessageId,omitempty"`
	RetryOf               *string    `sqlx:"retry_of" json:"retryOf,omitempty"`
	AgentIdUsed           *string    `sqlx:"agent_id_used" json:"agentIdUsed,omitempty"`
	AgentConfigUsedId     *string    `sqlx:"agent_config_used_id" json:"agentConfigUsedId,omitempty"`
	ModelOverrideProvider *string    `sqlx:"model_override_provider" json:"modelOverrideProvider,omitempty"`
	ModelOverride         *string    `sqlx:"model_override" json:"modelOverride,omitempty"`
	ModelParamsOverride   *string    `sqlx:"model_params_override" json:"modelParamsOverride,omitempty"`
	RunId                 *string    `sqlx:"run_id" json:"runId,omitempty"`
}

CurrentWriterView is generated canonical view metadata for writer.

type Input 

type Input struct {
	OrphanDetach  bool                 `parameter:"OrphanDetach,kind=orphandetach,in=enabledDetach,dataType=bool,required=false"`
	OrphanColumn  string               `parameter:"OrphanColumn,kind=orphandetach,in=column,dataType=string,required=false"`
	Turns         []*Turn              `` /* 182-byte string literal not displayed */
	WriterKeys    []WriterKeysRow      `` /* 126-byte string literal not displayed */
	CurrentWriter []*CurrentWriterView `` /* 158-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(context.Context) error

Legacy turn deletion acknowledges blank identities without touching storage.

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) SetOrphanColumn 

func (input *Input) SetOrphanColumn(value string)

func (*Input) SetOrphanDetach 

func (input *Input) SetOrphanDetach(value bool)

func (*Input) SetTurns 

func (input *Input) SetTurns(value []*Turn)

func (*Input) SetWriterKeys 

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

type InputHas 

type InputHas struct {
	OrphanDetach  bool
	OrphanColumn  bool
	Turns         bool
	WriterKeys    bool
	CurrentWriter bool
}

type Lifecycle 

type Lifecycle struct {
	Input *Input `bind:"kind=input"`
}

Lifecycle customizes role Input.Turns.

func (*Lifecycle) AfterQueue 

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

func (*Lifecycle) AfterSequence 

func (hooks *Lifecycle) AfterSequence(ctx context.Context, entity *Turn, state xhandler.LifecycleContext[Turn, 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 *Turn, state xhandler.LifecycleContext[Turn, xhandler.NoParent, Output]) error

func (*Lifecycle) Validate 

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

type Output 

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

Output is the generated output scaffold for writer.

type Turn 

type Turn struct {
	ShouldDelete          bool       `sqlx:"-" writer:"delete" json:"shouldDelete,omitempty"`
	Id                    string     `validate:"required" sqlx:"id,primaryKey" json:"id"`
	ConversationId        string     `validate:"required" json:"conversationId" sqlx:"conversation_id,refTable=conversation,refColumn=id,required=true"`
	QueueSeq              *int64     `sqlx:"queue_seq" json:"queueSeq,omitempty"`
	Status                string     `validate:"required" json:"status" sqlx:"status,required=true"`
	CreatedAt             *time.Time `sqlx:"created_at,required=true" json:"createdAt,omitempty"`
	Origin                *string    `sqlx:"origin" json:"origin,omitempty"`
	GoalId                *string    `sqlx:"goal_id" json:"goalId,omitempty"`
	StatusReason          *string    `sqlx:"status_reason" json:"statusReason,omitempty"`
	ErrorMessage          *string    `sqlx:"error_message" json:"errorMessage,omitempty"`
	StartedByMessageId    *string    `sqlx:"started_by_message_id" json:"startedByMessageId,omitempty"`
	RetryOf               *string    `sqlx:"retry_of" json:"retryOf,omitempty"`
	AgentIdUsed           *string    `sqlx:"agent_id_used" json:"agentIdUsed,omitempty"`
	AgentConfigUsedId     *string    `sqlx:"agent_config_used_id" json:"agentConfigUsedId,omitempty"`
	ModelOverrideProvider *string    `sqlx:"model_override_provider" json:"modelOverrideProvider,omitempty"`
	ModelOverride         *string    `sqlx:"model_override" json:"modelOverride,omitempty"`
	ModelParamsOverride   *string    `sqlx:"model_params_override" json:"modelParamsOverride,omitempty"`
	RunId                 *string    `sqlx:"run_id" json:"runId,omitempty"`
	Has                   *TurnHas   `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-" typeName:"TurnHas"`
}

Turn is generated canonical view metadata for writer.

func (*Turn) GetAgentConfigUsedId 

func (entity *Turn) GetAgentConfigUsedId() *string

func (*Turn) GetAgentIdUsed 

func (entity *Turn) GetAgentIdUsed() *string

func (*Turn) GetConversationId 

func (entity *Turn) GetConversationId() string

func (*Turn) GetCreatedAt 

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

func (*Turn) GetErrorMessage 

func (entity *Turn) GetErrorMessage() *string

func (*Turn) GetGoalId 

func (entity *Turn) GetGoalId() *string

func (*Turn) GetId 

func (entity *Turn) GetId() string

func (*Turn) GetModelOverride 

func (entity *Turn) GetModelOverride() *string

func (*Turn) GetModelOverrideProvider 

func (entity *Turn) GetModelOverrideProvider() *string

func (*Turn) GetModelParamsOverride 

func (entity *Turn) GetModelParamsOverride() *string

func (*Turn) GetOrigin 

func (entity *Turn) GetOrigin() *string

func (*Turn) GetQueueSeq 

func (entity *Turn) GetQueueSeq() *int64

func (*Turn) GetRetryOf 

func (entity *Turn) GetRetryOf() *string

func (*Turn) GetRunId 

func (entity *Turn) GetRunId() *string

func (*Turn) GetShouldDelete 

func (entity *Turn) GetShouldDelete() bool

func (*Turn) GetStartedByMessageId 

func (entity *Turn) GetStartedByMessageId() *string

func (*Turn) GetStatus 

func (entity *Turn) GetStatus() string

func (*Turn) GetStatusReason 

func (entity *Turn) GetStatusReason() *string

func (*Turn) SetAgentConfigUsedId 

func (entity *Turn) SetAgentConfigUsedId(value *string)

func (*Turn) SetAgentIdUsed 

func (entity *Turn) SetAgentIdUsed(value *string)

func (*Turn) SetConversationId 

func (entity *Turn) SetConversationId(value string)

func (*Turn) SetCreatedAt 

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

func (*Turn) SetErrorMessage 

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

func (*Turn) SetGoalId 

func (entity *Turn) SetGoalId(value *string)

func (*Turn) SetId 

func (entity *Turn) SetId(value string)

func (*Turn) SetModelOverride 

func (entity *Turn) SetModelOverride(value *string)

func (*Turn) SetModelOverrideProvider 

func (entity *Turn) SetModelOverrideProvider(value *string)

func (*Turn) SetModelParamsOverride 

func (entity *Turn) SetModelParamsOverride(value *string)

func (*Turn) SetOrigin 

func (entity *Turn) SetOrigin(value *string)

func (*Turn) SetQueueSeq 

func (entity *Turn) SetQueueSeq(value *int64)

func (*Turn) SetRetryOf 

func (entity *Turn) SetRetryOf(value *string)

func (*Turn) SetRunId 

func (entity *Turn) SetRunId(value *string)

func (*Turn) SetShouldDelete 

func (entity *Turn) SetShouldDelete(value bool)

func (*Turn) SetStartedByMessageId 

func (entity *Turn) SetStartedByMessageId(value *string)

func (*Turn) SetStatus 

func (entity *Turn) SetStatus(value string)

func (*Turn) SetStatusReason 

func (entity *Turn) SetStatusReason(value *string)

type TurnHas 

type TurnHas struct {
	ShouldDelete          bool
	Id                    bool
	ConversationId        bool
	QueueSeq              bool
	Status                bool
	CreatedAt             bool
	Origin                bool
	GoalId                bool
	StatusReason          bool
	ErrorMessage          bool
	StartedByMessageId    bool
	RetryOf               bool
	AgentIdUsed           bool
	AgentConfigUsedId     bool
	ModelOverrideProvider bool
	ModelOverride         bool
	ModelParamsOverride   bool
	RunId                 bool
}

type WriterComponent 

type WriterComponent struct {
	Contract xdatly.Component[Input, Output] "" /* 161-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 WriterHandlerCurrentWriterGroupedByAgentConfigUsedId 

type WriterHandlerCurrentWriterGroupedByAgentConfigUsedId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByAgentConfigUsedId) Has 

func (index WriterHandlerCurrentWriterGroupedByAgentConfigUsedId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByAgentIdUsed 

type WriterHandlerCurrentWriterGroupedByAgentIdUsed map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByAgentIdUsed) Has 

func (index WriterHandlerCurrentWriterGroupedByAgentIdUsed) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByConversationId 

type WriterHandlerCurrentWriterGroupedByConversationId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByConversationId) Has 

func (index WriterHandlerCurrentWriterGroupedByConversationId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByCreatedAt 

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

func (WriterHandlerCurrentWriterGroupedByCreatedAt) Has 

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

type WriterHandlerCurrentWriterGroupedByErrorMessage 

type WriterHandlerCurrentWriterGroupedByErrorMessage map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByErrorMessage) Has 

func (index WriterHandlerCurrentWriterGroupedByErrorMessage) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByGoalId 

type WriterHandlerCurrentWriterGroupedByGoalId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByGoalId) Has 

func (index WriterHandlerCurrentWriterGroupedByGoalId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedById 

type WriterHandlerCurrentWriterGroupedById map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedById) Has 

func (index WriterHandlerCurrentWriterGroupedById) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByModelOverride 

type WriterHandlerCurrentWriterGroupedByModelOverride map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByModelOverride) Has 

func (index WriterHandlerCurrentWriterGroupedByModelOverride) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByModelOverrideProvider 

type WriterHandlerCurrentWriterGroupedByModelOverrideProvider map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByModelOverrideProvider) Has 

func (index WriterHandlerCurrentWriterGroupedByModelOverrideProvider) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByModelParamsOverride 

type WriterHandlerCurrentWriterGroupedByModelParamsOverride map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByModelParamsOverride) Has 

func (index WriterHandlerCurrentWriterGroupedByModelParamsOverride) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByOrigin 

type WriterHandlerCurrentWriterGroupedByOrigin map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByOrigin) Has 

func (index WriterHandlerCurrentWriterGroupedByOrigin) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByQueueSeq 

type WriterHandlerCurrentWriterGroupedByQueueSeq map[int64][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByQueueSeq) Has 

func (index WriterHandlerCurrentWriterGroupedByQueueSeq) Has(key int64) bool

type WriterHandlerCurrentWriterGroupedByRetryOf 

type WriterHandlerCurrentWriterGroupedByRetryOf map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByRetryOf) Has 

func (index WriterHandlerCurrentWriterGroupedByRetryOf) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByRunId 

type WriterHandlerCurrentWriterGroupedByRunId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByRunId) Has 

func (index WriterHandlerCurrentWriterGroupedByRunId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByStartedByMessageId 

type WriterHandlerCurrentWriterGroupedByStartedByMessageId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByStartedByMessageId) Has 

func (index WriterHandlerCurrentWriterGroupedByStartedByMessageId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByStatus 

type WriterHandlerCurrentWriterGroupedByStatus map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByStatus) Has 

func (index WriterHandlerCurrentWriterGroupedByStatus) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByStatusReason 

type WriterHandlerCurrentWriterGroupedByStatusReason map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByStatusReason) Has 

func (index WriterHandlerCurrentWriterGroupedByStatusReason) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByAgentConfigUsedId 

type WriterHandlerCurrentWriterIndexedByAgentConfigUsedId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByAgentConfigUsedId) Has 

func (index WriterHandlerCurrentWriterIndexedByAgentConfigUsedId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByAgentIdUsed 

type WriterHandlerCurrentWriterIndexedByAgentIdUsed map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByAgentIdUsed) Has 

func (index WriterHandlerCurrentWriterIndexedByAgentIdUsed) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByConversationId 

type WriterHandlerCurrentWriterIndexedByConversationId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByConversationId) Has 

func (index WriterHandlerCurrentWriterIndexedByConversationId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByCreatedAt 

type WriterHandlerCurrentWriterIndexedByCreatedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCreatedAt) Has 

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

type WriterHandlerCurrentWriterIndexedByErrorMessage 

type WriterHandlerCurrentWriterIndexedByErrorMessage map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByErrorMessage) Has 

func (index WriterHandlerCurrentWriterIndexedByErrorMessage) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByGoalId 

type WriterHandlerCurrentWriterIndexedByGoalId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByGoalId) Has 

func (index WriterHandlerCurrentWriterIndexedByGoalId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedById 

type WriterHandlerCurrentWriterIndexedById map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedById) Has 

func (index WriterHandlerCurrentWriterIndexedById) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByModelOverride 

type WriterHandlerCurrentWriterIndexedByModelOverride map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByModelOverride) Has 

func (index WriterHandlerCurrentWriterIndexedByModelOverride) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByModelOverrideProvider 

type WriterHandlerCurrentWriterIndexedByModelOverrideProvider map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByModelOverrideProvider) Has 

func (index WriterHandlerCurrentWriterIndexedByModelOverrideProvider) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByModelParamsOverride 

type WriterHandlerCurrentWriterIndexedByModelParamsOverride map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByModelParamsOverride) Has 

func (index WriterHandlerCurrentWriterIndexedByModelParamsOverride) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByOrigin 

type WriterHandlerCurrentWriterIndexedByOrigin map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByOrigin) Has 

func (index WriterHandlerCurrentWriterIndexedByOrigin) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByQueueSeq 

type WriterHandlerCurrentWriterIndexedByQueueSeq map[int64]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByQueueSeq) Has 

func (index WriterHandlerCurrentWriterIndexedByQueueSeq) Has(key int64) bool

type WriterHandlerCurrentWriterIndexedByRetryOf 

type WriterHandlerCurrentWriterIndexedByRetryOf map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByRetryOf) Has 

func (index WriterHandlerCurrentWriterIndexedByRetryOf) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByRunId 

type WriterHandlerCurrentWriterIndexedByRunId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByRunId) Has 

func (index WriterHandlerCurrentWriterIndexedByRunId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByStartedByMessageId 

type WriterHandlerCurrentWriterIndexedByStartedByMessageId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByStartedByMessageId) Has 

func (index WriterHandlerCurrentWriterIndexedByStartedByMessageId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByStatus 

type WriterHandlerCurrentWriterIndexedByStatus map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByStatus) Has 

func (index WriterHandlerCurrentWriterIndexedByStatus) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByStatusReason 

type WriterHandlerCurrentWriterIndexedByStatusReason map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByStatusReason) Has 

func (index WriterHandlerCurrentWriterIndexedByStatusReason) Has(key string) bool

type WriterHandlerCurrentWriterSlice 

type WriterHandlerCurrentWriterSlice []*CurrentWriterView

func (WriterHandlerCurrentWriterSlice) GroupByAgentConfigUsedId 

func (rows WriterHandlerCurrentWriterSlice) GroupByAgentConfigUsedId() WriterHandlerCurrentWriterGroupedByAgentConfigUsedId

func (WriterHandlerCurrentWriterSlice) GroupByAgentIdUsed 

func (rows WriterHandlerCurrentWriterSlice) GroupByAgentIdUsed() WriterHandlerCurrentWriterGroupedByAgentIdUsed

func (WriterHandlerCurrentWriterSlice) GroupByConversationId 

func (rows WriterHandlerCurrentWriterSlice) GroupByConversationId() WriterHandlerCurrentWriterGroupedByConversationId

func (WriterHandlerCurrentWriterSlice) GroupByCreatedAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByCreatedAt() WriterHandlerCurrentWriterGroupedByCreatedAt

func (WriterHandlerCurrentWriterSlice) GroupByErrorMessage 

func (rows WriterHandlerCurrentWriterSlice) GroupByErrorMessage() WriterHandlerCurrentWriterGroupedByErrorMessage

func (WriterHandlerCurrentWriterSlice) GroupByGoalId 

func (rows WriterHandlerCurrentWriterSlice) GroupByGoalId() WriterHandlerCurrentWriterGroupedByGoalId

func (WriterHandlerCurrentWriterSlice) GroupById 

func (rows WriterHandlerCurrentWriterSlice) GroupById() WriterHandlerCurrentWriterGroupedById

func (WriterHandlerCurrentWriterSlice) GroupByModelOverride 

func (rows WriterHandlerCurrentWriterSlice) GroupByModelOverride() WriterHandlerCurrentWriterGroupedByModelOverride

func (WriterHandlerCurrentWriterSlice) GroupByModelOverrideProvider 

func (rows WriterHandlerCurrentWriterSlice) GroupByModelOverrideProvider() WriterHandlerCurrentWriterGroupedByModelOverrideProvider

func (WriterHandlerCurrentWriterSlice) GroupByModelParamsOverride 

func (rows WriterHandlerCurrentWriterSlice) GroupByModelParamsOverride() WriterHandlerCurrentWriterGroupedByModelParamsOverride

func (WriterHandlerCurrentWriterSlice) GroupByOrigin 

func (rows WriterHandlerCurrentWriterSlice) GroupByOrigin() WriterHandlerCurrentWriterGroupedByOrigin

func (WriterHandlerCurrentWriterSlice) GroupByQueueSeq 

func (rows WriterHandlerCurrentWriterSlice) GroupByQueueSeq() WriterHandlerCurrentWriterGroupedByQueueSeq

func (WriterHandlerCurrentWriterSlice) GroupByRetryOf 

func (rows WriterHandlerCurrentWriterSlice) GroupByRetryOf() WriterHandlerCurrentWriterGroupedByRetryOf

func (WriterHandlerCurrentWriterSlice) GroupByRunId 

func (rows WriterHandlerCurrentWriterSlice) GroupByRunId() WriterHandlerCurrentWriterGroupedByRunId

func (WriterHandlerCurrentWriterSlice) GroupByStartedByMessageId 

func (rows WriterHandlerCurrentWriterSlice) GroupByStartedByMessageId() WriterHandlerCurrentWriterGroupedByStartedByMessageId

func (WriterHandlerCurrentWriterSlice) GroupByStatus 

func (rows WriterHandlerCurrentWriterSlice) GroupByStatus() WriterHandlerCurrentWriterGroupedByStatus

func (WriterHandlerCurrentWriterSlice) GroupByStatusReason 

func (rows WriterHandlerCurrentWriterSlice) GroupByStatusReason() WriterHandlerCurrentWriterGroupedByStatusReason

func (WriterHandlerCurrentWriterSlice) IndexByAgentConfigUsedId 

func (rows WriterHandlerCurrentWriterSlice) IndexByAgentConfigUsedId() (WriterHandlerCurrentWriterIndexedByAgentConfigUsedId, error)

func (WriterHandlerCurrentWriterSlice) IndexByAgentIdUsed 

func (rows WriterHandlerCurrentWriterSlice) IndexByAgentIdUsed() (WriterHandlerCurrentWriterIndexedByAgentIdUsed, error)

func (WriterHandlerCurrentWriterSlice) IndexByConversationId 

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

func (WriterHandlerCurrentWriterSlice) IndexByCreatedAt 

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

func (WriterHandlerCurrentWriterSlice) IndexByErrorMessage 

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

func (WriterHandlerCurrentWriterSlice) IndexByGoalId 

func (rows WriterHandlerCurrentWriterSlice) IndexByGoalId() (WriterHandlerCurrentWriterIndexedByGoalId, error)

func (WriterHandlerCurrentWriterSlice) IndexById 

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

func (WriterHandlerCurrentWriterSlice) IndexByModelOverride 

func (rows WriterHandlerCurrentWriterSlice) IndexByModelOverride() (WriterHandlerCurrentWriterIndexedByModelOverride, error)

func (WriterHandlerCurrentWriterSlice) IndexByModelOverrideProvider 

func (rows WriterHandlerCurrentWriterSlice) IndexByModelOverrideProvider() (WriterHandlerCurrentWriterIndexedByModelOverrideProvider, error)

func (WriterHandlerCurrentWriterSlice) IndexByModelParamsOverride 

func (rows WriterHandlerCurrentWriterSlice) IndexByModelParamsOverride() (WriterHandlerCurrentWriterIndexedByModelParamsOverride, error)

func (WriterHandlerCurrentWriterSlice) IndexByOrigin 

func (rows WriterHandlerCurrentWriterSlice) IndexByOrigin() (WriterHandlerCurrentWriterIndexedByOrigin, error)

func (WriterHandlerCurrentWriterSlice) IndexByQueueSeq 

func (rows WriterHandlerCurrentWriterSlice) IndexByQueueSeq() (WriterHandlerCurrentWriterIndexedByQueueSeq, error)

func (WriterHandlerCurrentWriterSlice) IndexByRetryOf 

func (rows WriterHandlerCurrentWriterSlice) IndexByRetryOf() (WriterHandlerCurrentWriterIndexedByRetryOf, error)

func (WriterHandlerCurrentWriterSlice) IndexByRunId 

func (rows WriterHandlerCurrentWriterSlice) IndexByRunId() (WriterHandlerCurrentWriterIndexedByRunId, error)

func (WriterHandlerCurrentWriterSlice) IndexByStartedByMessageId 

func (rows WriterHandlerCurrentWriterSlice) IndexByStartedByMessageId() (WriterHandlerCurrentWriterIndexedByStartedByMessageId, error)

func (WriterHandlerCurrentWriterSlice) IndexByStatus 

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

func (WriterHandlerCurrentWriterSlice) IndexByStatusReason 

func (rows WriterHandlerCurrentWriterSlice) IndexByStatusReason() (WriterHandlerCurrentWriterIndexedByStatusReason, 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.