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

Documentation

Index

Constants

View Source 
const WriterDatlyResourceNamespace = "datly_payload_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 WriterHandlerCurrentWriterIndexByCompressionKey 

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

func WriterHandlerCurrentWriterIndexByCreatedAtKey 

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

func WriterHandlerCurrentWriterIndexByDigestKey 

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

func WriterHandlerCurrentWriterIndexByEncryptionKmsKeyIdKey 

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

func WriterHandlerCurrentWriterIndexByIdKey 

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

func WriterHandlerCurrentWriterIndexByKindKey 

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

func WriterHandlerCurrentWriterIndexByMimeTypeKey 

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

func WriterHandlerCurrentWriterIndexByRedactedKey 

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

func WriterHandlerCurrentWriterIndexByRedactionPolicyVersionKey 

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

func WriterHandlerCurrentWriterIndexByRunIdKey 

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

func WriterHandlerCurrentWriterIndexBySchemaRefKey 

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

func WriterHandlerCurrentWriterIndexBySequenceKey 

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

func WriterHandlerCurrentWriterIndexBySizeBytesKey 

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

func WriterHandlerCurrentWriterIndexByStorageKey 

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

func WriterHandlerCurrentWriterIndexBySubtypeKey 

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

func WriterHandlerCurrentWriterIndexByTenantIdKey 

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

func WriterHandlerCurrentWriterIndexByUriKey 

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

Types

type CurrentWriterView 

type CurrentWriterView struct {
	Id                     string     `validate:"required" sqlx:"id,primaryKey" json:"id"`
	Kind                   string     `validate:"required" json:"kind" sqlx:"kind,required=true"`
	MimeType               string     `validate:"required" json:"mimeType" sqlx:"mime_type,required=true"`
	SizeBytes              int        `validate:"required" json:"sizeBytes" sqlx:"size_bytes,required=true"`
	Storage                string     `validate:"required" json:"storage" sqlx:"storage,required=true"`
	InlineBody             *[]byte    `sqlx:"inline_body" json:"inlineBody,omitempty"`
	Compression            string     `json:"compression" sqlx:"compression,required=true"`
	TenantId               *string    `sqlx:"tenant_id" json:"tenantId,omitempty"`
	Subtype                *string    `sqlx:"subtype" json:"subtype,omitempty"`
	Digest                 *string    `sqlx:"digest" json:"digest,omitempty"`
	Uri                    *string    `sqlx:"uri" json:"uri,omitempty"`
	EncryptionKmsKeyId     *string    `sqlx:"encryption_kms_key_id" json:"encryptionKmsKeyId,omitempty"`
	RedactionPolicyVersion *string    `sqlx:"redaction_policy_version" json:"redactionPolicyVersion,omitempty"`
	Redacted               *int       `sqlx:"redacted,required=true" json:"redacted,omitempty"`
	CreatedAt              *time.Time `sqlx:"created_at,required=true" json:"createdAt,omitempty"`
	SchemaRef              *string    `sqlx:"schema_ref" json:"schemaRef,omitempty"`
	RunId                  *string    `sqlx:"run_id,refTable=run,refColumn=id" json:"runId,omitempty"`
	Sequence               *int       `sqlx:"sequence" json:"sequence,omitempty"`
}

CurrentWriterView is generated canonical view metadata for writer.

type Input 

type Input struct {
	DeleteUnreferenced bool                 `` /* 1069-byte string literal not displayed */
	Payloads           []*Payload           `` /* 222-byte string literal not displayed */
	WriterKeys         []WriterKeysRow      `` /* 132-byte string literal not displayed */
	CurrentWriter      []*CurrentWriterView `` /* 169-byte string literal not displayed */

	Has *InputHas `setMarker:"true" typeName:"InputHas" json:"-" sqlx:"-"`
	// contains filtered or unexported fields
}

Input is the generated input scaffold for writer.

func (*Input) Init 

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

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

func (input *Input) SetDeleteUnreferenced(value bool)

func (*Input) SetPayloads 

func (input *Input) SetPayloads(value []*Payload)

func (*Input) SetWriterKeys 

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

type InputHas 

type InputHas struct {
	DeleteUnreferenced bool
	Payloads           bool
	WriterKeys         bool
	CurrentWriter      bool
}

type Lifecycle 

type Lifecycle struct{}

Lifecycle customizes role Input.Payloads.

func (*Lifecycle) AfterQueue 

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

func (*Lifecycle) AfterSequence 

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

func (*Lifecycle) Validate 

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

type Output 

type Output struct {
	response.Status `parameter:",kind=output,in=status"`
	Data            []*Payload `parameter:"Data,kind=output,in=body,dataType=[]*Payload" json:"data,omitempty"`
}

Output is the generated output scaffold for writer.

type Payload 

type Payload struct {
	ShouldDelete           bool        `sqlx:"-" writer:"delete" json:"shouldDelete,omitempty"`
	Id                     string      `validate:"required" sqlx:"id,primaryKey" json:"id"`
	Kind                   string      `validate:"required" json:"kind" sqlx:"kind,required=true"`
	MimeType               string      `validate:"required" json:"mimeType" sqlx:"mime_type,required=true"`
	SizeBytes              int         `validate:"required" json:"sizeBytes" sqlx:"size_bytes,required=true"`
	Storage                string      `validate:"required" json:"storage" sqlx:"storage,required=true"`
	InlineBody             *[]byte     `sqlx:"inline_body" json:"inlineBody,omitempty"`
	Compression            string      `json:"compression" sqlx:"compression,required=true"`
	TenantId               *string     `sqlx:"tenant_id" json:"tenantId,omitempty"`
	Subtype                *string     `sqlx:"subtype" json:"subtype,omitempty"`
	Digest                 *string     `sqlx:"digest" json:"digest,omitempty"`
	Uri                    *string     `sqlx:"uri" json:"uri,omitempty"`
	EncryptionKmsKeyId     *string     `sqlx:"encryption_kms_key_id" json:"encryptionKmsKeyId,omitempty"`
	RedactionPolicyVersion *string     `sqlx:"redaction_policy_version" json:"redactionPolicyVersion,omitempty"`
	Redacted               *int        `sqlx:"redacted,required=true" json:"redacted,omitempty"`
	CreatedAt              *time.Time  `sqlx:"created_at,required=true" json:"createdAt,omitempty"`
	SchemaRef              *string     `sqlx:"schema_ref" json:"schemaRef,omitempty"`
	RunId                  *string     `sqlx:"run_id,refTable=run,refColumn=id" json:"runId,omitempty"`
	Sequence               *int        `sqlx:"sequence" json:"sequence,omitempty"`
	Has                    *PayloadHas `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-" typeName:"PayloadHas"`
}

Payload is generated canonical view metadata for writer.

func (*Payload) GetCompression 

func (entity *Payload) GetCompression() string

func (*Payload) GetCreatedAt 

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

func (*Payload) GetDigest 

func (entity *Payload) GetDigest() *string

func (*Payload) GetEncryptionKmsKeyId 

func (entity *Payload) GetEncryptionKmsKeyId() *string

func (*Payload) GetId 

func (entity *Payload) GetId() string

func (*Payload) GetInlineBody 

func (entity *Payload) GetInlineBody() *[]byte

func (*Payload) GetKind 

func (entity *Payload) GetKind() string

func (*Payload) GetMimeType 

func (entity *Payload) GetMimeType() string

func (*Payload) GetRedacted 

func (entity *Payload) GetRedacted() *int

func (*Payload) GetRedactionPolicyVersion 

func (entity *Payload) GetRedactionPolicyVersion() *string

func (*Payload) GetRunId 

func (entity *Payload) GetRunId() *string

func (*Payload) GetSchemaRef 

func (entity *Payload) GetSchemaRef() *string

func (*Payload) GetSequence 

func (entity *Payload) GetSequence() *int

func (*Payload) GetShouldDelete 

func (entity *Payload) GetShouldDelete() bool

func (*Payload) GetSizeBytes 

func (entity *Payload) GetSizeBytes() int

func (*Payload) GetStorage 

func (entity *Payload) GetStorage() string

func (*Payload) GetSubtype 

func (entity *Payload) GetSubtype() *string

func (*Payload) GetTenantId 

func (entity *Payload) GetTenantId() *string

func (*Payload) GetUri 

func (entity *Payload) GetUri() *string

func (*Payload) SetCompression 

func (entity *Payload) SetCompression(value string)

func (*Payload) SetCreatedAt 

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

func (*Payload) SetDigest 

func (entity *Payload) SetDigest(value *string)

func (*Payload) SetEncryptionKmsKeyId 

func (entity *Payload) SetEncryptionKmsKeyId(value *string)

func (*Payload) SetId 

func (entity *Payload) SetId(value string)

func (*Payload) SetInlineBody 

func (entity *Payload) SetInlineBody(value *[]byte)

func (*Payload) SetKind 

func (entity *Payload) SetKind(value string)

func (*Payload) SetMimeType 

func (entity *Payload) SetMimeType(value string)

func (*Payload) SetRedacted 

func (entity *Payload) SetRedacted(value *int)

func (*Payload) SetRedactionPolicyVersion 

func (entity *Payload) SetRedactionPolicyVersion(value *string)

func (*Payload) SetRunId 

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

func (*Payload) SetSchemaRef 

func (entity *Payload) SetSchemaRef(value *string)

func (*Payload) SetSequence 

func (entity *Payload) SetSequence(value *int)

func (*Payload) SetShouldDelete 

func (entity *Payload) SetShouldDelete(value bool)

func (*Payload) SetSizeBytes 

func (entity *Payload) SetSizeBytes(value int)

func (*Payload) SetStorage 

func (entity *Payload) SetStorage(value string)

func (*Payload) SetSubtype 

func (entity *Payload) SetSubtype(value *string)

func (*Payload) SetTenantId 

func (entity *Payload) SetTenantId(value *string)

func (*Payload) SetUri 

func (entity *Payload) SetUri(value *string)

type PayloadHas 

type PayloadHas struct {
	ShouldDelete           bool
	Id                     bool
	Kind                   bool
	MimeType               bool
	SizeBytes              bool
	Storage                bool
	InlineBody             bool
	Compression            bool
	TenantId               bool
	Subtype                bool
	Digest                 bool
	Uri                    bool
	EncryptionKmsKeyId     bool
	RedactionPolicyVersion bool
	Redacted               bool
	CreatedAt              bool
	SchemaRef              bool
	RunId                  bool
	Sequence               bool
}

type WriterComponent 

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

type WriterHandlerCurrentWriterGroupedByCompression map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByCompression) Has 

func (index WriterHandlerCurrentWriterGroupedByCompression) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByCreatedAt 

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

func (WriterHandlerCurrentWriterGroupedByCreatedAt) Has 

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

type WriterHandlerCurrentWriterGroupedByDigest 

type WriterHandlerCurrentWriterGroupedByDigest map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByDigest) Has 

func (index WriterHandlerCurrentWriterGroupedByDigest) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByEncryptionKmsKeyId 

type WriterHandlerCurrentWriterGroupedByEncryptionKmsKeyId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByEncryptionKmsKeyId) Has 

func (index WriterHandlerCurrentWriterGroupedByEncryptionKmsKeyId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedById 

type WriterHandlerCurrentWriterGroupedById map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedById) Has 

func (index WriterHandlerCurrentWriterGroupedById) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByKind 

type WriterHandlerCurrentWriterGroupedByKind map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByKind) Has 

func (index WriterHandlerCurrentWriterGroupedByKind) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByMimeType 

type WriterHandlerCurrentWriterGroupedByMimeType map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByMimeType) Has 

func (index WriterHandlerCurrentWriterGroupedByMimeType) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByRedacted 

type WriterHandlerCurrentWriterGroupedByRedacted map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByRedacted) Has 

func (index WriterHandlerCurrentWriterGroupedByRedacted) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByRedactionPolicyVersion 

type WriterHandlerCurrentWriterGroupedByRedactionPolicyVersion map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByRedactionPolicyVersion) Has 

func (index WriterHandlerCurrentWriterGroupedByRedactionPolicyVersion) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByRunId 

type WriterHandlerCurrentWriterGroupedByRunId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByRunId) Has 

func (index WriterHandlerCurrentWriterGroupedByRunId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedBySchemaRef 

type WriterHandlerCurrentWriterGroupedBySchemaRef map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedBySchemaRef) Has 

func (index WriterHandlerCurrentWriterGroupedBySchemaRef) Has(key string) bool

type WriterHandlerCurrentWriterGroupedBySequence 

type WriterHandlerCurrentWriterGroupedBySequence map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedBySequence) Has 

func (index WriterHandlerCurrentWriterGroupedBySequence) Has(key int) bool

type WriterHandlerCurrentWriterGroupedBySizeBytes 

type WriterHandlerCurrentWriterGroupedBySizeBytes map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedBySizeBytes) Has 

func (index WriterHandlerCurrentWriterGroupedBySizeBytes) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByStorage 

type WriterHandlerCurrentWriterGroupedByStorage map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByStorage) Has 

func (index WriterHandlerCurrentWriterGroupedByStorage) Has(key string) bool

type WriterHandlerCurrentWriterGroupedBySubtype 

type WriterHandlerCurrentWriterGroupedBySubtype map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedBySubtype) Has 

func (index WriterHandlerCurrentWriterGroupedBySubtype) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByTenantId 

type WriterHandlerCurrentWriterGroupedByTenantId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByTenantId) Has 

func (index WriterHandlerCurrentWriterGroupedByTenantId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByUri 

type WriterHandlerCurrentWriterGroupedByUri map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByUri) Has 

func (index WriterHandlerCurrentWriterGroupedByUri) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByCompression 

type WriterHandlerCurrentWriterIndexedByCompression map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCompression) Has 

func (index WriterHandlerCurrentWriterIndexedByCompression) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByCreatedAt 

type WriterHandlerCurrentWriterIndexedByCreatedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCreatedAt) Has 

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

type WriterHandlerCurrentWriterIndexedByDigest 

type WriterHandlerCurrentWriterIndexedByDigest map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByDigest) Has 

func (index WriterHandlerCurrentWriterIndexedByDigest) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByEncryptionKmsKeyId 

type WriterHandlerCurrentWriterIndexedByEncryptionKmsKeyId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByEncryptionKmsKeyId) Has 

func (index WriterHandlerCurrentWriterIndexedByEncryptionKmsKeyId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedById 

type WriterHandlerCurrentWriterIndexedById map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedById) Has 

func (index WriterHandlerCurrentWriterIndexedById) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByKind 

type WriterHandlerCurrentWriterIndexedByKind map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByKind) Has 

func (index WriterHandlerCurrentWriterIndexedByKind) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByMimeType 

type WriterHandlerCurrentWriterIndexedByMimeType map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByMimeType) Has 

func (index WriterHandlerCurrentWriterIndexedByMimeType) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByRedacted 

type WriterHandlerCurrentWriterIndexedByRedacted map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByRedacted) Has 

func (index WriterHandlerCurrentWriterIndexedByRedacted) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByRedactionPolicyVersion 

type WriterHandlerCurrentWriterIndexedByRedactionPolicyVersion map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByRedactionPolicyVersion) Has 

func (index WriterHandlerCurrentWriterIndexedByRedactionPolicyVersion) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByRunId 

type WriterHandlerCurrentWriterIndexedByRunId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByRunId) Has 

func (index WriterHandlerCurrentWriterIndexedByRunId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedBySchemaRef 

type WriterHandlerCurrentWriterIndexedBySchemaRef map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedBySchemaRef) Has 

func (index WriterHandlerCurrentWriterIndexedBySchemaRef) Has(key string) bool

type WriterHandlerCurrentWriterIndexedBySequence 

type WriterHandlerCurrentWriterIndexedBySequence map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedBySequence) Has 

func (index WriterHandlerCurrentWriterIndexedBySequence) Has(key int) bool

type WriterHandlerCurrentWriterIndexedBySizeBytes 

type WriterHandlerCurrentWriterIndexedBySizeBytes map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedBySizeBytes) Has 

func (index WriterHandlerCurrentWriterIndexedBySizeBytes) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByStorage 

type WriterHandlerCurrentWriterIndexedByStorage map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByStorage) Has 

func (index WriterHandlerCurrentWriterIndexedByStorage) Has(key string) bool

type WriterHandlerCurrentWriterIndexedBySubtype 

type WriterHandlerCurrentWriterIndexedBySubtype map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedBySubtype) Has 

func (index WriterHandlerCurrentWriterIndexedBySubtype) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByTenantId 

type WriterHandlerCurrentWriterIndexedByTenantId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByTenantId) Has 

func (index WriterHandlerCurrentWriterIndexedByTenantId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByUri 

type WriterHandlerCurrentWriterIndexedByUri map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByUri) Has 

func (index WriterHandlerCurrentWriterIndexedByUri) Has(key string) bool

type WriterHandlerCurrentWriterSlice 

type WriterHandlerCurrentWriterSlice []*CurrentWriterView

func (WriterHandlerCurrentWriterSlice) GroupByCompression 

func (rows WriterHandlerCurrentWriterSlice) GroupByCompression() WriterHandlerCurrentWriterGroupedByCompression

func (WriterHandlerCurrentWriterSlice) GroupByCreatedAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByCreatedAt() WriterHandlerCurrentWriterGroupedByCreatedAt

func (WriterHandlerCurrentWriterSlice) GroupByDigest 

func (rows WriterHandlerCurrentWriterSlice) GroupByDigest() WriterHandlerCurrentWriterGroupedByDigest

func (WriterHandlerCurrentWriterSlice) GroupByEncryptionKmsKeyId 

func (rows WriterHandlerCurrentWriterSlice) GroupByEncryptionKmsKeyId() WriterHandlerCurrentWriterGroupedByEncryptionKmsKeyId

func (WriterHandlerCurrentWriterSlice) GroupById 

func (rows WriterHandlerCurrentWriterSlice) GroupById() WriterHandlerCurrentWriterGroupedById

func (WriterHandlerCurrentWriterSlice) GroupByKind 

func (rows WriterHandlerCurrentWriterSlice) GroupByKind() WriterHandlerCurrentWriterGroupedByKind

func (WriterHandlerCurrentWriterSlice) GroupByMimeType 

func (rows WriterHandlerCurrentWriterSlice) GroupByMimeType() WriterHandlerCurrentWriterGroupedByMimeType

func (WriterHandlerCurrentWriterSlice) GroupByRedacted 

func (rows WriterHandlerCurrentWriterSlice) GroupByRedacted() WriterHandlerCurrentWriterGroupedByRedacted

func (WriterHandlerCurrentWriterSlice) GroupByRedactionPolicyVersion 

func (rows WriterHandlerCurrentWriterSlice) GroupByRedactionPolicyVersion() WriterHandlerCurrentWriterGroupedByRedactionPolicyVersion

func (WriterHandlerCurrentWriterSlice) GroupByRunId 

func (rows WriterHandlerCurrentWriterSlice) GroupByRunId() WriterHandlerCurrentWriterGroupedByRunId

func (WriterHandlerCurrentWriterSlice) GroupBySchemaRef 

func (rows WriterHandlerCurrentWriterSlice) GroupBySchemaRef() WriterHandlerCurrentWriterGroupedBySchemaRef

func (WriterHandlerCurrentWriterSlice) GroupBySequence 

func (rows WriterHandlerCurrentWriterSlice) GroupBySequence() WriterHandlerCurrentWriterGroupedBySequence

func (WriterHandlerCurrentWriterSlice) GroupBySizeBytes 

func (rows WriterHandlerCurrentWriterSlice) GroupBySizeBytes() WriterHandlerCurrentWriterGroupedBySizeBytes

func (WriterHandlerCurrentWriterSlice) GroupByStorage 

func (rows WriterHandlerCurrentWriterSlice) GroupByStorage() WriterHandlerCurrentWriterGroupedByStorage

func (WriterHandlerCurrentWriterSlice) GroupBySubtype 

func (rows WriterHandlerCurrentWriterSlice) GroupBySubtype() WriterHandlerCurrentWriterGroupedBySubtype

func (WriterHandlerCurrentWriterSlice) GroupByTenantId 

func (rows WriterHandlerCurrentWriterSlice) GroupByTenantId() WriterHandlerCurrentWriterGroupedByTenantId

func (WriterHandlerCurrentWriterSlice) GroupByUri 

func (rows WriterHandlerCurrentWriterSlice) GroupByUri() WriterHandlerCurrentWriterGroupedByUri

func (WriterHandlerCurrentWriterSlice) IndexByCompression 

func (rows WriterHandlerCurrentWriterSlice) IndexByCompression() (WriterHandlerCurrentWriterIndexedByCompression, error)

func (WriterHandlerCurrentWriterSlice) IndexByCreatedAt 

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

func (WriterHandlerCurrentWriterSlice) IndexByDigest 

func (rows WriterHandlerCurrentWriterSlice) IndexByDigest() (WriterHandlerCurrentWriterIndexedByDigest, error)

func (WriterHandlerCurrentWriterSlice) IndexByEncryptionKmsKeyId 

func (rows WriterHandlerCurrentWriterSlice) IndexByEncryptionKmsKeyId() (WriterHandlerCurrentWriterIndexedByEncryptionKmsKeyId, error)

func (WriterHandlerCurrentWriterSlice) IndexById 

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

func (WriterHandlerCurrentWriterSlice) IndexByKind 

func (rows WriterHandlerCurrentWriterSlice) IndexByKind() (WriterHandlerCurrentWriterIndexedByKind, error)

func (WriterHandlerCurrentWriterSlice) IndexByMimeType 

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

func (WriterHandlerCurrentWriterSlice) IndexByRedacted 

func (rows WriterHandlerCurrentWriterSlice) IndexByRedacted() (WriterHandlerCurrentWriterIndexedByRedacted, error)

func (WriterHandlerCurrentWriterSlice) IndexByRedactionPolicyVersion 

func (rows WriterHandlerCurrentWriterSlice) IndexByRedactionPolicyVersion() (WriterHandlerCurrentWriterIndexedByRedactionPolicyVersion, error)

func (WriterHandlerCurrentWriterSlice) IndexByRunId 

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

func (WriterHandlerCurrentWriterSlice) IndexBySchemaRef 

func (rows WriterHandlerCurrentWriterSlice) IndexBySchemaRef() (WriterHandlerCurrentWriterIndexedBySchemaRef, error)

func (WriterHandlerCurrentWriterSlice) IndexBySequence 

func (rows WriterHandlerCurrentWriterSlice) IndexBySequence() (WriterHandlerCurrentWriterIndexedBySequence, error)

func (WriterHandlerCurrentWriterSlice) IndexBySizeBytes 

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

func (WriterHandlerCurrentWriterSlice) IndexByStorage 

func (rows WriterHandlerCurrentWriterSlice) IndexByStorage() (WriterHandlerCurrentWriterIndexedByStorage, error)

func (WriterHandlerCurrentWriterSlice) IndexBySubtype 

func (rows WriterHandlerCurrentWriterSlice) IndexBySubtype() (WriterHandlerCurrentWriterIndexedBySubtype, error)

func (WriterHandlerCurrentWriterSlice) IndexByTenantId 

func (rows WriterHandlerCurrentWriterSlice) IndexByTenantId() (WriterHandlerCurrentWriterIndexedByTenantId, error)

func (WriterHandlerCurrentWriterSlice) IndexByUri 

func (rows WriterHandlerCurrentWriterSlice) IndexByUri() (WriterHandlerCurrentWriterIndexedByUri, 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.