Documentation
¶
Index ¶
- Constants
- Variables
- func LifecycleDatlyType() reflect.Type
- func WriterDatlyType() reflect.Type
- func WriterHandlerCurrentWriterIndexByAgentRefKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByConversationIdKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByCreatedAtKey(value *CurrentWriterView) (time.Time, bool)
- func WriterHandlerCurrentWriterIndexByCreatedByUserIdKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByCronExprKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByDescriptionKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByEnabledKey(value *CurrentWriterView) (bool, bool)
- func WriterHandlerCurrentWriterIndexByEndAtKey(value *CurrentWriterView) (time.Time, bool)
- func WriterHandlerCurrentWriterIndexByGoalIdKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByIdKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByInternalKey(value *CurrentWriterView) (bool, bool)
- func WriterHandlerCurrentWriterIndexByIntervalSecondsKey(value *CurrentWriterView) (int, bool)
- func WriterHandlerCurrentWriterIndexByLastErrorKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByLastRunAtKey(value *CurrentWriterView) (time.Time, bool)
- func WriterHandlerCurrentWriterIndexByLastStatusKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByLeaseOwnerKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByLeaseUntilKey(value *CurrentWriterView) (time.Time, bool)
- func WriterHandlerCurrentWriterIndexByModelOverrideKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByNameKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByNextRunAtKey(value *CurrentWriterView) (time.Time, bool)
- func WriterHandlerCurrentWriterIndexByScheduleTypeKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByStartAtKey(value *CurrentWriterView) (time.Time, bool)
- func WriterHandlerCurrentWriterIndexByTaskPromptKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByTaskPromptUriKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByTimeoutSecondsKey(value *CurrentWriterView) (int, bool)
- func WriterHandlerCurrentWriterIndexByTimezoneKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByUpdatedAtKey(value *CurrentWriterView) (time.Time, bool)
- func WriterHandlerCurrentWriterIndexByUserCredUrlKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByVisibilityKey(value *CurrentWriterView) (string, bool)
- type CurrentWriterView
- type Input
- func (input *Input) Init(ctx context.Context) error
- func (input *Input) PrepareReadIndexes(ctx context.Context) error
- func (input *Input) ReadIndexes(ctx context.Context) (*WriterHandlerReadIndexes, error)
- func (input *Input) SetCurrentWriter(value []*CurrentWriterView)
- func (input *Input) SetLeaseMode(value string)
- func (input *Input) SetLeaseNow(value time.Time)
- func (input *Input) SetLeaseOwner(value string)
- func (input *Input) SetOrphanColumn(value string)
- func (input *Input) SetOrphanDetach(value bool)
- func (input *Input) SetSchedules(value []*Schedule)
- func (input *Input) SetVisibilitySubject(value *string)
- func (input *Input) SetWriterKeys(value []WriterKeysRow)
- type InputHas
- type Lifecycle
- func (h *Lifecycle) AfterQueue(context.Context, *Schedule, ...) error
- func (h *Lifecycle) AfterSequence(context.Context, *Schedule, ...) error
- func (h *Lifecycle) Finalize(_ context.Context, input *Input, out *Output, outcome xhandler.Outcome) error
- func (h *Lifecycle) Init(ctx context.Context, rec *Schedule, ...) error
- func (h *Lifecycle) Recover(ctx context.Context, input *Input, out *Output, ...) (rhandler.Recovery, error)
- func (h *Lifecycle) Validate(context.Context, *Schedule, ...) error
- type Output
- type Schedule
- func (entity *Schedule) GetAgentRef() string
- func (entity *Schedule) GetConversationId() *string
- func (entity *Schedule) GetCreatedAt() *time.Time
- func (entity *Schedule) GetCreatedByUserId() *string
- func (entity *Schedule) GetCronExpr() *string
- func (entity *Schedule) GetDescription() *string
- func (entity *Schedule) GetEnabled() bool
- func (entity *Schedule) GetEndAt() *time.Time
- func (entity *Schedule) GetGoalId() *string
- func (entity *Schedule) GetId() string
- func (entity *Schedule) GetInternal() *bool
- func (entity *Schedule) GetIntervalSeconds() *int
- func (entity *Schedule) GetLastError() *string
- func (entity *Schedule) GetLastRunAt() *time.Time
- func (entity *Schedule) GetLastStatus() *string
- func (entity *Schedule) GetLeaseOwner() *string
- func (entity *Schedule) GetLeaseUntil() *time.Time
- func (entity *Schedule) GetModelOverride() *string
- func (entity *Schedule) GetName() string
- func (entity *Schedule) GetNextRunAt() *time.Time
- func (entity *Schedule) GetScheduleType() string
- func (entity *Schedule) GetShouldDelete() bool
- func (entity *Schedule) GetStartAt() *time.Time
- func (entity *Schedule) GetTaskPrompt() *string
- func (entity *Schedule) GetTaskPromptUri() *string
- func (entity *Schedule) GetTimeoutSeconds() int
- func (entity *Schedule) GetTimezone() string
- func (entity *Schedule) GetUpdatedAt() *time.Time
- func (entity *Schedule) GetUserCredUrl() *string
- func (entity *Schedule) GetVisibility() string
- func (entity *Schedule) SetAgentRef(value string)
- func (entity *Schedule) SetConversationId(value *string)
- func (entity *Schedule) SetCreatedAt(value *time.Time)
- func (entity *Schedule) SetCreatedByUserId(value *string)
- func (entity *Schedule) SetCronExpr(value *string)
- func (entity *Schedule) SetDescription(value *string)
- func (entity *Schedule) SetEnabled(value bool)
- func (entity *Schedule) SetEndAt(value *time.Time)
- func (entity *Schedule) SetGoalId(value *string)
- func (entity *Schedule) SetId(value string)
- func (entity *Schedule) SetInternal(value *bool)
- func (entity *Schedule) SetIntervalSeconds(value *int)
- func (entity *Schedule) SetLastError(value *string)
- func (entity *Schedule) SetLastRunAt(value *time.Time)
- func (entity *Schedule) SetLastStatus(value *string)
- func (entity *Schedule) SetLeaseOwner(value *string)
- func (entity *Schedule) SetLeaseUntil(value *time.Time)
- func (entity *Schedule) SetModelOverride(value *string)
- func (entity *Schedule) SetName(value string)
- func (entity *Schedule) SetNextRunAt(value *time.Time)
- func (entity *Schedule) SetScheduleType(value string)
- func (entity *Schedule) SetShouldDelete(value bool)
- func (entity *Schedule) SetStartAt(value *time.Time)
- func (entity *Schedule) SetTaskPrompt(value *string)
- func (entity *Schedule) SetTaskPromptUri(value *string)
- func (entity *Schedule) SetTimeoutSeconds(value int)
- func (entity *Schedule) SetTimezone(value string)
- func (entity *Schedule) SetUpdatedAt(value *time.Time)
- func (entity *Schedule) SetUserCredUrl(value *string)
- func (entity *Schedule) SetVisibility(value string)
- type ScheduleHas
- type WriterComponent
- type WriterHandlerCurrentWriterGroupedByAgentRef
- type WriterHandlerCurrentWriterGroupedByConversationId
- type WriterHandlerCurrentWriterGroupedByCreatedAt
- type WriterHandlerCurrentWriterGroupedByCreatedByUserId
- type WriterHandlerCurrentWriterGroupedByCronExpr
- type WriterHandlerCurrentWriterGroupedByDescription
- type WriterHandlerCurrentWriterGroupedByEnabled
- type WriterHandlerCurrentWriterGroupedByEndAt
- type WriterHandlerCurrentWriterGroupedByGoalId
- type WriterHandlerCurrentWriterGroupedById
- type WriterHandlerCurrentWriterGroupedByInternal
- type WriterHandlerCurrentWriterGroupedByIntervalSeconds
- type WriterHandlerCurrentWriterGroupedByLastError
- type WriterHandlerCurrentWriterGroupedByLastRunAt
- type WriterHandlerCurrentWriterGroupedByLastStatus
- type WriterHandlerCurrentWriterGroupedByLeaseOwner
- type WriterHandlerCurrentWriterGroupedByLeaseUntil
- type WriterHandlerCurrentWriterGroupedByModelOverride
- type WriterHandlerCurrentWriterGroupedByName
- type WriterHandlerCurrentWriterGroupedByNextRunAt
- type WriterHandlerCurrentWriterGroupedByScheduleType
- type WriterHandlerCurrentWriterGroupedByStartAt
- type WriterHandlerCurrentWriterGroupedByTaskPrompt
- type WriterHandlerCurrentWriterGroupedByTaskPromptUri
- type WriterHandlerCurrentWriterGroupedByTimeoutSeconds
- type WriterHandlerCurrentWriterGroupedByTimezone
- type WriterHandlerCurrentWriterGroupedByUpdatedAt
- type WriterHandlerCurrentWriterGroupedByUserCredUrl
- type WriterHandlerCurrentWriterGroupedByVisibility
- type WriterHandlerCurrentWriterIndexedByAgentRef
- type WriterHandlerCurrentWriterIndexedByConversationId
- type WriterHandlerCurrentWriterIndexedByCreatedAt
- type WriterHandlerCurrentWriterIndexedByCreatedByUserId
- type WriterHandlerCurrentWriterIndexedByCronExpr
- type WriterHandlerCurrentWriterIndexedByDescription
- type WriterHandlerCurrentWriterIndexedByEnabled
- type WriterHandlerCurrentWriterIndexedByEndAt
- type WriterHandlerCurrentWriterIndexedByGoalId
- type WriterHandlerCurrentWriterIndexedById
- type WriterHandlerCurrentWriterIndexedByInternal
- type WriterHandlerCurrentWriterIndexedByIntervalSeconds
- type WriterHandlerCurrentWriterIndexedByLastError
- type WriterHandlerCurrentWriterIndexedByLastRunAt
- type WriterHandlerCurrentWriterIndexedByLastStatus
- type WriterHandlerCurrentWriterIndexedByLeaseOwner
- type WriterHandlerCurrentWriterIndexedByLeaseUntil
- type WriterHandlerCurrentWriterIndexedByModelOverride
- type WriterHandlerCurrentWriterIndexedByName
- type WriterHandlerCurrentWriterIndexedByNextRunAt
- type WriterHandlerCurrentWriterIndexedByScheduleType
- type WriterHandlerCurrentWriterIndexedByStartAt
- type WriterHandlerCurrentWriterIndexedByTaskPrompt
- type WriterHandlerCurrentWriterIndexedByTaskPromptUri
- type WriterHandlerCurrentWriterIndexedByTimeoutSeconds
- type WriterHandlerCurrentWriterIndexedByTimezone
- type WriterHandlerCurrentWriterIndexedByUpdatedAt
- type WriterHandlerCurrentWriterIndexedByUserCredUrl
- type WriterHandlerCurrentWriterIndexedByVisibility
- type WriterHandlerCurrentWriterSlice
- func (rows WriterHandlerCurrentWriterSlice) GroupByAgentRef() WriterHandlerCurrentWriterGroupedByAgentRef
- func (rows WriterHandlerCurrentWriterSlice) GroupByConversationId() WriterHandlerCurrentWriterGroupedByConversationId
- func (rows WriterHandlerCurrentWriterSlice) GroupByCreatedAt() WriterHandlerCurrentWriterGroupedByCreatedAt
- func (rows WriterHandlerCurrentWriterSlice) GroupByCreatedByUserId() WriterHandlerCurrentWriterGroupedByCreatedByUserId
- func (rows WriterHandlerCurrentWriterSlice) GroupByCronExpr() WriterHandlerCurrentWriterGroupedByCronExpr
- func (rows WriterHandlerCurrentWriterSlice) GroupByDescription() WriterHandlerCurrentWriterGroupedByDescription
- func (rows WriterHandlerCurrentWriterSlice) GroupByEnabled() WriterHandlerCurrentWriterGroupedByEnabled
- func (rows WriterHandlerCurrentWriterSlice) GroupByEndAt() WriterHandlerCurrentWriterGroupedByEndAt
- func (rows WriterHandlerCurrentWriterSlice) GroupByGoalId() WriterHandlerCurrentWriterGroupedByGoalId
- func (rows WriterHandlerCurrentWriterSlice) GroupById() WriterHandlerCurrentWriterGroupedById
- func (rows WriterHandlerCurrentWriterSlice) GroupByInternal() WriterHandlerCurrentWriterGroupedByInternal
- func (rows WriterHandlerCurrentWriterSlice) GroupByIntervalSeconds() WriterHandlerCurrentWriterGroupedByIntervalSeconds
- func (rows WriterHandlerCurrentWriterSlice) GroupByLastError() WriterHandlerCurrentWriterGroupedByLastError
- func (rows WriterHandlerCurrentWriterSlice) GroupByLastRunAt() WriterHandlerCurrentWriterGroupedByLastRunAt
- func (rows WriterHandlerCurrentWriterSlice) GroupByLastStatus() WriterHandlerCurrentWriterGroupedByLastStatus
- func (rows WriterHandlerCurrentWriterSlice) GroupByLeaseOwner() WriterHandlerCurrentWriterGroupedByLeaseOwner
- func (rows WriterHandlerCurrentWriterSlice) GroupByLeaseUntil() WriterHandlerCurrentWriterGroupedByLeaseUntil
- func (rows WriterHandlerCurrentWriterSlice) GroupByModelOverride() WriterHandlerCurrentWriterGroupedByModelOverride
- func (rows WriterHandlerCurrentWriterSlice) GroupByName() WriterHandlerCurrentWriterGroupedByName
- func (rows WriterHandlerCurrentWriterSlice) GroupByNextRunAt() WriterHandlerCurrentWriterGroupedByNextRunAt
- func (rows WriterHandlerCurrentWriterSlice) GroupByScheduleType() WriterHandlerCurrentWriterGroupedByScheduleType
- func (rows WriterHandlerCurrentWriterSlice) GroupByStartAt() WriterHandlerCurrentWriterGroupedByStartAt
- func (rows WriterHandlerCurrentWriterSlice) GroupByTaskPrompt() WriterHandlerCurrentWriterGroupedByTaskPrompt
- func (rows WriterHandlerCurrentWriterSlice) GroupByTaskPromptUri() WriterHandlerCurrentWriterGroupedByTaskPromptUri
- func (rows WriterHandlerCurrentWriterSlice) GroupByTimeoutSeconds() WriterHandlerCurrentWriterGroupedByTimeoutSeconds
- func (rows WriterHandlerCurrentWriterSlice) GroupByTimezone() WriterHandlerCurrentWriterGroupedByTimezone
- func (rows WriterHandlerCurrentWriterSlice) GroupByUpdatedAt() WriterHandlerCurrentWriterGroupedByUpdatedAt
- func (rows WriterHandlerCurrentWriterSlice) GroupByUserCredUrl() WriterHandlerCurrentWriterGroupedByUserCredUrl
- func (rows WriterHandlerCurrentWriterSlice) GroupByVisibility() WriterHandlerCurrentWriterGroupedByVisibility
- func (rows WriterHandlerCurrentWriterSlice) IndexByAgentRef() (WriterHandlerCurrentWriterIndexedByAgentRef, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByConversationId() (WriterHandlerCurrentWriterIndexedByConversationId, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByCreatedAt() (WriterHandlerCurrentWriterIndexedByCreatedAt, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByCreatedByUserId() (WriterHandlerCurrentWriterIndexedByCreatedByUserId, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByCronExpr() (WriterHandlerCurrentWriterIndexedByCronExpr, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByDescription() (WriterHandlerCurrentWriterIndexedByDescription, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByEnabled() (WriterHandlerCurrentWriterIndexedByEnabled, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByEndAt() (WriterHandlerCurrentWriterIndexedByEndAt, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByGoalId() (WriterHandlerCurrentWriterIndexedByGoalId, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexById() (WriterHandlerCurrentWriterIndexedById, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByInternal() (WriterHandlerCurrentWriterIndexedByInternal, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByIntervalSeconds() (WriterHandlerCurrentWriterIndexedByIntervalSeconds, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByLastError() (WriterHandlerCurrentWriterIndexedByLastError, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByLastRunAt() (WriterHandlerCurrentWriterIndexedByLastRunAt, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByLastStatus() (WriterHandlerCurrentWriterIndexedByLastStatus, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByLeaseOwner() (WriterHandlerCurrentWriterIndexedByLeaseOwner, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByLeaseUntil() (WriterHandlerCurrentWriterIndexedByLeaseUntil, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByModelOverride() (WriterHandlerCurrentWriterIndexedByModelOverride, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByName() (WriterHandlerCurrentWriterIndexedByName, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByNextRunAt() (WriterHandlerCurrentWriterIndexedByNextRunAt, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByScheduleType() (WriterHandlerCurrentWriterIndexedByScheduleType, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByStartAt() (WriterHandlerCurrentWriterIndexedByStartAt, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByTaskPrompt() (WriterHandlerCurrentWriterIndexedByTaskPrompt, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByTaskPromptUri() (WriterHandlerCurrentWriterIndexedByTaskPromptUri, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByTimeoutSeconds() (WriterHandlerCurrentWriterIndexedByTimeoutSeconds, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByTimezone() (WriterHandlerCurrentWriterIndexedByTimezone, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByUpdatedAt() (WriterHandlerCurrentWriterIndexedByUpdatedAt, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByUserCredUrl() (WriterHandlerCurrentWriterIndexedByUserCredUrl, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByVisibility() (WriterHandlerCurrentWriterIndexedByVisibility, error)
- type WriterHandlerReadIndexes
- type WriterKeysRow
Constants ¶
View Source
const WriterDatlyResourceNamespace = "datly_schedule_write_writer"
DatlyResourceNamespace identifies this package's generated resource filesystem.
Variables ¶
View Source
var LifecycleDatly = LifecycleDatlyType()
View Source
var LifecycleHooks = new(Lifecycle)
View Source
var WriterDatly = new(WriterComponent)
The public value supports explicit component wiring.
View Source
var WriterDatlyResources embed.FS
Functions ¶
func LifecycleDatlyType ¶
func WriterDatlyType ¶
WriterDatlyType returns the public component type.
func WriterHandlerCurrentWriterIndexByAgentRefKey ¶
func WriterHandlerCurrentWriterIndexByAgentRefKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByConversationIdKey ¶
func WriterHandlerCurrentWriterIndexByConversationIdKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByCreatedAtKey ¶
func WriterHandlerCurrentWriterIndexByCreatedAtKey(value *CurrentWriterView) (time.Time, bool)
func WriterHandlerCurrentWriterIndexByCreatedByUserIdKey ¶
func WriterHandlerCurrentWriterIndexByCreatedByUserIdKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByCronExprKey ¶
func WriterHandlerCurrentWriterIndexByCronExprKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByDescriptionKey ¶
func WriterHandlerCurrentWriterIndexByDescriptionKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByEnabledKey ¶
func WriterHandlerCurrentWriterIndexByEnabledKey(value *CurrentWriterView) (bool, bool)
func WriterHandlerCurrentWriterIndexByEndAtKey ¶
func WriterHandlerCurrentWriterIndexByEndAtKey(value *CurrentWriterView) (time.Time, bool)
func WriterHandlerCurrentWriterIndexByGoalIdKey ¶
func WriterHandlerCurrentWriterIndexByGoalIdKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByIdKey ¶
func WriterHandlerCurrentWriterIndexByIdKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByInternalKey ¶
func WriterHandlerCurrentWriterIndexByInternalKey(value *CurrentWriterView) (bool, bool)
func WriterHandlerCurrentWriterIndexByIntervalSecondsKey ¶
func WriterHandlerCurrentWriterIndexByIntervalSecondsKey(value *CurrentWriterView) (int, bool)
func WriterHandlerCurrentWriterIndexByLastErrorKey ¶
func WriterHandlerCurrentWriterIndexByLastErrorKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByLastRunAtKey ¶
func WriterHandlerCurrentWriterIndexByLastRunAtKey(value *CurrentWriterView) (time.Time, bool)
func WriterHandlerCurrentWriterIndexByLastStatusKey ¶
func WriterHandlerCurrentWriterIndexByLastStatusKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByLeaseOwnerKey ¶
func WriterHandlerCurrentWriterIndexByLeaseOwnerKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByLeaseUntilKey ¶
func WriterHandlerCurrentWriterIndexByLeaseUntilKey(value *CurrentWriterView) (time.Time, bool)
func WriterHandlerCurrentWriterIndexByModelOverrideKey ¶
func WriterHandlerCurrentWriterIndexByModelOverrideKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByNameKey ¶
func WriterHandlerCurrentWriterIndexByNameKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByNextRunAtKey ¶
func WriterHandlerCurrentWriterIndexByNextRunAtKey(value *CurrentWriterView) (time.Time, bool)
func WriterHandlerCurrentWriterIndexByScheduleTypeKey ¶
func WriterHandlerCurrentWriterIndexByScheduleTypeKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByStartAtKey ¶
func WriterHandlerCurrentWriterIndexByStartAtKey(value *CurrentWriterView) (time.Time, bool)
func WriterHandlerCurrentWriterIndexByTaskPromptKey ¶
func WriterHandlerCurrentWriterIndexByTaskPromptKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByTaskPromptUriKey ¶
func WriterHandlerCurrentWriterIndexByTaskPromptUriKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByTimeoutSecondsKey ¶
func WriterHandlerCurrentWriterIndexByTimeoutSecondsKey(value *CurrentWriterView) (int, bool)
func WriterHandlerCurrentWriterIndexByTimezoneKey ¶
func WriterHandlerCurrentWriterIndexByTimezoneKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByUpdatedAtKey ¶
func WriterHandlerCurrentWriterIndexByUpdatedAtKey(value *CurrentWriterView) (time.Time, bool)
func WriterHandlerCurrentWriterIndexByUserCredUrlKey ¶
func WriterHandlerCurrentWriterIndexByUserCredUrlKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByVisibilityKey ¶
func WriterHandlerCurrentWriterIndexByVisibilityKey(value *CurrentWriterView) (string, bool)
Types ¶
type CurrentWriterView ¶
type CurrentWriterView struct {
Id string `validate:"required" sqlx:"id,primaryKey" json:"id"`
Name string `validate:"required" json:"name" sqlx:"name,required=true"`
Visibility string `json:"visibility" sqlx:"visibility,required=true"`
Internal *bool `sqlx:"internal,required=true" json:"internal,omitempty"`
AgentRef string `validate:"required" json:"agentRef" sqlx:"agent_ref,required=true"`
Enabled bool `json:"enabled" sqlx:"enabled,required=true"`
ScheduleType string `validate:"required" json:"scheduleType" sqlx:"schedule_type,required=true"`
Timezone string `validate:"required" json:"timezone" sqlx:"timezone,required=true"`
TimeoutSeconds int `json:"timeoutSeconds" sqlx:"timeout_seconds,required=true"`
Description *string `sqlx:"description" json:"description,omitempty"`
CreatedByUserId *string `sqlx:"created_by_user_id" json:"createdByUserId,omitempty"`
ConversationId *string `sqlx:"conversation_id" json:"conversationId,omitempty"`
GoalId *string `sqlx:"goal_id" json:"goalId,omitempty"`
ModelOverride *string `sqlx:"model_override" json:"modelOverride,omitempty"`
UserCredUrl *string `sqlx:"user_cred_url" json:"userCredUrl,omitempty"`
StartAt *time.Time `sqlx:"start_at" json:"startAt,omitempty"`
EndAt *time.Time `sqlx:"end_at" json:"endAt,omitempty"`
CronExpr *string `sqlx:"cron_expr" json:"cronExpr,omitempty"`
IntervalSeconds *int `sqlx:"interval_seconds" json:"intervalSeconds,omitempty"`
TaskPromptUri *string `sqlx:"task_prompt_uri" json:"taskPromptUri,omitempty"`
TaskPrompt *string `sqlx:"task_prompt" json:"taskPrompt,omitempty"`
NextRunAt *time.Time `sqlx:"next_run_at" json:"nextRunAt,omitempty"`
LastRunAt *time.Time `sqlx:"last_run_at" json:"lastRunAt,omitempty"`
LastStatus *string `sqlx:"last_status" json:"lastStatus,omitempty"`
LastError *string `sqlx:"last_error" json:"lastError,omitempty"`
LeaseOwner *string `sqlx:"lease_owner" json:"leaseOwner,omitempty"`
LeaseUntil *time.Time `sqlx:"lease_until" json:"leaseUntil,omitempty"`
CreatedAt *time.Time `sqlx:"created_at,required=true" json:"createdAt,omitempty"`
UpdatedAt *time.Time `sqlx:"updated_at" json:"updatedAt,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"`
LeaseMode string `` /* 174-byte string literal not displayed */
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"`
VisibilitySubject *string `parameter:"VisibilitySubject,kind=visibility,in=subject,dataType=*string,required=true"`
Schedules []*Schedule `` /* 222-byte string literal not displayed */
WriterKeys []WriterKeysRow `` /* 134-byte string literal not displayed */
CurrentWriter []*CurrentWriterView `` /* 166-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) ReadIndexes ¶
func (input *Input) ReadIndexes(ctx context.Context) (*WriterHandlerReadIndexes, error)
func (*Input) SetCurrentWriter ¶
func (input *Input) SetCurrentWriter(value []*CurrentWriterView)
func (*Input) SetLeaseMode ¶
func (*Input) SetLeaseNow ¶
func (*Input) SetLeaseOwner ¶
func (*Input) SetOrphanColumn ¶
func (*Input) SetOrphanDetach ¶
func (*Input) SetSchedules ¶
func (*Input) SetVisibilitySubject ¶
func (*Input) SetWriterKeys ¶
func (input *Input) SetWriterKeys(value []WriterKeysRow)
type Lifecycle ¶
type Lifecycle struct {
Input *Input `bind:"kind=input"`
Invoker dexec.ComponentInvoker `bind:"kind=component_invoker"`
}
func (*Lifecycle) AfterQueue ¶
func (*Lifecycle) AfterSequence ¶
type Output ¶
type Output struct {
Data []*Schedule `parameter:"Data,kind=output,in=body,dataType=[]*Schedule" json:"data,omitempty"`
LeaseResult bool `parameter:"LeaseResult,kind=output,in=leaseResult,dataType=bool" json:"leaseResult,omitempty"`
}
Output is the generated output scaffold for writer.
type Schedule ¶
type Schedule struct {
ShouldDelete bool `sqlx:"-" writer:"delete" json:"shouldDelete,omitempty"`
Id string `validate:"required" sqlx:"id,primaryKey" json:"id"`
Name string `validate:"required" json:"name" sqlx:"name,required=true"`
Visibility string `json:"visibility" sqlx:"visibility,required=true"`
Internal *bool `sqlx:"internal,required=true" json:"internal,omitempty"`
AgentRef string `validate:"required" json:"agentRef" sqlx:"agent_ref,required=true"`
Enabled bool `json:"enabled" sqlx:"enabled,required=true"`
ScheduleType string `validate:"required" json:"scheduleType" sqlx:"schedule_type,required=true"`
Timezone string `validate:"required" json:"timezone" sqlx:"timezone,required=true"`
TimeoutSeconds int `json:"timeoutSeconds" sqlx:"timeout_seconds,required=true"`
Description *string `sqlx:"description" json:"description,omitempty"`
CreatedByUserId *string `sqlx:"created_by_user_id" json:"createdByUserId,omitempty"`
ConversationId *string `sqlx:"conversation_id" json:"conversationId,omitempty"`
GoalId *string `sqlx:"goal_id" json:"goalId,omitempty"`
ModelOverride *string `sqlx:"model_override" json:"modelOverride,omitempty"`
UserCredUrl *string `sqlx:"user_cred_url" json:"userCredUrl,omitempty"`
StartAt *time.Time `sqlx:"start_at" json:"startAt,omitempty"`
EndAt *time.Time `sqlx:"end_at" json:"endAt,omitempty"`
CronExpr *string `sqlx:"cron_expr" json:"cronExpr,omitempty"`
IntervalSeconds *int `sqlx:"interval_seconds" json:"intervalSeconds,omitempty"`
TaskPromptUri *string `sqlx:"task_prompt_uri" json:"taskPromptUri,omitempty"`
TaskPrompt *string `sqlx:"task_prompt" json:"taskPrompt,omitempty"`
NextRunAt *time.Time `sqlx:"next_run_at" json:"nextRunAt,omitempty"`
LastRunAt *time.Time `sqlx:"last_run_at" json:"lastRunAt,omitempty"`
LastStatus *string `sqlx:"last_status" json:"lastStatus,omitempty"`
LastError *string `sqlx:"last_error" json:"lastError,omitempty"`
LeaseOwner *string `sqlx:"lease_owner" json:"leaseOwner,omitempty"`
LeaseUntil *time.Time `sqlx:"lease_until" json:"leaseUntil,omitempty"`
CreatedAt *time.Time `sqlx:"created_at,required=true" json:"createdAt,omitempty"`
UpdatedAt *time.Time `sqlx:"updated_at" json:"updatedAt,omitempty"`
Has *ScheduleHas `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-" typeName:"ScheduleHas"`
}
Schedule is generated canonical view metadata for writer.
func (*Schedule) GetAgentRef ¶
func (*Schedule) GetConversationId ¶
func (*Schedule) GetCreatedAt ¶
func (*Schedule) GetCreatedByUserId ¶
func (*Schedule) GetCronExpr ¶
func (*Schedule) GetDescription ¶
func (*Schedule) GetEnabled ¶
func (*Schedule) GetInternal ¶
func (*Schedule) GetIntervalSeconds ¶
func (*Schedule) GetLastError ¶
func (*Schedule) GetLastRunAt ¶
func (*Schedule) GetLastStatus ¶
func (*Schedule) GetLeaseOwner ¶
func (*Schedule) GetLeaseUntil ¶
func (*Schedule) GetModelOverride ¶
func (*Schedule) GetNextRunAt ¶
func (*Schedule) GetScheduleType ¶
func (*Schedule) GetShouldDelete ¶
func (*Schedule) GetStartAt ¶
func (*Schedule) GetTaskPrompt ¶
func (*Schedule) GetTaskPromptUri ¶
func (*Schedule) GetTimeoutSeconds ¶
func (*Schedule) GetTimezone ¶
func (*Schedule) GetUpdatedAt ¶
func (*Schedule) GetUserCredUrl ¶
func (*Schedule) GetVisibility ¶
func (*Schedule) SetAgentRef ¶
func (*Schedule) SetConversationId ¶
func (*Schedule) SetCreatedAt ¶
func (*Schedule) SetCreatedByUserId ¶
func (*Schedule) SetCronExpr ¶
func (*Schedule) SetDescription ¶
func (*Schedule) SetEnabled ¶
func (*Schedule) SetInternal ¶
func (*Schedule) SetIntervalSeconds ¶
func (*Schedule) SetLastError ¶
func (*Schedule) SetLastRunAt ¶
func (*Schedule) SetLastStatus ¶
func (*Schedule) SetLeaseOwner ¶
func (*Schedule) SetLeaseUntil ¶
func (*Schedule) SetModelOverride ¶
func (*Schedule) SetNextRunAt ¶
func (*Schedule) SetScheduleType ¶
func (*Schedule) SetShouldDelete ¶
func (*Schedule) SetStartAt ¶
func (*Schedule) SetTaskPrompt ¶
func (*Schedule) SetTaskPromptUri ¶
func (*Schedule) SetTimeoutSeconds ¶
func (*Schedule) SetTimezone ¶
func (*Schedule) SetUpdatedAt ¶
func (*Schedule) SetUserCredUrl ¶
func (*Schedule) SetVisibility ¶
type ScheduleHas ¶
type ScheduleHas struct {
ShouldDelete bool
Id bool
Name bool
Visibility bool
Internal bool
AgentRef bool
Enabled bool
ScheduleType bool
Timezone bool
TimeoutSeconds bool
Description bool
CreatedByUserId bool
ConversationId bool
GoalId bool
ModelOverride bool
UserCredUrl bool
StartAt bool
EndAt bool
CronExpr bool
IntervalSeconds bool
TaskPromptUri bool
TaskPrompt bool
NextRunAt bool
LastRunAt bool
LastStatus bool
LastError bool
LeaseOwner bool
LeaseUntil bool
CreatedAt bool
UpdatedAt bool
}
type WriterComponent ¶
type WriterComponent struct {
Contract xdatly.Component[Input, Output] "" /* 202-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 WriterHandlerCurrentWriterGroupedByAgentRef ¶
type WriterHandlerCurrentWriterGroupedByAgentRef map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByAgentRef) Has ¶
func (index WriterHandlerCurrentWriterGroupedByAgentRef) 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
type WriterHandlerCurrentWriterGroupedByCreatedByUserId ¶
type WriterHandlerCurrentWriterGroupedByCreatedByUserId map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByCreatedByUserId) Has ¶
func (index WriterHandlerCurrentWriterGroupedByCreatedByUserId) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByCronExpr ¶
type WriterHandlerCurrentWriterGroupedByCronExpr map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByCronExpr) Has ¶
func (index WriterHandlerCurrentWriterGroupedByCronExpr) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByDescription ¶
type WriterHandlerCurrentWriterGroupedByDescription map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByDescription) Has ¶
func (index WriterHandlerCurrentWriterGroupedByDescription) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByEnabled ¶
type WriterHandlerCurrentWriterGroupedByEnabled map[bool][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByEnabled) Has ¶
func (index WriterHandlerCurrentWriterGroupedByEnabled) Has(key bool) bool
type WriterHandlerCurrentWriterGroupedByEndAt ¶
type WriterHandlerCurrentWriterGroupedByEndAt map[time.Time][]*CurrentWriterView
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 WriterHandlerCurrentWriterGroupedByInternal ¶
type WriterHandlerCurrentWriterGroupedByInternal map[bool][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByInternal) Has ¶
func (index WriterHandlerCurrentWriterGroupedByInternal) Has(key bool) bool
type WriterHandlerCurrentWriterGroupedByIntervalSeconds ¶
type WriterHandlerCurrentWriterGroupedByIntervalSeconds map[int][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByIntervalSeconds) Has ¶
func (index WriterHandlerCurrentWriterGroupedByIntervalSeconds) Has(key int) bool
type WriterHandlerCurrentWriterGroupedByLastError ¶
type WriterHandlerCurrentWriterGroupedByLastError map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByLastError) Has ¶
func (index WriterHandlerCurrentWriterGroupedByLastError) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByLastRunAt ¶
type WriterHandlerCurrentWriterGroupedByLastRunAt map[time.Time][]*CurrentWriterView
type WriterHandlerCurrentWriterGroupedByLastStatus ¶
type WriterHandlerCurrentWriterGroupedByLastStatus map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByLastStatus) Has ¶
func (index WriterHandlerCurrentWriterGroupedByLastStatus) Has(key string) 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
type WriterHandlerCurrentWriterGroupedByModelOverride ¶
type WriterHandlerCurrentWriterGroupedByModelOverride map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByModelOverride) Has ¶
func (index WriterHandlerCurrentWriterGroupedByModelOverride) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByName ¶
type WriterHandlerCurrentWriterGroupedByName map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByName) Has ¶
func (index WriterHandlerCurrentWriterGroupedByName) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByNextRunAt ¶
type WriterHandlerCurrentWriterGroupedByNextRunAt map[time.Time][]*CurrentWriterView
type WriterHandlerCurrentWriterGroupedByScheduleType ¶
type WriterHandlerCurrentWriterGroupedByScheduleType map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByScheduleType) Has ¶
func (index WriterHandlerCurrentWriterGroupedByScheduleType) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByStartAt ¶
type WriterHandlerCurrentWriterGroupedByStartAt map[time.Time][]*CurrentWriterView
type WriterHandlerCurrentWriterGroupedByTaskPrompt ¶
type WriterHandlerCurrentWriterGroupedByTaskPrompt map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByTaskPrompt) Has ¶
func (index WriterHandlerCurrentWriterGroupedByTaskPrompt) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByTaskPromptUri ¶
type WriterHandlerCurrentWriterGroupedByTaskPromptUri map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByTaskPromptUri) Has ¶
func (index WriterHandlerCurrentWriterGroupedByTaskPromptUri) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByTimeoutSeconds ¶
type WriterHandlerCurrentWriterGroupedByTimeoutSeconds map[int][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByTimeoutSeconds) Has ¶
func (index WriterHandlerCurrentWriterGroupedByTimeoutSeconds) Has(key int) bool
type WriterHandlerCurrentWriterGroupedByTimezone ¶
type WriterHandlerCurrentWriterGroupedByTimezone map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByTimezone) Has ¶
func (index WriterHandlerCurrentWriterGroupedByTimezone) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByUpdatedAt ¶
type WriterHandlerCurrentWriterGroupedByUpdatedAt map[time.Time][]*CurrentWriterView
type WriterHandlerCurrentWriterGroupedByUserCredUrl ¶
type WriterHandlerCurrentWriterGroupedByUserCredUrl map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByUserCredUrl) Has ¶
func (index WriterHandlerCurrentWriterGroupedByUserCredUrl) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByVisibility ¶
type WriterHandlerCurrentWriterGroupedByVisibility map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByVisibility) Has ¶
func (index WriterHandlerCurrentWriterGroupedByVisibility) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByAgentRef ¶
type WriterHandlerCurrentWriterIndexedByAgentRef map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByAgentRef) Has ¶
func (index WriterHandlerCurrentWriterIndexedByAgentRef) 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
type WriterHandlerCurrentWriterIndexedByCreatedByUserId ¶
type WriterHandlerCurrentWriterIndexedByCreatedByUserId map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByCreatedByUserId) Has ¶
func (index WriterHandlerCurrentWriterIndexedByCreatedByUserId) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByCronExpr ¶
type WriterHandlerCurrentWriterIndexedByCronExpr map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByCronExpr) Has ¶
func (index WriterHandlerCurrentWriterIndexedByCronExpr) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByDescription ¶
type WriterHandlerCurrentWriterIndexedByDescription map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByDescription) Has ¶
func (index WriterHandlerCurrentWriterIndexedByDescription) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByEnabled ¶
type WriterHandlerCurrentWriterIndexedByEnabled map[bool]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByEnabled) Has ¶
func (index WriterHandlerCurrentWriterIndexedByEnabled) Has(key bool) bool
type WriterHandlerCurrentWriterIndexedByEndAt ¶
type WriterHandlerCurrentWriterIndexedByEndAt map[time.Time]*CurrentWriterView
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 WriterHandlerCurrentWriterIndexedByInternal ¶
type WriterHandlerCurrentWriterIndexedByInternal map[bool]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByInternal) Has ¶
func (index WriterHandlerCurrentWriterIndexedByInternal) Has(key bool) bool
type WriterHandlerCurrentWriterIndexedByIntervalSeconds ¶
type WriterHandlerCurrentWriterIndexedByIntervalSeconds map[int]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByIntervalSeconds) Has ¶
func (index WriterHandlerCurrentWriterIndexedByIntervalSeconds) Has(key int) bool
type WriterHandlerCurrentWriterIndexedByLastError ¶
type WriterHandlerCurrentWriterIndexedByLastError map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByLastError) Has ¶
func (index WriterHandlerCurrentWriterIndexedByLastError) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByLastRunAt ¶
type WriterHandlerCurrentWriterIndexedByLastRunAt map[time.Time]*CurrentWriterView
type WriterHandlerCurrentWriterIndexedByLastStatus ¶
type WriterHandlerCurrentWriterIndexedByLastStatus map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByLastStatus) Has ¶
func (index WriterHandlerCurrentWriterIndexedByLastStatus) Has(key string) 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
type WriterHandlerCurrentWriterIndexedByModelOverride ¶
type WriterHandlerCurrentWriterIndexedByModelOverride map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByModelOverride) Has ¶
func (index WriterHandlerCurrentWriterIndexedByModelOverride) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByName ¶
type WriterHandlerCurrentWriterIndexedByName map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByName) Has ¶
func (index WriterHandlerCurrentWriterIndexedByName) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByNextRunAt ¶
type WriterHandlerCurrentWriterIndexedByNextRunAt map[time.Time]*CurrentWriterView
type WriterHandlerCurrentWriterIndexedByScheduleType ¶
type WriterHandlerCurrentWriterIndexedByScheduleType map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByScheduleType) Has ¶
func (index WriterHandlerCurrentWriterIndexedByScheduleType) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByStartAt ¶
type WriterHandlerCurrentWriterIndexedByStartAt map[time.Time]*CurrentWriterView
type WriterHandlerCurrentWriterIndexedByTaskPrompt ¶
type WriterHandlerCurrentWriterIndexedByTaskPrompt map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByTaskPrompt) Has ¶
func (index WriterHandlerCurrentWriterIndexedByTaskPrompt) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByTaskPromptUri ¶
type WriterHandlerCurrentWriterIndexedByTaskPromptUri map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByTaskPromptUri) Has ¶
func (index WriterHandlerCurrentWriterIndexedByTaskPromptUri) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByTimeoutSeconds ¶
type WriterHandlerCurrentWriterIndexedByTimeoutSeconds map[int]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByTimeoutSeconds) Has ¶
func (index WriterHandlerCurrentWriterIndexedByTimeoutSeconds) Has(key int) bool
type WriterHandlerCurrentWriterIndexedByTimezone ¶
type WriterHandlerCurrentWriterIndexedByTimezone map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByTimezone) Has ¶
func (index WriterHandlerCurrentWriterIndexedByTimezone) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByUpdatedAt ¶
type WriterHandlerCurrentWriterIndexedByUpdatedAt map[time.Time]*CurrentWriterView
type WriterHandlerCurrentWriterIndexedByUserCredUrl ¶
type WriterHandlerCurrentWriterIndexedByUserCredUrl map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByUserCredUrl) Has ¶
func (index WriterHandlerCurrentWriterIndexedByUserCredUrl) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByVisibility ¶
type WriterHandlerCurrentWriterIndexedByVisibility map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByVisibility) Has ¶
func (index WriterHandlerCurrentWriterIndexedByVisibility) Has(key string) bool
type WriterHandlerCurrentWriterSlice ¶
type WriterHandlerCurrentWriterSlice []*CurrentWriterView
func (WriterHandlerCurrentWriterSlice) GroupByAgentRef ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByAgentRef() WriterHandlerCurrentWriterGroupedByAgentRef
func (WriterHandlerCurrentWriterSlice) GroupByConversationId ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByConversationId() WriterHandlerCurrentWriterGroupedByConversationId
func (WriterHandlerCurrentWriterSlice) GroupByCreatedAt ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByCreatedAt() WriterHandlerCurrentWriterGroupedByCreatedAt
func (WriterHandlerCurrentWriterSlice) GroupByCreatedByUserId ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByCreatedByUserId() WriterHandlerCurrentWriterGroupedByCreatedByUserId
func (WriterHandlerCurrentWriterSlice) GroupByCronExpr ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByCronExpr() WriterHandlerCurrentWriterGroupedByCronExpr
func (WriterHandlerCurrentWriterSlice) GroupByDescription ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByDescription() WriterHandlerCurrentWriterGroupedByDescription
func (WriterHandlerCurrentWriterSlice) GroupByEnabled ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByEnabled() WriterHandlerCurrentWriterGroupedByEnabled
func (WriterHandlerCurrentWriterSlice) GroupByEndAt ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByEndAt() WriterHandlerCurrentWriterGroupedByEndAt
func (WriterHandlerCurrentWriterSlice) GroupByGoalId ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByGoalId() WriterHandlerCurrentWriterGroupedByGoalId
func (WriterHandlerCurrentWriterSlice) GroupById ¶
func (rows WriterHandlerCurrentWriterSlice) GroupById() WriterHandlerCurrentWriterGroupedById
func (WriterHandlerCurrentWriterSlice) GroupByInternal ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByInternal() WriterHandlerCurrentWriterGroupedByInternal
func (WriterHandlerCurrentWriterSlice) GroupByIntervalSeconds ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByIntervalSeconds() WriterHandlerCurrentWriterGroupedByIntervalSeconds
func (WriterHandlerCurrentWriterSlice) GroupByLastError ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByLastError() WriterHandlerCurrentWriterGroupedByLastError
func (WriterHandlerCurrentWriterSlice) GroupByLastRunAt ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByLastRunAt() WriterHandlerCurrentWriterGroupedByLastRunAt
func (WriterHandlerCurrentWriterSlice) GroupByLastStatus ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByLastStatus() WriterHandlerCurrentWriterGroupedByLastStatus
func (WriterHandlerCurrentWriterSlice) GroupByLeaseOwner ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByLeaseOwner() WriterHandlerCurrentWriterGroupedByLeaseOwner
func (WriterHandlerCurrentWriterSlice) GroupByLeaseUntil ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByLeaseUntil() WriterHandlerCurrentWriterGroupedByLeaseUntil
func (WriterHandlerCurrentWriterSlice) GroupByModelOverride ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByModelOverride() WriterHandlerCurrentWriterGroupedByModelOverride
func (WriterHandlerCurrentWriterSlice) GroupByName ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByName() WriterHandlerCurrentWriterGroupedByName
func (WriterHandlerCurrentWriterSlice) GroupByNextRunAt ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByNextRunAt() WriterHandlerCurrentWriterGroupedByNextRunAt
func (WriterHandlerCurrentWriterSlice) GroupByScheduleType ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByScheduleType() WriterHandlerCurrentWriterGroupedByScheduleType
func (WriterHandlerCurrentWriterSlice) GroupByStartAt ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByStartAt() WriterHandlerCurrentWriterGroupedByStartAt
func (WriterHandlerCurrentWriterSlice) GroupByTaskPrompt ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByTaskPrompt() WriterHandlerCurrentWriterGroupedByTaskPrompt
func (WriterHandlerCurrentWriterSlice) GroupByTaskPromptUri ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByTaskPromptUri() WriterHandlerCurrentWriterGroupedByTaskPromptUri
func (WriterHandlerCurrentWriterSlice) GroupByTimeoutSeconds ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByTimeoutSeconds() WriterHandlerCurrentWriterGroupedByTimeoutSeconds
func (WriterHandlerCurrentWriterSlice) GroupByTimezone ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByTimezone() WriterHandlerCurrentWriterGroupedByTimezone
func (WriterHandlerCurrentWriterSlice) GroupByUpdatedAt ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByUpdatedAt() WriterHandlerCurrentWriterGroupedByUpdatedAt
func (WriterHandlerCurrentWriterSlice) GroupByUserCredUrl ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByUserCredUrl() WriterHandlerCurrentWriterGroupedByUserCredUrl
func (WriterHandlerCurrentWriterSlice) GroupByVisibility ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByVisibility() WriterHandlerCurrentWriterGroupedByVisibility
func (WriterHandlerCurrentWriterSlice) IndexByAgentRef ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByAgentRef() (WriterHandlerCurrentWriterIndexedByAgentRef, error)
func (WriterHandlerCurrentWriterSlice) IndexByConversationId ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByConversationId() (WriterHandlerCurrentWriterIndexedByConversationId, error)
func (WriterHandlerCurrentWriterSlice) IndexByCreatedAt ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByCreatedAt() (WriterHandlerCurrentWriterIndexedByCreatedAt, error)
func (WriterHandlerCurrentWriterSlice) IndexByCreatedByUserId ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByCreatedByUserId() (WriterHandlerCurrentWriterIndexedByCreatedByUserId, error)
func (WriterHandlerCurrentWriterSlice) IndexByCronExpr ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByCronExpr() (WriterHandlerCurrentWriterIndexedByCronExpr, error)
func (WriterHandlerCurrentWriterSlice) IndexByDescription ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByDescription() (WriterHandlerCurrentWriterIndexedByDescription, error)
func (WriterHandlerCurrentWriterSlice) IndexByEnabled ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByEnabled() (WriterHandlerCurrentWriterIndexedByEnabled, error)
func (WriterHandlerCurrentWriterSlice) IndexByEndAt ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByEndAt() (WriterHandlerCurrentWriterIndexedByEndAt, error)
func (WriterHandlerCurrentWriterSlice) IndexByGoalId ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByGoalId() (WriterHandlerCurrentWriterIndexedByGoalId, error)
func (WriterHandlerCurrentWriterSlice) IndexById ¶
func (rows WriterHandlerCurrentWriterSlice) IndexById() (WriterHandlerCurrentWriterIndexedById, error)
func (WriterHandlerCurrentWriterSlice) IndexByInternal ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByInternal() (WriterHandlerCurrentWriterIndexedByInternal, error)
func (WriterHandlerCurrentWriterSlice) IndexByIntervalSeconds ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByIntervalSeconds() (WriterHandlerCurrentWriterIndexedByIntervalSeconds, error)
func (WriterHandlerCurrentWriterSlice) IndexByLastError ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByLastError() (WriterHandlerCurrentWriterIndexedByLastError, error)
func (WriterHandlerCurrentWriterSlice) IndexByLastRunAt ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByLastRunAt() (WriterHandlerCurrentWriterIndexedByLastRunAt, error)
func (WriterHandlerCurrentWriterSlice) IndexByLastStatus ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByLastStatus() (WriterHandlerCurrentWriterIndexedByLastStatus, error)
func (WriterHandlerCurrentWriterSlice) IndexByLeaseOwner ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByLeaseOwner() (WriterHandlerCurrentWriterIndexedByLeaseOwner, error)
func (WriterHandlerCurrentWriterSlice) IndexByLeaseUntil ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByLeaseUntil() (WriterHandlerCurrentWriterIndexedByLeaseUntil, error)
func (WriterHandlerCurrentWriterSlice) IndexByModelOverride ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByModelOverride() (WriterHandlerCurrentWriterIndexedByModelOverride, error)
func (WriterHandlerCurrentWriterSlice) IndexByName ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByName() (WriterHandlerCurrentWriterIndexedByName, error)
func (WriterHandlerCurrentWriterSlice) IndexByNextRunAt ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByNextRunAt() (WriterHandlerCurrentWriterIndexedByNextRunAt, error)
func (WriterHandlerCurrentWriterSlice) IndexByScheduleType ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByScheduleType() (WriterHandlerCurrentWriterIndexedByScheduleType, error)
func (WriterHandlerCurrentWriterSlice) IndexByStartAt ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByStartAt() (WriterHandlerCurrentWriterIndexedByStartAt, error)
func (WriterHandlerCurrentWriterSlice) IndexByTaskPrompt ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByTaskPrompt() (WriterHandlerCurrentWriterIndexedByTaskPrompt, error)
func (WriterHandlerCurrentWriterSlice) IndexByTaskPromptUri ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByTaskPromptUri() (WriterHandlerCurrentWriterIndexedByTaskPromptUri, error)
func (WriterHandlerCurrentWriterSlice) IndexByTimeoutSeconds ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByTimeoutSeconds() (WriterHandlerCurrentWriterIndexedByTimeoutSeconds, error)
func (WriterHandlerCurrentWriterSlice) IndexByTimezone ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByTimezone() (WriterHandlerCurrentWriterIndexedByTimezone, error)
func (WriterHandlerCurrentWriterSlice) IndexByUpdatedAt ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByUpdatedAt() (WriterHandlerCurrentWriterIndexedByUpdatedAt, error)
func (WriterHandlerCurrentWriterSlice) IndexByUserCredUrl ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByUserCredUrl() (WriterHandlerCurrentWriterIndexedByUserCredUrl, error)
func (WriterHandlerCurrentWriterSlice) IndexByVisibility ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByVisibility() (WriterHandlerCurrentWriterIndexedByVisibility, 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"`
}
Click to show internal directories.
Click to hide internal directories.