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

write

package
v0.1.58 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source
const WriterDatlyResourceNamespace = "datly_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 LifecycleDatlyType() reflect.Type

func WriterDatlyType

func WriterDatlyType() reflect.Type

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

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

func (*Input) PrepareReadIndexes

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

func (*Input) ReadIndexes

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

func (*Input) SetCurrentWriter

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

func (*Input) SetLeaseMode

func (input *Input) SetLeaseMode(value string)

func (*Input) SetLeaseNow

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

func (*Input) SetLeaseOwner

func (input *Input) SetLeaseOwner(value string)

func (*Input) SetOrphanColumn

func (input *Input) SetOrphanColumn(value string)

func (*Input) SetOrphanDetach

func (input *Input) SetOrphanDetach(value bool)

func (*Input) SetSchedules

func (input *Input) SetSchedules(value []*Schedule)

func (*Input) SetVisibilitySubject

func (input *Input) SetVisibilitySubject(value *string)

func (*Input) SetWriterKeys

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

type InputHas

type InputHas struct {
	OrphanDetach      bool
	OrphanColumn      bool
	LeaseMode         bool
	LeaseOwner        bool
	LeaseNow          bool
	VisibilitySubject bool
	Schedules         bool
	WriterKeys        bool
	CurrentWriter     bool
}

type Lifecycle

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

func (*Lifecycle) Finalize

func (h *Lifecycle) Finalize(_ context.Context, input *Input, out *Output, outcome xhandler.Outcome) error

func (*Lifecycle) Init

func (*Lifecycle) Recover

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

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 (entity *Schedule) GetAgentRef() string

func (*Schedule) GetConversationId

func (entity *Schedule) GetConversationId() *string

func (*Schedule) GetCreatedAt

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

func (*Schedule) GetCreatedByUserId

func (entity *Schedule) GetCreatedByUserId() *string

func (*Schedule) GetCronExpr

func (entity *Schedule) GetCronExpr() *string

func (*Schedule) GetDescription

func (entity *Schedule) GetDescription() *string

func (*Schedule) GetEnabled

func (entity *Schedule) GetEnabled() bool

func (*Schedule) GetEndAt

func (entity *Schedule) GetEndAt() *time.Time

func (*Schedule) GetGoalId

func (entity *Schedule) GetGoalId() *string

func (*Schedule) GetId

func (entity *Schedule) GetId() string

func (*Schedule) GetInternal

func (entity *Schedule) GetInternal() *bool

func (*Schedule) GetIntervalSeconds

func (entity *Schedule) GetIntervalSeconds() *int

func (*Schedule) GetLastError

func (entity *Schedule) GetLastError() *string

func (*Schedule) GetLastRunAt

func (entity *Schedule) GetLastRunAt() *time.Time

func (*Schedule) GetLastStatus

func (entity *Schedule) GetLastStatus() *string

func (*Schedule) GetLeaseOwner

func (entity *Schedule) GetLeaseOwner() *string

func (*Schedule) GetLeaseUntil

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

func (*Schedule) GetModelOverride

func (entity *Schedule) GetModelOverride() *string

func (*Schedule) GetName

func (entity *Schedule) GetName() string

func (*Schedule) GetNextRunAt

func (entity *Schedule) GetNextRunAt() *time.Time

func (*Schedule) GetScheduleType

func (entity *Schedule) GetScheduleType() string

func (*Schedule) GetShouldDelete

func (entity *Schedule) GetShouldDelete() bool

func (*Schedule) GetStartAt

func (entity *Schedule) GetStartAt() *time.Time

func (*Schedule) GetTaskPrompt

func (entity *Schedule) GetTaskPrompt() *string

func (*Schedule) GetTaskPromptUri

func (entity *Schedule) GetTaskPromptUri() *string

func (*Schedule) GetTimeoutSeconds

func (entity *Schedule) GetTimeoutSeconds() int

func (*Schedule) GetTimezone

func (entity *Schedule) GetTimezone() string

func (*Schedule) GetUpdatedAt

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

func (*Schedule) GetUserCredUrl

func (entity *Schedule) GetUserCredUrl() *string

func (*Schedule) GetVisibility

func (entity *Schedule) GetVisibility() string

func (*Schedule) SetAgentRef

func (entity *Schedule) SetAgentRef(value string)

func (*Schedule) SetConversationId

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

func (*Schedule) SetCreatedAt

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

func (*Schedule) SetCreatedByUserId

func (entity *Schedule) SetCreatedByUserId(value *string)

func (*Schedule) SetCronExpr

func (entity *Schedule) SetCronExpr(value *string)

func (*Schedule) SetDescription

func (entity *Schedule) SetDescription(value *string)

func (*Schedule) SetEnabled

func (entity *Schedule) SetEnabled(value bool)

func (*Schedule) SetEndAt

func (entity *Schedule) SetEndAt(value *time.Time)

func (*Schedule) SetGoalId

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

func (*Schedule) SetId

func (entity *Schedule) SetId(value string)

func (*Schedule) SetInternal

func (entity *Schedule) SetInternal(value *bool)

func (*Schedule) SetIntervalSeconds

func (entity *Schedule) SetIntervalSeconds(value *int)

func (*Schedule) SetLastError

func (entity *Schedule) SetLastError(value *string)

func (*Schedule) SetLastRunAt

func (entity *Schedule) SetLastRunAt(value *time.Time)

func (*Schedule) SetLastStatus

func (entity *Schedule) SetLastStatus(value *string)

func (*Schedule) SetLeaseOwner

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

func (*Schedule) SetLeaseUntil

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

func (*Schedule) SetModelOverride

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

func (*Schedule) SetName

func (entity *Schedule) SetName(value string)

func (*Schedule) SetNextRunAt

func (entity *Schedule) SetNextRunAt(value *time.Time)

func (*Schedule) SetScheduleType

func (entity *Schedule) SetScheduleType(value string)

func (*Schedule) SetShouldDelete

func (entity *Schedule) SetShouldDelete(value bool)

func (*Schedule) SetStartAt

func (entity *Schedule) SetStartAt(value *time.Time)

func (*Schedule) SetTaskPrompt

func (entity *Schedule) SetTaskPrompt(value *string)

func (*Schedule) SetTaskPromptUri

func (entity *Schedule) SetTaskPromptUri(value *string)

func (*Schedule) SetTimeoutSeconds

func (entity *Schedule) SetTimeoutSeconds(value int)

func (*Schedule) SetTimezone

func (entity *Schedule) SetTimezone(value string)

func (*Schedule) SetUpdatedAt

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

func (*Schedule) SetUserCredUrl

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

func (*Schedule) SetVisibility

func (entity *Schedule) SetVisibility(value string)

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

type WriterHandlerCurrentWriterGroupedByConversationId

type WriterHandlerCurrentWriterGroupedByConversationId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByConversationId) Has

type WriterHandlerCurrentWriterGroupedByCreatedAt

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

func (WriterHandlerCurrentWriterGroupedByCreatedAt) Has

type WriterHandlerCurrentWriterGroupedByCreatedByUserId

type WriterHandlerCurrentWriterGroupedByCreatedByUserId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByCreatedByUserId) Has

type WriterHandlerCurrentWriterGroupedByCronExpr

type WriterHandlerCurrentWriterGroupedByCronExpr map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByCronExpr) Has

type WriterHandlerCurrentWriterGroupedByDescription

type WriterHandlerCurrentWriterGroupedByDescription map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByDescription) Has

type WriterHandlerCurrentWriterGroupedByEnabled

type WriterHandlerCurrentWriterGroupedByEnabled map[bool][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByEnabled) Has

type WriterHandlerCurrentWriterGroupedByEndAt

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

func (WriterHandlerCurrentWriterGroupedByEndAt) Has

type WriterHandlerCurrentWriterGroupedByGoalId

type WriterHandlerCurrentWriterGroupedByGoalId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByGoalId) Has

type WriterHandlerCurrentWriterGroupedById

type WriterHandlerCurrentWriterGroupedById map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedById) Has

type WriterHandlerCurrentWriterGroupedByInternal

type WriterHandlerCurrentWriterGroupedByInternal map[bool][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByInternal) Has

type WriterHandlerCurrentWriterGroupedByIntervalSeconds

type WriterHandlerCurrentWriterGroupedByIntervalSeconds map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByIntervalSeconds) Has

type WriterHandlerCurrentWriterGroupedByLastError

type WriterHandlerCurrentWriterGroupedByLastError map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByLastError) Has

type WriterHandlerCurrentWriterGroupedByLastRunAt

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

func (WriterHandlerCurrentWriterGroupedByLastRunAt) Has

type WriterHandlerCurrentWriterGroupedByLastStatus

type WriterHandlerCurrentWriterGroupedByLastStatus map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByLastStatus) Has

type WriterHandlerCurrentWriterGroupedByLeaseOwner

type WriterHandlerCurrentWriterGroupedByLeaseOwner map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByLeaseOwner) Has

type WriterHandlerCurrentWriterGroupedByLeaseUntil

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

func (WriterHandlerCurrentWriterGroupedByLeaseUntil) Has

type WriterHandlerCurrentWriterGroupedByModelOverride

type WriterHandlerCurrentWriterGroupedByModelOverride map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByModelOverride) Has

type WriterHandlerCurrentWriterGroupedByName

type WriterHandlerCurrentWriterGroupedByName map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByName) Has

type WriterHandlerCurrentWriterGroupedByNextRunAt

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

func (WriterHandlerCurrentWriterGroupedByNextRunAt) Has

type WriterHandlerCurrentWriterGroupedByScheduleType

type WriterHandlerCurrentWriterGroupedByScheduleType map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByScheduleType) Has

type WriterHandlerCurrentWriterGroupedByStartAt

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

func (WriterHandlerCurrentWriterGroupedByStartAt) Has

type WriterHandlerCurrentWriterGroupedByTaskPrompt

type WriterHandlerCurrentWriterGroupedByTaskPrompt map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByTaskPrompt) Has

type WriterHandlerCurrentWriterGroupedByTaskPromptUri

type WriterHandlerCurrentWriterGroupedByTaskPromptUri map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByTaskPromptUri) Has

type WriterHandlerCurrentWriterGroupedByTimeoutSeconds

type WriterHandlerCurrentWriterGroupedByTimeoutSeconds map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByTimeoutSeconds) Has

type WriterHandlerCurrentWriterGroupedByTimezone

type WriterHandlerCurrentWriterGroupedByTimezone map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByTimezone) Has

type WriterHandlerCurrentWriterGroupedByUpdatedAt

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

func (WriterHandlerCurrentWriterGroupedByUpdatedAt) Has

type WriterHandlerCurrentWriterGroupedByUserCredUrl

type WriterHandlerCurrentWriterGroupedByUserCredUrl map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByUserCredUrl) Has

type WriterHandlerCurrentWriterGroupedByVisibility

type WriterHandlerCurrentWriterGroupedByVisibility map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByVisibility) Has

type WriterHandlerCurrentWriterIndexedByAgentRef

type WriterHandlerCurrentWriterIndexedByAgentRef map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByAgentRef) Has

type WriterHandlerCurrentWriterIndexedByConversationId

type WriterHandlerCurrentWriterIndexedByConversationId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByConversationId) Has

type WriterHandlerCurrentWriterIndexedByCreatedAt

type WriterHandlerCurrentWriterIndexedByCreatedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCreatedAt) Has

type WriterHandlerCurrentWriterIndexedByCreatedByUserId

type WriterHandlerCurrentWriterIndexedByCreatedByUserId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCreatedByUserId) Has

type WriterHandlerCurrentWriterIndexedByCronExpr

type WriterHandlerCurrentWriterIndexedByCronExpr map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCronExpr) Has

type WriterHandlerCurrentWriterIndexedByDescription

type WriterHandlerCurrentWriterIndexedByDescription map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByDescription) Has

type WriterHandlerCurrentWriterIndexedByEnabled

type WriterHandlerCurrentWriterIndexedByEnabled map[bool]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByEnabled) Has

type WriterHandlerCurrentWriterIndexedByEndAt

type WriterHandlerCurrentWriterIndexedByEndAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByEndAt) Has

type WriterHandlerCurrentWriterIndexedByGoalId

type WriterHandlerCurrentWriterIndexedByGoalId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByGoalId) Has

type WriterHandlerCurrentWriterIndexedById

type WriterHandlerCurrentWriterIndexedById map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedById) Has

type WriterHandlerCurrentWriterIndexedByInternal

type WriterHandlerCurrentWriterIndexedByInternal map[bool]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByInternal) Has

type WriterHandlerCurrentWriterIndexedByIntervalSeconds

type WriterHandlerCurrentWriterIndexedByIntervalSeconds map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByIntervalSeconds) Has

type WriterHandlerCurrentWriterIndexedByLastError

type WriterHandlerCurrentWriterIndexedByLastError map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByLastError) Has

type WriterHandlerCurrentWriterIndexedByLastRunAt

type WriterHandlerCurrentWriterIndexedByLastRunAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByLastRunAt) Has

type WriterHandlerCurrentWriterIndexedByLastStatus

type WriterHandlerCurrentWriterIndexedByLastStatus map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByLastStatus) Has

type WriterHandlerCurrentWriterIndexedByLeaseOwner

type WriterHandlerCurrentWriterIndexedByLeaseOwner map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByLeaseOwner) Has

type WriterHandlerCurrentWriterIndexedByLeaseUntil

type WriterHandlerCurrentWriterIndexedByLeaseUntil map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByLeaseUntil) Has

type WriterHandlerCurrentWriterIndexedByModelOverride

type WriterHandlerCurrentWriterIndexedByModelOverride map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByModelOverride) Has

type WriterHandlerCurrentWriterIndexedByName

type WriterHandlerCurrentWriterIndexedByName map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByName) Has

type WriterHandlerCurrentWriterIndexedByNextRunAt

type WriterHandlerCurrentWriterIndexedByNextRunAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByNextRunAt) Has

type WriterHandlerCurrentWriterIndexedByScheduleType

type WriterHandlerCurrentWriterIndexedByScheduleType map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByScheduleType) Has

type WriterHandlerCurrentWriterIndexedByStartAt

type WriterHandlerCurrentWriterIndexedByStartAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByStartAt) Has

type WriterHandlerCurrentWriterIndexedByTaskPrompt

type WriterHandlerCurrentWriterIndexedByTaskPrompt map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByTaskPrompt) Has

type WriterHandlerCurrentWriterIndexedByTaskPromptUri

type WriterHandlerCurrentWriterIndexedByTaskPromptUri map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByTaskPromptUri) Has

type WriterHandlerCurrentWriterIndexedByTimeoutSeconds

type WriterHandlerCurrentWriterIndexedByTimeoutSeconds map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByTimeoutSeconds) Has

type WriterHandlerCurrentWriterIndexedByTimezone

type WriterHandlerCurrentWriterIndexedByTimezone map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByTimezone) Has

type WriterHandlerCurrentWriterIndexedByUpdatedAt

type WriterHandlerCurrentWriterIndexedByUpdatedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByUpdatedAt) Has

type WriterHandlerCurrentWriterIndexedByUserCredUrl

type WriterHandlerCurrentWriterIndexedByUserCredUrl map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByUserCredUrl) Has

type WriterHandlerCurrentWriterIndexedByVisibility

type WriterHandlerCurrentWriterIndexedByVisibility map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByVisibility) Has

type WriterHandlerCurrentWriterSlice

type WriterHandlerCurrentWriterSlice []*CurrentWriterView

func (WriterHandlerCurrentWriterSlice) GroupByAgentRef

func (WriterHandlerCurrentWriterSlice) GroupByConversationId

func (WriterHandlerCurrentWriterSlice) GroupByCreatedAt

func (WriterHandlerCurrentWriterSlice) GroupByCreatedByUserId

func (WriterHandlerCurrentWriterSlice) GroupByCronExpr

func (WriterHandlerCurrentWriterSlice) GroupByDescription

func (WriterHandlerCurrentWriterSlice) GroupByEnabled

func (WriterHandlerCurrentWriterSlice) GroupByEndAt

func (WriterHandlerCurrentWriterSlice) GroupByGoalId

func (WriterHandlerCurrentWriterSlice) GroupById

func (WriterHandlerCurrentWriterSlice) GroupByInternal

func (WriterHandlerCurrentWriterSlice) GroupByIntervalSeconds

func (WriterHandlerCurrentWriterSlice) GroupByLastError

func (WriterHandlerCurrentWriterSlice) GroupByLastRunAt

func (WriterHandlerCurrentWriterSlice) GroupByLastStatus

func (WriterHandlerCurrentWriterSlice) GroupByLeaseOwner

func (WriterHandlerCurrentWriterSlice) GroupByLeaseUntil

func (WriterHandlerCurrentWriterSlice) GroupByModelOverride

func (WriterHandlerCurrentWriterSlice) GroupByName

func (WriterHandlerCurrentWriterSlice) GroupByNextRunAt

func (WriterHandlerCurrentWriterSlice) GroupByScheduleType

func (WriterHandlerCurrentWriterSlice) GroupByStartAt

func (WriterHandlerCurrentWriterSlice) GroupByTaskPrompt

func (WriterHandlerCurrentWriterSlice) GroupByTaskPromptUri

func (WriterHandlerCurrentWriterSlice) GroupByTimeoutSeconds

func (WriterHandlerCurrentWriterSlice) GroupByTimezone

func (WriterHandlerCurrentWriterSlice) GroupByUpdatedAt

func (WriterHandlerCurrentWriterSlice) GroupByUserCredUrl

func (WriterHandlerCurrentWriterSlice) GroupByVisibility

func (WriterHandlerCurrentWriterSlice) IndexByAgentRef

func (WriterHandlerCurrentWriterSlice) IndexByConversationId

func (WriterHandlerCurrentWriterSlice) IndexByCreatedAt

func (WriterHandlerCurrentWriterSlice) IndexByCreatedByUserId

func (WriterHandlerCurrentWriterSlice) IndexByCronExpr

func (WriterHandlerCurrentWriterSlice) IndexByDescription

func (WriterHandlerCurrentWriterSlice) IndexByEnabled

func (WriterHandlerCurrentWriterSlice) IndexByEndAt

func (WriterHandlerCurrentWriterSlice) IndexByGoalId

func (WriterHandlerCurrentWriterSlice) IndexById

func (WriterHandlerCurrentWriterSlice) IndexByInternal

func (WriterHandlerCurrentWriterSlice) IndexByIntervalSeconds

func (WriterHandlerCurrentWriterSlice) IndexByLastError

func (WriterHandlerCurrentWriterSlice) IndexByLastRunAt

func (WriterHandlerCurrentWriterSlice) IndexByLastStatus

func (WriterHandlerCurrentWriterSlice) IndexByLeaseOwner

func (WriterHandlerCurrentWriterSlice) IndexByLeaseUntil

func (WriterHandlerCurrentWriterSlice) IndexByModelOverride

func (WriterHandlerCurrentWriterSlice) IndexByName

func (WriterHandlerCurrentWriterSlice) IndexByNextRunAt

func (WriterHandlerCurrentWriterSlice) IndexByScheduleType

func (WriterHandlerCurrentWriterSlice) IndexByStartAt

func (WriterHandlerCurrentWriterSlice) IndexByTaskPrompt

func (WriterHandlerCurrentWriterSlice) IndexByTaskPromptUri

func (WriterHandlerCurrentWriterSlice) IndexByTimeoutSeconds

func (WriterHandlerCurrentWriterSlice) IndexByTimezone

func (WriterHandlerCurrentWriterSlice) IndexByUpdatedAt

func (WriterHandlerCurrentWriterSlice) IndexByUserCredUrl

func (WriterHandlerCurrentWriterSlice) IndexByVisibility

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"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL