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: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const WriterDatlyResourceNamespace = "datly_toolapprovalqueue_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 WriterHandlerCurrentWriterIndexByApprovedAtKey 

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

func WriterHandlerCurrentWriterIndexByApprovedByUserIdKey 

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

func WriterHandlerCurrentWriterIndexByCompletedAtKey 

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

func WriterHandlerCurrentWriterIndexByConversationIdKey 

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

func WriterHandlerCurrentWriterIndexByCreatedAtKey 

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

func WriterHandlerCurrentWriterIndexByDecisionKey 

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

func WriterHandlerCurrentWriterIndexByErrorMessageKey 

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

func WriterHandlerCurrentWriterIndexByExecutedAtKey 

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

func WriterHandlerCurrentWriterIndexByExpiresAtKey 

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

func WriterHandlerCurrentWriterIndexByIdKey 

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

func WriterHandlerCurrentWriterIndexByMessageIdKey 

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

func WriterHandlerCurrentWriterIndexByStatusKey 

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

func WriterHandlerCurrentWriterIndexByTimedOutAtKey 

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

func WriterHandlerCurrentWriterIndexByTitleKey 

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

func WriterHandlerCurrentWriterIndexByToolNameKey 

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

func WriterHandlerCurrentWriterIndexByTurnIdKey 

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

func WriterHandlerCurrentWriterIndexByUpdatedAtKey 

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

func WriterHandlerCurrentWriterIndexByUserIdKey 

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

Types

type CurrentWriterView 

type CurrentWriterView struct {
	Id               string     `validate:"required" sqlx:"id,primaryKey" json:"id"`
	UserId           string     `validate:"required" json:"userId" sqlx:"user_id,required=true"`
	ToolName         string     `validate:"required" json:"toolName" sqlx:"tool_name,required=true"`
	Arguments        []byte     `validate:"required" json:"arguments" sqlx:"arguments,required=true"`
	Metadata         *[]byte    `sqlx:"metadata" json:"metadata,omitempty"`
	Status           string     `validate:"required" json:"status" sqlx:"status,required=true"`
	ConversationId   *string    `sqlx:"conversation_id,refTable=conversation,refColumn=id" json:"conversationId,omitempty"`
	TurnId           *string    `sqlx:"turn_id,refTable=turn,refColumn=id" json:"turnId,omitempty"`
	MessageId        *string    `sqlx:"message_id,refTable=message,refColumn=id" json:"messageId,omitempty"`
	Title            *string    `sqlx:"title" json:"title,omitempty"`
	Decision         *string    `sqlx:"decision" json:"decision,omitempty"`
	ExpiresAt        *time.Time `sqlx:"expires_at" json:"expiresAt,omitempty"`
	TimedOutAt       *time.Time `sqlx:"timed_out_at" json:"timedOutAt,omitempty"`
	ApprovedByUserId *string    `sqlx:"approved_by_user_id" json:"approvedByUserId,omitempty"`
	ApprovedAt       *time.Time `sqlx:"approved_at" json:"approvedAt,omitempty"`
	ExecutedAt       *time.Time `sqlx:"executed_at" json:"executedAt,omitempty"`
	ErrorMessage     *string    `sqlx:"error_message" json:"errorMessage,omitempty"`
	CreatedAt        *time.Time `sqlx:"created_at,required=true" json:"createdAt,omitempty"`
	UpdatedAt        *time.Time `sqlx:"updated_at" json:"updatedAt,omitempty"`
	CompletedAt      *time.Time `sqlx:"completed_at" json:"completedAt,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"`
	Queues        []*ToolApprovalQueue `` /* 237-byte string literal not displayed */
	WriterKeys    []WriterKeysRow      `` /* 140-byte string literal not displayed */
	CurrentWriter []*CurrentWriterView `` /* 186-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) 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) SetQueues 

func (input *Input) SetQueues(value []*ToolApprovalQueue)

func (*Input) SetWriterKeys 

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

type InputHas 

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

type Lifecycle 

type Lifecycle struct {
	Input *Input `bind:"kind=input"`
	// contains filtered or unexported fields
}

Lifecycle customizes role Input.Queues.

func (*Lifecycle) AfterQueue 

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

func (*Lifecycle) AfterSequence 

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

func (*Lifecycle) Validate 

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

type Output 

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

Output is the generated output scaffold for writer.

type ToolApprovalQueue 

type ToolApprovalQueue struct {
	ShouldDelete     bool                  `sqlx:"-" writer:"delete" json:"shouldDelete,omitempty"`
	Id               string                `validate:"required" sqlx:"id,primaryKey" json:"id"`
	UserId           string                `validate:"required" json:"userId" sqlx:"user_id,required=true"`
	ToolName         string                `validate:"required" json:"toolName" sqlx:"tool_name,required=true"`
	Arguments        []byte                `validate:"required" json:"arguments" sqlx:"arguments,required=true"`
	Metadata         *[]byte               `sqlx:"metadata" json:"metadata,omitempty"`
	Status           string                `validate:"required" json:"status" sqlx:"status,required=true"`
	ConversationId   *string               `sqlx:"conversation_id,refTable=conversation,refColumn=id" json:"conversationId,omitempty"`
	TurnId           *string               `sqlx:"turn_id,refTable=turn,refColumn=id" json:"turnId,omitempty"`
	MessageId        *string               `sqlx:"message_id,refTable=message,refColumn=id" json:"messageId,omitempty"`
	Title            *string               `sqlx:"title" json:"title,omitempty"`
	Decision         *string               `sqlx:"decision" json:"decision,omitempty"`
	ExpiresAt        *time.Time            `sqlx:"expires_at" json:"expiresAt,omitempty"`
	TimedOutAt       *time.Time            `sqlx:"timed_out_at" json:"timedOutAt,omitempty"`
	ApprovedByUserId *string               `sqlx:"approved_by_user_id" json:"approvedByUserId,omitempty"`
	ApprovedAt       *time.Time            `sqlx:"approved_at" json:"approvedAt,omitempty"`
	ExecutedAt       *time.Time            `sqlx:"executed_at" json:"executedAt,omitempty"`
	ErrorMessage     *string               `sqlx:"error_message" json:"errorMessage,omitempty"`
	CreatedAt        *time.Time            `sqlx:"created_at,required=true" json:"createdAt,omitempty"`
	UpdatedAt        *time.Time            `sqlx:"updated_at" json:"updatedAt,omitempty"`
	CompletedAt      *time.Time            `sqlx:"completed_at" json:"completedAt,omitempty"`
	Has              *ToolApprovalQueueHas `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-" typeName:"ToolApprovalQueueHas"`
}

ToolApprovalQueue is generated canonical view metadata for writer.

func (*ToolApprovalQueue) GetApprovedAt 

func (entity *ToolApprovalQueue) GetApprovedAt() *time.Time

func (*ToolApprovalQueue) GetApprovedByUserId 

func (entity *ToolApprovalQueue) GetApprovedByUserId() *string

func (*ToolApprovalQueue) GetArguments 

func (entity *ToolApprovalQueue) GetArguments() []byte

func (*ToolApprovalQueue) GetCompletedAt 

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

func (*ToolApprovalQueue) GetConversationId 

func (entity *ToolApprovalQueue) GetConversationId() *string

func (*ToolApprovalQueue) GetCreatedAt 

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

func (*ToolApprovalQueue) GetDecision 

func (entity *ToolApprovalQueue) GetDecision() *string

func (*ToolApprovalQueue) GetErrorMessage 

func (entity *ToolApprovalQueue) GetErrorMessage() *string

func (*ToolApprovalQueue) GetExecutedAt 

func (entity *ToolApprovalQueue) GetExecutedAt() *time.Time

func (*ToolApprovalQueue) GetExpiresAt 

func (entity *ToolApprovalQueue) GetExpiresAt() *time.Time

func (*ToolApprovalQueue) GetId 

func (entity *ToolApprovalQueue) GetId() string

func (*ToolApprovalQueue) GetMessageId 

func (entity *ToolApprovalQueue) GetMessageId() *string

func (*ToolApprovalQueue) GetMetadata 

func (entity *ToolApprovalQueue) GetMetadata() *[]byte

func (*ToolApprovalQueue) GetShouldDelete 

func (entity *ToolApprovalQueue) GetShouldDelete() bool

func (*ToolApprovalQueue) GetStatus 

func (entity *ToolApprovalQueue) GetStatus() string

func (*ToolApprovalQueue) GetTimedOutAt 

func (entity *ToolApprovalQueue) GetTimedOutAt() *time.Time

func (*ToolApprovalQueue) GetTitle 

func (entity *ToolApprovalQueue) GetTitle() *string

func (*ToolApprovalQueue) GetToolName 

func (entity *ToolApprovalQueue) GetToolName() string

func (*ToolApprovalQueue) GetTurnId 

func (entity *ToolApprovalQueue) GetTurnId() *string

func (*ToolApprovalQueue) GetUpdatedAt 

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

func (*ToolApprovalQueue) GetUserId 

func (entity *ToolApprovalQueue) GetUserId() string

func (*ToolApprovalQueue) SetApprovedAt 

func (entity *ToolApprovalQueue) SetApprovedAt(value *time.Time)

func (*ToolApprovalQueue) SetApprovedByUserId 

func (entity *ToolApprovalQueue) SetApprovedByUserId(value *string)

func (*ToolApprovalQueue) SetArguments 

func (entity *ToolApprovalQueue) SetArguments(value []byte)

func (*ToolApprovalQueue) SetCompletedAt 

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

func (*ToolApprovalQueue) SetConversationId 

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

func (*ToolApprovalQueue) SetCreatedAt 

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

func (*ToolApprovalQueue) SetDecision 

func (entity *ToolApprovalQueue) SetDecision(value *string)

func (*ToolApprovalQueue) SetErrorMessage 

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

func (*ToolApprovalQueue) SetExecutedAt 

func (entity *ToolApprovalQueue) SetExecutedAt(value *time.Time)

func (*ToolApprovalQueue) SetExpiresAt 

func (entity *ToolApprovalQueue) SetExpiresAt(value *time.Time)

func (*ToolApprovalQueue) SetId 

func (entity *ToolApprovalQueue) SetId(value string)

func (*ToolApprovalQueue) SetMessageId 

func (entity *ToolApprovalQueue) SetMessageId(value *string)

func (*ToolApprovalQueue) SetMetadata 

func (entity *ToolApprovalQueue) SetMetadata(value *[]byte)

func (*ToolApprovalQueue) SetShouldDelete 

func (entity *ToolApprovalQueue) SetShouldDelete(value bool)

func (*ToolApprovalQueue) SetStatus 

func (entity *ToolApprovalQueue) SetStatus(value string)

func (*ToolApprovalQueue) SetTimedOutAt 

func (entity *ToolApprovalQueue) SetTimedOutAt(value *time.Time)

func (*ToolApprovalQueue) SetTitle 

func (entity *ToolApprovalQueue) SetTitle(value *string)

func (*ToolApprovalQueue) SetToolName 

func (entity *ToolApprovalQueue) SetToolName(value string)

func (*ToolApprovalQueue) SetTurnId 

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

func (*ToolApprovalQueue) SetUpdatedAt 

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

func (*ToolApprovalQueue) SetUserId 

func (entity *ToolApprovalQueue) SetUserId(value string)

type ToolApprovalQueueHas 

type ToolApprovalQueueHas struct {
	ShouldDelete     bool
	Id               bool
	UserId           bool
	ToolName         bool
	Arguments        bool
	Metadata         bool
	Status           bool
	ConversationId   bool
	TurnId           bool
	MessageId        bool
	Title            bool
	Decision         bool
	ExpiresAt        bool
	TimedOutAt       bool
	ApprovedByUserId bool
	ApprovedAt       bool
	ExecutedAt       bool
	ErrorMessage     bool
	CreatedAt        bool
	UpdatedAt        bool
	CompletedAt      bool
}

type WriterComponent 

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

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

func (WriterHandlerCurrentWriterGroupedByApprovedAt) Has 

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

type WriterHandlerCurrentWriterGroupedByApprovedByUserId 

type WriterHandlerCurrentWriterGroupedByApprovedByUserId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByApprovedByUserId) Has 

func (index WriterHandlerCurrentWriterGroupedByApprovedByUserId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByCompletedAt 

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

func (WriterHandlerCurrentWriterGroupedByCompletedAt) Has 

func (index WriterHandlerCurrentWriterGroupedByCompletedAt) Has(key time.Time) 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 WriterHandlerCurrentWriterGroupedByDecision 

type WriterHandlerCurrentWriterGroupedByDecision map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByDecision) Has 

func (index WriterHandlerCurrentWriterGroupedByDecision) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByErrorMessage 

type WriterHandlerCurrentWriterGroupedByErrorMessage map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByErrorMessage) Has 

func (index WriterHandlerCurrentWriterGroupedByErrorMessage) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByExecutedAt 

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

func (WriterHandlerCurrentWriterGroupedByExecutedAt) Has 

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

type WriterHandlerCurrentWriterGroupedByExpiresAt 

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

func (WriterHandlerCurrentWriterGroupedByExpiresAt) Has 

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

type WriterHandlerCurrentWriterGroupedById 

type WriterHandlerCurrentWriterGroupedById map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedById) Has 

func (index WriterHandlerCurrentWriterGroupedById) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByMessageId 

type WriterHandlerCurrentWriterGroupedByMessageId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByMessageId) Has 

func (index WriterHandlerCurrentWriterGroupedByMessageId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByStatus 

type WriterHandlerCurrentWriterGroupedByStatus map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByStatus) Has 

func (index WriterHandlerCurrentWriterGroupedByStatus) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByTimedOutAt 

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

func (WriterHandlerCurrentWriterGroupedByTimedOutAt) Has 

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

type WriterHandlerCurrentWriterGroupedByTitle 

type WriterHandlerCurrentWriterGroupedByTitle map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByTitle) Has 

func (index WriterHandlerCurrentWriterGroupedByTitle) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByToolName 

type WriterHandlerCurrentWriterGroupedByToolName map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByToolName) Has 

func (index WriterHandlerCurrentWriterGroupedByToolName) 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 WriterHandlerCurrentWriterGroupedByUserId 

type WriterHandlerCurrentWriterGroupedByUserId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByUserId) Has 

func (index WriterHandlerCurrentWriterGroupedByUserId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByApprovedAt 

type WriterHandlerCurrentWriterIndexedByApprovedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByApprovedAt) Has 

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

type WriterHandlerCurrentWriterIndexedByApprovedByUserId 

type WriterHandlerCurrentWriterIndexedByApprovedByUserId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByApprovedByUserId) Has 

func (index WriterHandlerCurrentWriterIndexedByApprovedByUserId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByCompletedAt 

type WriterHandlerCurrentWriterIndexedByCompletedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCompletedAt) Has 

func (index WriterHandlerCurrentWriterIndexedByCompletedAt) Has(key time.Time) 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 WriterHandlerCurrentWriterIndexedByDecision 

type WriterHandlerCurrentWriterIndexedByDecision map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByDecision) Has 

func (index WriterHandlerCurrentWriterIndexedByDecision) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByErrorMessage 

type WriterHandlerCurrentWriterIndexedByErrorMessage map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByErrorMessage) Has 

func (index WriterHandlerCurrentWriterIndexedByErrorMessage) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByExecutedAt 

type WriterHandlerCurrentWriterIndexedByExecutedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByExecutedAt) Has 

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

type WriterHandlerCurrentWriterIndexedByExpiresAt 

type WriterHandlerCurrentWriterIndexedByExpiresAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByExpiresAt) Has 

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

type WriterHandlerCurrentWriterIndexedById 

type WriterHandlerCurrentWriterIndexedById map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedById) Has 

func (index WriterHandlerCurrentWriterIndexedById) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByMessageId 

type WriterHandlerCurrentWriterIndexedByMessageId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByMessageId) Has 

func (index WriterHandlerCurrentWriterIndexedByMessageId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByStatus 

type WriterHandlerCurrentWriterIndexedByStatus map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByStatus) Has 

func (index WriterHandlerCurrentWriterIndexedByStatus) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByTimedOutAt 

type WriterHandlerCurrentWriterIndexedByTimedOutAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByTimedOutAt) Has 

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

type WriterHandlerCurrentWriterIndexedByTitle 

type WriterHandlerCurrentWriterIndexedByTitle map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByTitle) Has 

func (index WriterHandlerCurrentWriterIndexedByTitle) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByToolName 

type WriterHandlerCurrentWriterIndexedByToolName map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByToolName) Has 

func (index WriterHandlerCurrentWriterIndexedByToolName) 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 WriterHandlerCurrentWriterIndexedByUserId 

type WriterHandlerCurrentWriterIndexedByUserId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByUserId) Has 

func (index WriterHandlerCurrentWriterIndexedByUserId) Has(key string) bool

type WriterHandlerCurrentWriterSlice 

type WriterHandlerCurrentWriterSlice []*CurrentWriterView

func (WriterHandlerCurrentWriterSlice) GroupByApprovedAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByApprovedAt() WriterHandlerCurrentWriterGroupedByApprovedAt

func (WriterHandlerCurrentWriterSlice) GroupByApprovedByUserId 

func (rows WriterHandlerCurrentWriterSlice) GroupByApprovedByUserId() WriterHandlerCurrentWriterGroupedByApprovedByUserId

func (WriterHandlerCurrentWriterSlice) GroupByCompletedAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByCompletedAt() WriterHandlerCurrentWriterGroupedByCompletedAt

func (WriterHandlerCurrentWriterSlice) GroupByConversationId 

func (rows WriterHandlerCurrentWriterSlice) GroupByConversationId() WriterHandlerCurrentWriterGroupedByConversationId

func (WriterHandlerCurrentWriterSlice) GroupByCreatedAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByCreatedAt() WriterHandlerCurrentWriterGroupedByCreatedAt

func (WriterHandlerCurrentWriterSlice) GroupByDecision 

func (rows WriterHandlerCurrentWriterSlice) GroupByDecision() WriterHandlerCurrentWriterGroupedByDecision

func (WriterHandlerCurrentWriterSlice) GroupByErrorMessage 

func (rows WriterHandlerCurrentWriterSlice) GroupByErrorMessage() WriterHandlerCurrentWriterGroupedByErrorMessage

func (WriterHandlerCurrentWriterSlice) GroupByExecutedAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByExecutedAt() WriterHandlerCurrentWriterGroupedByExecutedAt

func (WriterHandlerCurrentWriterSlice) GroupByExpiresAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByExpiresAt() WriterHandlerCurrentWriterGroupedByExpiresAt

func (WriterHandlerCurrentWriterSlice) GroupById 

func (rows WriterHandlerCurrentWriterSlice) GroupById() WriterHandlerCurrentWriterGroupedById

func (WriterHandlerCurrentWriterSlice) GroupByMessageId 

func (rows WriterHandlerCurrentWriterSlice) GroupByMessageId() WriterHandlerCurrentWriterGroupedByMessageId

func (WriterHandlerCurrentWriterSlice) GroupByStatus 

func (rows WriterHandlerCurrentWriterSlice) GroupByStatus() WriterHandlerCurrentWriterGroupedByStatus

func (WriterHandlerCurrentWriterSlice) GroupByTimedOutAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByTimedOutAt() WriterHandlerCurrentWriterGroupedByTimedOutAt

func (WriterHandlerCurrentWriterSlice) GroupByTitle 

func (rows WriterHandlerCurrentWriterSlice) GroupByTitle() WriterHandlerCurrentWriterGroupedByTitle

func (WriterHandlerCurrentWriterSlice) GroupByToolName 

func (rows WriterHandlerCurrentWriterSlice) GroupByToolName() WriterHandlerCurrentWriterGroupedByToolName

func (WriterHandlerCurrentWriterSlice) GroupByTurnId 

func (rows WriterHandlerCurrentWriterSlice) GroupByTurnId() WriterHandlerCurrentWriterGroupedByTurnId

func (WriterHandlerCurrentWriterSlice) GroupByUpdatedAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByUpdatedAt() WriterHandlerCurrentWriterGroupedByUpdatedAt

func (WriterHandlerCurrentWriterSlice) GroupByUserId 

func (rows WriterHandlerCurrentWriterSlice) GroupByUserId() WriterHandlerCurrentWriterGroupedByUserId

func (WriterHandlerCurrentWriterSlice) IndexByApprovedAt 

func (rows WriterHandlerCurrentWriterSlice) IndexByApprovedAt() (WriterHandlerCurrentWriterIndexedByApprovedAt, error)

func (WriterHandlerCurrentWriterSlice) IndexByApprovedByUserId 

func (rows WriterHandlerCurrentWriterSlice) IndexByApprovedByUserId() (WriterHandlerCurrentWriterIndexedByApprovedByUserId, error)

func (WriterHandlerCurrentWriterSlice) IndexByCompletedAt 

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

func (WriterHandlerCurrentWriterSlice) IndexByConversationId 

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

func (WriterHandlerCurrentWriterSlice) IndexByCreatedAt 

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

func (WriterHandlerCurrentWriterSlice) IndexByDecision 

func (rows WriterHandlerCurrentWriterSlice) IndexByDecision() (WriterHandlerCurrentWriterIndexedByDecision, error)

func (WriterHandlerCurrentWriterSlice) IndexByErrorMessage 

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

func (WriterHandlerCurrentWriterSlice) IndexByExecutedAt 

func (rows WriterHandlerCurrentWriterSlice) IndexByExecutedAt() (WriterHandlerCurrentWriterIndexedByExecutedAt, error)

func (WriterHandlerCurrentWriterSlice) IndexByExpiresAt 

func (rows WriterHandlerCurrentWriterSlice) IndexByExpiresAt() (WriterHandlerCurrentWriterIndexedByExpiresAt, error)

func (WriterHandlerCurrentWriterSlice) IndexById 

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

func (WriterHandlerCurrentWriterSlice) IndexByMessageId 

func (rows WriterHandlerCurrentWriterSlice) IndexByMessageId() (WriterHandlerCurrentWriterIndexedByMessageId, error)

func (WriterHandlerCurrentWriterSlice) IndexByStatus 

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

func (WriterHandlerCurrentWriterSlice) IndexByTimedOutAt 

func (rows WriterHandlerCurrentWriterSlice) IndexByTimedOutAt() (WriterHandlerCurrentWriterIndexedByTimedOutAt, error)

func (WriterHandlerCurrentWriterSlice) IndexByTitle 

func (rows WriterHandlerCurrentWriterSlice) IndexByTitle() (WriterHandlerCurrentWriterIndexedByTitle, error)

func (WriterHandlerCurrentWriterSlice) IndexByToolName 

func (rows WriterHandlerCurrentWriterSlice) IndexByToolName() (WriterHandlerCurrentWriterIndexedByToolName, error)

func (WriterHandlerCurrentWriterSlice) IndexByTurnId 

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

func (WriterHandlerCurrentWriterSlice) IndexByUpdatedAt 

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

func (WriterHandlerCurrentWriterSlice) IndexByUserId 

func (rows WriterHandlerCurrentWriterSlice) IndexByUserId() (WriterHandlerCurrentWriterIndexedByUserId, 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.