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_generatedfile_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 WriterHandlerCurrentWriterIndexByChecksumKey 

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

func WriterHandlerCurrentWriterIndexByContainerIdKey 

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

func WriterHandlerCurrentWriterIndexByConversationIdKey 

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

func WriterHandlerCurrentWriterIndexByCopyModeKey 

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

func WriterHandlerCurrentWriterIndexByCreatedAtKey 

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

func WriterHandlerCurrentWriterIndexByErrorMessageKey 

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

func WriterHandlerCurrentWriterIndexByExpiresAtKey 

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

func WriterHandlerCurrentWriterIndexByFilenameKey 

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

func WriterHandlerCurrentWriterIndexByIdKey 

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

func WriterHandlerCurrentWriterIndexByMessageIdKey 

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

func WriterHandlerCurrentWriterIndexByMimeTypeKey 

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

func WriterHandlerCurrentWriterIndexByModeKey 

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

func WriterHandlerCurrentWriterIndexByPayloadIdKey 

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

func WriterHandlerCurrentWriterIndexByProviderFileIdKey 

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

func WriterHandlerCurrentWriterIndexByProviderKey 

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

func WriterHandlerCurrentWriterIndexBySizeBytesKey 

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

func WriterHandlerCurrentWriterIndexByStatusKey 

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

func WriterHandlerCurrentWriterIndexByTurnIdKey 

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

func WriterHandlerCurrentWriterIndexByUpdatedAtKey 

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

Types

type CurrentWriterView 

type CurrentWriterView struct {
	Id             string     `validate:"required" sqlx:"id,primaryKey" json:"id"`
	ConversationId string     "" /* 137-byte string literal not displayed */
	Provider       string     "validate:\"required\" json:\"provider\" sqlx:\"provider|`provider`,required=true\""
	Mode           string     "validate:\"required\" json:\"mode\" sqlx:\"mode|`mode`,required=true\""
	CopyMode       string     "validate:\"required\" json:\"copyMode\" sqlx:\"copy_mode|`copy_mode`,required=true\""
	Status         string     "validate:\"required\" json:\"status\" sqlx:\"status|`status`,required=true\""
	TurnId         *string    "sqlx:\"turn_id|`turn_id`\" json:\"turnId,omitempty\""
	MessageId      *string    "sqlx:\"message_id|`message_id`\" json:\"messageId,omitempty\""
	PayloadId      *string    "sqlx:\"payload_id|`payload_id`\" json:\"payloadId,omitempty\""
	ContainerId    *string    "sqlx:\"container_id|`container_id`\" json:\"containerId,omitempty\""
	ProviderFileId *string    "sqlx:\"provider_file_id|`provider_file_id`\" json:\"providerFileId,omitempty\""
	Filename       *string    "sqlx:\"filename|`filename`\" json:\"filename,omitempty\""
	MimeType       *string    "sqlx:\"mime_type|`mime_type`\" json:\"mimeType,omitempty\""
	SizeBytes      *int       "sqlx:\"size_bytes|`size_bytes`\" json:\"sizeBytes,omitempty\""
	Checksum       *string    "sqlx:\"checksum|`checksum`\" json:\"checksum,omitempty\""
	ErrorMessage   *string    "sqlx:\"error_message|`error_message`\" json:\"errorMessage,omitempty\""
	ExpiresAt      *time.Time "sqlx:\"expires_at|`expires_at`\" json:\"expiresAt,omitempty\""
	CreatedAt      *time.Time "sqlx:\"created_at|`created_at`,required=true\" json:\"createdAt,omitempty\""
	UpdatedAt      *time.Time "sqlx:\"updated_at|`updated_at`,required=true\" json:\"updatedAt,omitempty\""
}

CurrentWriterView is generated canonical view metadata for writer.

type GeneratedFile 

type GeneratedFile struct {
	ShouldDelete   bool              `sqlx:"-" writer:"delete" json:"shouldDelete,omitempty"`
	Id             string            `validate:"required" sqlx:"id,primaryKey" json:"id"`
	ConversationId string            "" /* 137-byte string literal not displayed */
	Provider       string            "validate:\"required\" json:\"provider\" sqlx:\"provider|`provider`,required=true\""
	Mode           string            "validate:\"required\" json:\"mode\" sqlx:\"mode|`mode`,required=true\""
	CopyMode       string            "validate:\"required\" json:\"copyMode\" sqlx:\"copy_mode|`copy_mode`,required=true\""
	Status         string            "validate:\"required\" json:\"status\" sqlx:\"status|`status`,required=true\""
	TurnId         *string           "sqlx:\"turn_id|`turn_id`\" json:\"turnId,omitempty\""
	MessageId      *string           "sqlx:\"message_id|`message_id`\" json:\"messageId,omitempty\""
	PayloadId      *string           "sqlx:\"payload_id|`payload_id`\" json:\"payloadId,omitempty\""
	ContainerId    *string           "sqlx:\"container_id|`container_id`\" json:\"containerId,omitempty\""
	ProviderFileId *string           "sqlx:\"provider_file_id|`provider_file_id`\" json:\"providerFileId,omitempty\""
	Filename       *string           "sqlx:\"filename|`filename`\" json:\"filename,omitempty\""
	MimeType       *string           "sqlx:\"mime_type|`mime_type`\" json:\"mimeType,omitempty\""
	SizeBytes      *int              "sqlx:\"size_bytes|`size_bytes`\" json:\"sizeBytes,omitempty\""
	Checksum       *string           "sqlx:\"checksum|`checksum`\" json:\"checksum,omitempty\""
	ErrorMessage   *string           "sqlx:\"error_message|`error_message`\" json:\"errorMessage,omitempty\""
	ExpiresAt      *time.Time        "sqlx:\"expires_at|`expires_at`\" json:\"expiresAt,omitempty\""
	CreatedAt      *time.Time        "sqlx:\"created_at|`created_at`,required=true\" json:\"createdAt,omitempty\""
	UpdatedAt      *time.Time        "sqlx:\"updated_at|`updated_at`,required=true\" json:\"updatedAt,omitempty\""
	Has            *GeneratedFileHas `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-" typeName:"GeneratedFileHas"`
}

GeneratedFile is generated canonical view metadata for writer.

func (*GeneratedFile) GetChecksum 

func (entity *GeneratedFile) GetChecksum() *string

func (*GeneratedFile) GetContainerId 

func (entity *GeneratedFile) GetContainerId() *string

func (*GeneratedFile) GetConversationId 

func (entity *GeneratedFile) GetConversationId() string

func (*GeneratedFile) GetCopyMode 

func (entity *GeneratedFile) GetCopyMode() string

func (*GeneratedFile) GetCreatedAt 

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

func (*GeneratedFile) GetErrorMessage 

func (entity *GeneratedFile) GetErrorMessage() *string

func (*GeneratedFile) GetExpiresAt 

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

func (*GeneratedFile) GetFilename 

func (entity *GeneratedFile) GetFilename() *string

func (*GeneratedFile) GetId 

func (entity *GeneratedFile) GetId() string

func (*GeneratedFile) GetMessageId 

func (entity *GeneratedFile) GetMessageId() *string

func (*GeneratedFile) GetMimeType 

func (entity *GeneratedFile) GetMimeType() *string

func (*GeneratedFile) GetMode 

func (entity *GeneratedFile) GetMode() string

func (*GeneratedFile) GetPayloadId 

func (entity *GeneratedFile) GetPayloadId() *string

func (*GeneratedFile) GetProvider 

func (entity *GeneratedFile) GetProvider() string

func (*GeneratedFile) GetProviderFileId 

func (entity *GeneratedFile) GetProviderFileId() *string

func (*GeneratedFile) GetShouldDelete 

func (entity *GeneratedFile) GetShouldDelete() bool

func (*GeneratedFile) GetSizeBytes 

func (entity *GeneratedFile) GetSizeBytes() *int

func (*GeneratedFile) GetStatus 

func (entity *GeneratedFile) GetStatus() string

func (*GeneratedFile) GetTurnId 

func (entity *GeneratedFile) GetTurnId() *string

func (*GeneratedFile) GetUpdatedAt 

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

func (*GeneratedFile) SetChecksum 

func (entity *GeneratedFile) SetChecksum(value *string)

func (*GeneratedFile) SetContainerId 

func (entity *GeneratedFile) SetContainerId(value *string)

func (*GeneratedFile) SetConversationId 

func (entity *GeneratedFile) SetConversationId(value string)

func (*GeneratedFile) SetCopyMode 

func (entity *GeneratedFile) SetCopyMode(value string)

func (*GeneratedFile) SetCreatedAt 

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

func (*GeneratedFile) SetErrorMessage 

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

func (*GeneratedFile) SetExpiresAt 

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

func (*GeneratedFile) SetFilename 

func (entity *GeneratedFile) SetFilename(value *string)

func (*GeneratedFile) SetId 

func (entity *GeneratedFile) SetId(value string)

func (*GeneratedFile) SetMessageId 

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

func (*GeneratedFile) SetMimeType 

func (entity *GeneratedFile) SetMimeType(value *string)

func (*GeneratedFile) SetMode 

func (entity *GeneratedFile) SetMode(value string)

func (*GeneratedFile) SetPayloadId 

func (entity *GeneratedFile) SetPayloadId(value *string)

func (*GeneratedFile) SetProvider 

func (entity *GeneratedFile) SetProvider(value string)

func (*GeneratedFile) SetProviderFileId 

func (entity *GeneratedFile) SetProviderFileId(value *string)

func (*GeneratedFile) SetShouldDelete 

func (entity *GeneratedFile) SetShouldDelete(value bool)

func (*GeneratedFile) SetSizeBytes 

func (entity *GeneratedFile) SetSizeBytes(value *int)

func (*GeneratedFile) SetStatus 

func (entity *GeneratedFile) SetStatus(value string)

func (*GeneratedFile) SetTurnId 

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

func (*GeneratedFile) SetUpdatedAt 

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

type GeneratedFileHas 

type GeneratedFileHas struct {
	ShouldDelete   bool
	Id             bool
	ConversationId bool
	Provider       bool
	Mode           bool
	CopyMode       bool
	Status         bool
	TurnId         bool
	MessageId      bool
	PayloadId      bool
	ContainerId    bool
	ProviderFileId bool
	Filename       bool
	MimeType       bool
	SizeBytes      bool
	Checksum       bool
	ErrorMessage   bool
	ExpiresAt      bool
	CreatedAt      bool
	UpdatedAt      bool
}

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"`
	GeneratedFiles []*GeneratedFile     `` /* 228-byte string literal not displayed */
	WriterKeys     []WriterKeysRow      `` /* 144-byte string literal not displayed */
	CurrentWriter  []*CurrentWriterView `` /* 177-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) SetGeneratedFiles 

func (input *Input) SetGeneratedFiles(value []*GeneratedFile)

func (*Input) SetOrphanColumn 

func (input *Input) SetOrphanColumn(value string)

func (*Input) SetOrphanDetach 

func (input *Input) SetOrphanDetach(value bool)

func (*Input) SetWriterKeys 

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

type InputHas 

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

type Lifecycle 

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

Lifecycle customizes role Input.GeneratedFiles.

func (*Lifecycle) AfterQueue 

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

func (*Lifecycle) AfterSequence 

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

func (*Lifecycle) Validate 

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

type Output 

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

Output is the generated output scaffold for writer.

type WriterComponent 

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

type WriterHandlerCurrentWriterGroupedByChecksum map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByChecksum) Has 

func (index WriterHandlerCurrentWriterGroupedByChecksum) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByContainerId 

type WriterHandlerCurrentWriterGroupedByContainerId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByContainerId) Has 

func (index WriterHandlerCurrentWriterGroupedByContainerId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByConversationId 

type WriterHandlerCurrentWriterGroupedByConversationId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByConversationId) Has 

func (index WriterHandlerCurrentWriterGroupedByConversationId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByCopyMode 

type WriterHandlerCurrentWriterGroupedByCopyMode map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByCopyMode) Has 

func (index WriterHandlerCurrentWriterGroupedByCopyMode) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByCreatedAt 

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

func (WriterHandlerCurrentWriterGroupedByCreatedAt) Has 

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

type WriterHandlerCurrentWriterGroupedByErrorMessage 

type WriterHandlerCurrentWriterGroupedByErrorMessage map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByErrorMessage) Has 

func (index WriterHandlerCurrentWriterGroupedByErrorMessage) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByExpiresAt 

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

func (WriterHandlerCurrentWriterGroupedByExpiresAt) Has 

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

type WriterHandlerCurrentWriterGroupedByFilename 

type WriterHandlerCurrentWriterGroupedByFilename map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByFilename) Has 

func (index WriterHandlerCurrentWriterGroupedByFilename) Has(key string) 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 WriterHandlerCurrentWriterGroupedByMimeType 

type WriterHandlerCurrentWriterGroupedByMimeType map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByMimeType) Has 

func (index WriterHandlerCurrentWriterGroupedByMimeType) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByMode 

type WriterHandlerCurrentWriterGroupedByMode map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByMode) Has 

func (index WriterHandlerCurrentWriterGroupedByMode) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByPayloadId 

type WriterHandlerCurrentWriterGroupedByPayloadId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByPayloadId) Has 

func (index WriterHandlerCurrentWriterGroupedByPayloadId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByProvider 

type WriterHandlerCurrentWriterGroupedByProvider map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProvider) Has 

func (index WriterHandlerCurrentWriterGroupedByProvider) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByProviderFileId 

type WriterHandlerCurrentWriterGroupedByProviderFileId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProviderFileId) Has 

func (index WriterHandlerCurrentWriterGroupedByProviderFileId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedBySizeBytes 

type WriterHandlerCurrentWriterGroupedBySizeBytes map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedBySizeBytes) Has 

func (index WriterHandlerCurrentWriterGroupedBySizeBytes) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByStatus 

type WriterHandlerCurrentWriterGroupedByStatus map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByStatus) Has 

func (index WriterHandlerCurrentWriterGroupedByStatus) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByTurnId 

type WriterHandlerCurrentWriterGroupedByTurnId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByTurnId) Has 

func (index WriterHandlerCurrentWriterGroupedByTurnId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByUpdatedAt 

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

func (WriterHandlerCurrentWriterGroupedByUpdatedAt) Has 

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

type WriterHandlerCurrentWriterIndexedByChecksum 

type WriterHandlerCurrentWriterIndexedByChecksum map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByChecksum) Has 

func (index WriterHandlerCurrentWriterIndexedByChecksum) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByContainerId 

type WriterHandlerCurrentWriterIndexedByContainerId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByContainerId) Has 

func (index WriterHandlerCurrentWriterIndexedByContainerId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByConversationId 

type WriterHandlerCurrentWriterIndexedByConversationId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByConversationId) Has 

func (index WriterHandlerCurrentWriterIndexedByConversationId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByCopyMode 

type WriterHandlerCurrentWriterIndexedByCopyMode map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCopyMode) Has 

func (index WriterHandlerCurrentWriterIndexedByCopyMode) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByCreatedAt 

type WriterHandlerCurrentWriterIndexedByCreatedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCreatedAt) Has 

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

type WriterHandlerCurrentWriterIndexedByErrorMessage 

type WriterHandlerCurrentWriterIndexedByErrorMessage map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByErrorMessage) Has 

func (index WriterHandlerCurrentWriterIndexedByErrorMessage) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByExpiresAt 

type WriterHandlerCurrentWriterIndexedByExpiresAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByExpiresAt) Has 

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

type WriterHandlerCurrentWriterIndexedByFilename 

type WriterHandlerCurrentWriterIndexedByFilename map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByFilename) Has 

func (index WriterHandlerCurrentWriterIndexedByFilename) Has(key string) 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 WriterHandlerCurrentWriterIndexedByMimeType 

type WriterHandlerCurrentWriterIndexedByMimeType map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByMimeType) Has 

func (index WriterHandlerCurrentWriterIndexedByMimeType) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByMode 

type WriterHandlerCurrentWriterIndexedByMode map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByMode) Has 

func (index WriterHandlerCurrentWriterIndexedByMode) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByPayloadId 

type WriterHandlerCurrentWriterIndexedByPayloadId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByPayloadId) Has 

func (index WriterHandlerCurrentWriterIndexedByPayloadId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByProvider 

type WriterHandlerCurrentWriterIndexedByProvider map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProvider) Has 

func (index WriterHandlerCurrentWriterIndexedByProvider) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByProviderFileId 

type WriterHandlerCurrentWriterIndexedByProviderFileId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProviderFileId) Has 

func (index WriterHandlerCurrentWriterIndexedByProviderFileId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedBySizeBytes 

type WriterHandlerCurrentWriterIndexedBySizeBytes map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedBySizeBytes) Has 

func (index WriterHandlerCurrentWriterIndexedBySizeBytes) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByStatus 

type WriterHandlerCurrentWriterIndexedByStatus map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByStatus) Has 

func (index WriterHandlerCurrentWriterIndexedByStatus) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByTurnId 

type WriterHandlerCurrentWriterIndexedByTurnId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByTurnId) Has 

func (index WriterHandlerCurrentWriterIndexedByTurnId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByUpdatedAt 

type WriterHandlerCurrentWriterIndexedByUpdatedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByUpdatedAt) Has 

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

type WriterHandlerCurrentWriterSlice 

type WriterHandlerCurrentWriterSlice []*CurrentWriterView

func (WriterHandlerCurrentWriterSlice) GroupByChecksum 

func (rows WriterHandlerCurrentWriterSlice) GroupByChecksum() WriterHandlerCurrentWriterGroupedByChecksum

func (WriterHandlerCurrentWriterSlice) GroupByContainerId 

func (rows WriterHandlerCurrentWriterSlice) GroupByContainerId() WriterHandlerCurrentWriterGroupedByContainerId

func (WriterHandlerCurrentWriterSlice) GroupByConversationId 

func (rows WriterHandlerCurrentWriterSlice) GroupByConversationId() WriterHandlerCurrentWriterGroupedByConversationId

func (WriterHandlerCurrentWriterSlice) GroupByCopyMode 

func (rows WriterHandlerCurrentWriterSlice) GroupByCopyMode() WriterHandlerCurrentWriterGroupedByCopyMode

func (WriterHandlerCurrentWriterSlice) GroupByCreatedAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByCreatedAt() WriterHandlerCurrentWriterGroupedByCreatedAt

func (WriterHandlerCurrentWriterSlice) GroupByErrorMessage 

func (rows WriterHandlerCurrentWriterSlice) GroupByErrorMessage() WriterHandlerCurrentWriterGroupedByErrorMessage

func (WriterHandlerCurrentWriterSlice) GroupByExpiresAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByExpiresAt() WriterHandlerCurrentWriterGroupedByExpiresAt

func (WriterHandlerCurrentWriterSlice) GroupByFilename 

func (rows WriterHandlerCurrentWriterSlice) GroupByFilename() WriterHandlerCurrentWriterGroupedByFilename

func (WriterHandlerCurrentWriterSlice) GroupById 

func (rows WriterHandlerCurrentWriterSlice) GroupById() WriterHandlerCurrentWriterGroupedById

func (WriterHandlerCurrentWriterSlice) GroupByMessageId 

func (rows WriterHandlerCurrentWriterSlice) GroupByMessageId() WriterHandlerCurrentWriterGroupedByMessageId

func (WriterHandlerCurrentWriterSlice) GroupByMimeType 

func (rows WriterHandlerCurrentWriterSlice) GroupByMimeType() WriterHandlerCurrentWriterGroupedByMimeType

func (WriterHandlerCurrentWriterSlice) GroupByMode 

func (rows WriterHandlerCurrentWriterSlice) GroupByMode() WriterHandlerCurrentWriterGroupedByMode

func (WriterHandlerCurrentWriterSlice) GroupByPayloadId 

func (rows WriterHandlerCurrentWriterSlice) GroupByPayloadId() WriterHandlerCurrentWriterGroupedByPayloadId

func (WriterHandlerCurrentWriterSlice) GroupByProvider 

func (rows WriterHandlerCurrentWriterSlice) GroupByProvider() WriterHandlerCurrentWriterGroupedByProvider

func (WriterHandlerCurrentWriterSlice) GroupByProviderFileId 

func (rows WriterHandlerCurrentWriterSlice) GroupByProviderFileId() WriterHandlerCurrentWriterGroupedByProviderFileId

func (WriterHandlerCurrentWriterSlice) GroupBySizeBytes 

func (rows WriterHandlerCurrentWriterSlice) GroupBySizeBytes() WriterHandlerCurrentWriterGroupedBySizeBytes

func (WriterHandlerCurrentWriterSlice) GroupByStatus 

func (rows WriterHandlerCurrentWriterSlice) GroupByStatus() WriterHandlerCurrentWriterGroupedByStatus

func (WriterHandlerCurrentWriterSlice) GroupByTurnId 

func (rows WriterHandlerCurrentWriterSlice) GroupByTurnId() WriterHandlerCurrentWriterGroupedByTurnId

func (WriterHandlerCurrentWriterSlice) GroupByUpdatedAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByUpdatedAt() WriterHandlerCurrentWriterGroupedByUpdatedAt

func (WriterHandlerCurrentWriterSlice) IndexByChecksum 

func (rows WriterHandlerCurrentWriterSlice) IndexByChecksum() (WriterHandlerCurrentWriterIndexedByChecksum, error)

func (WriterHandlerCurrentWriterSlice) IndexByContainerId 

func (rows WriterHandlerCurrentWriterSlice) IndexByContainerId() (WriterHandlerCurrentWriterIndexedByContainerId, error)

func (WriterHandlerCurrentWriterSlice) IndexByConversationId 

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

func (WriterHandlerCurrentWriterSlice) IndexByCopyMode 

func (rows WriterHandlerCurrentWriterSlice) IndexByCopyMode() (WriterHandlerCurrentWriterIndexedByCopyMode, error)

func (WriterHandlerCurrentWriterSlice) IndexByCreatedAt 

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

func (WriterHandlerCurrentWriterSlice) IndexByErrorMessage 

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

func (WriterHandlerCurrentWriterSlice) IndexByExpiresAt 

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

func (WriterHandlerCurrentWriterSlice) IndexByFilename 

func (rows WriterHandlerCurrentWriterSlice) IndexByFilename() (WriterHandlerCurrentWriterIndexedByFilename, error)

func (WriterHandlerCurrentWriterSlice) IndexById 

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

func (WriterHandlerCurrentWriterSlice) IndexByMessageId 

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

func (WriterHandlerCurrentWriterSlice) IndexByMimeType 

func (rows WriterHandlerCurrentWriterSlice) IndexByMimeType() (WriterHandlerCurrentWriterIndexedByMimeType, error)

func (WriterHandlerCurrentWriterSlice) IndexByMode 

func (rows WriterHandlerCurrentWriterSlice) IndexByMode() (WriterHandlerCurrentWriterIndexedByMode, error)

func (WriterHandlerCurrentWriterSlice) IndexByPayloadId 

func (rows WriterHandlerCurrentWriterSlice) IndexByPayloadId() (WriterHandlerCurrentWriterIndexedByPayloadId, error)

func (WriterHandlerCurrentWriterSlice) IndexByProvider 

func (rows WriterHandlerCurrentWriterSlice) IndexByProvider() (WriterHandlerCurrentWriterIndexedByProvider, error)

func (WriterHandlerCurrentWriterSlice) IndexByProviderFileId 

func (rows WriterHandlerCurrentWriterSlice) IndexByProviderFileId() (WriterHandlerCurrentWriterIndexedByProviderFileId, error)

func (WriterHandlerCurrentWriterSlice) IndexBySizeBytes 

func (rows WriterHandlerCurrentWriterSlice) IndexBySizeBytes() (WriterHandlerCurrentWriterIndexedBySizeBytes, error)

func (WriterHandlerCurrentWriterSlice) IndexByStatus 

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

func (WriterHandlerCurrentWriterSlice) IndexByTurnId 

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

func (WriterHandlerCurrentWriterSlice) IndexByUpdatedAt 

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

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.