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

Documentation

Index

Constants

View Source 
const WriterDatlyResourceNamespace = "reporting_run_write_writer"

DatlyResourceNamespace identifies this package's generated resource filesystem.

Variables

View Source 
var (
	ErrAlreadyExists = errors.New("report run already exists")
	ErrNotFound      = errors.New("report run not found")
	ErrCASMismatch   = errors.New("report run revision mismatch")
	ErrImmutable     = errors.New("completed report run is immutable")
	ErrOwnerDenied   = errors.New("report run owner denied")
)
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 WriterHandlerCurrentWriterIndexByActivationSourceKey 

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

func WriterHandlerCurrentWriterIndexByActorIdKey 

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

func WriterHandlerCurrentWriterIndexByAdoptionSourceKey 

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

func WriterHandlerCurrentWriterIndexByBuilderRefKey 

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

func WriterHandlerCurrentWriterIndexByCompletedAtKey 

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

func WriterHandlerCurrentWriterIndexByConversationIdKey 

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

func WriterHandlerCurrentWriterIndexByCreatedAtKey 

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

func WriterHandlerCurrentWriterIndexByFailureCodeKey 

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

func WriterHandlerCurrentWriterIndexByFailureTextKey 

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

func WriterHandlerCurrentWriterIndexByMaterializerKey 

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

func WriterHandlerCurrentWriterIndexByOriginKey 

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

func WriterHandlerCurrentWriterIndexByOwnerIdKey 

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

func WriterHandlerCurrentWriterIndexByPresetIdKey 

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

func WriterHandlerCurrentWriterIndexByReportRunIdKey 

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

func WriterHandlerCurrentWriterIndexByRevisionKey 

func WriterHandlerCurrentWriterIndexByRevisionKey(value *CurrentWriterView) (int64, bool)

func WriterHandlerCurrentWriterIndexBySourceIdKey 

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

func WriterHandlerCurrentWriterIndexBySourceKindKey 

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

func WriterHandlerCurrentWriterIndexByStartedAtKey 

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

func WriterHandlerCurrentWriterIndexByStatusKey 

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

func WriterHandlerCurrentWriterIndexByUiRunRequestIdKey 

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

func WriterHandlerCurrentWriterIndexByUpdatedAtKey 

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

Types

type CurrentWriterView 

type CurrentWriterView struct {
	Revision            int64      `sqlx:"revision,required=true" json:"revision,omitempty"`
	ReportRunId         string     `sqlx:"report_run_id,primaryKey=true,required=true" json:"reportRunId,omitempty"`
	OwnerId             string     `sqlx:"owner_id,required=true" json:"ownerId,omitempty"`
	Materializer        string     `sqlx:"materializer,required=true" json:"materializer,omitempty"`
	RequestedParamsJson []byte     `sqlx:"requested_params_json" json:"requestedParamsJson,omitempty"`
	EffectiveParamsJson []byte     `sqlx:"effective_params_json" json:"effectiveParamsJson,omitempty"`
	Status              string     `sqlx:"status,required=true" json:"status,omitempty"`
	StartedAt           time.Time  `sqlx:"started_at,required=true" json:"startedAt,omitempty"`
	UiRunRequestId      string     `sqlx:"ui_run_request_id,required=true" json:"uiRunRequestId,omitempty"`
	ReportSpecJson      []byte     `sqlx:"report_spec_json" json:"reportSpecJson,omitempty"`
	ReportFillJson      []byte     `sqlx:"report_fill_json" json:"reportFillJson,omitempty"`
	ReportPrintJson     []byte     `sqlx:"report_print_json" json:"reportPrintJson,omitempty"`
	CreatedAt           time.Time  `sqlx:"created_at,required=true" json:"createdAt,omitempty"`
	UpdatedAt           time.Time  `sqlx:"updated_at,required=true" json:"updatedAt,omitempty"`
	ConversationId      *string    `sqlx:"conversation_id,refTable=conversation,refColumn=id" json:"conversationId,omitempty"`
	Origin              *string    `sqlx:"origin" json:"origin,omitempty"`
	BuilderRef          *string    `sqlx:"builder_ref" json:"builderRef,omitempty"`
	PresetId            *string    `sqlx:"preset_id" json:"presetId,omitempty"`
	SourceKind          *string    `sqlx:"source_kind" json:"sourceKind,omitempty"`
	SourceId            *string    `sqlx:"source_id" json:"sourceId,omitempty"`
	FailureCode         *string    `sqlx:"failure_code" json:"failureCode,omitempty"`
	FailureText         *string    `sqlx:"failure_text" json:"failureText,omitempty"`
	CompletedAt         *time.Time `sqlx:"completed_at" json:"completedAt,omitempty"`
	ActivationSource    *string    `sqlx:"activation_source" json:"activationSource,omitempty"`
	AdoptionSource      *string    `sqlx:"adoption_source" json:"adoptionSource,omitempty"`
	ActorId             *string    `sqlx:"actor_id" json:"actorId,omitempty"`
}

CurrentWriterView is generated canonical view metadata for writer.

type Input 

type Input struct {
	Internal          bool                 `parameter:"Internal,kind=reportaccess,in=internal,dataType=bool,required=true"`
	OwnerSubject      *string              `` /* 128-byte string literal not displayed */
	OrphanDetach      bool                 `parameter:"OrphanDetach,kind=orphandetach,in=enabledDetach,dataType=bool,required=false"`
	OrphanColumn      string               `parameter:"OrphanColumn,kind=orphandetach,in=column,dataType=string,required=false"`
	Mode              string               `parameter:"Mode,kind=query,in=mode,dataType=string,required=true"`
	DesiredRevision   int64                `parameter:"DesiredRevision,kind=query,in=desiredRevision,dataType=int64,required=false"`
	ExpectedRequestID string               `` /* 147-byte string literal not displayed */
	Runs              []*Run               `` /* 207-byte string literal not displayed */
	WriterKeys        []WriterKeysRow      `` /* 128-byte string literal not displayed */
	CurrentWriter     []*CurrentWriterView `` /* 167-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) SetDesiredRevision 

func (input *Input) SetDesiredRevision(value int64)

func (*Input) SetExpectedRequestID 

func (input *Input) SetExpectedRequestID(value string)

func (*Input) SetInternal 

func (input *Input) SetInternal(value bool)

func (*Input) SetMode 

func (input *Input) SetMode(value string)

func (*Input) SetOrphanColumn 

func (input *Input) SetOrphanColumn(value string)

func (*Input) SetOrphanDetach 

func (input *Input) SetOrphanDetach(value bool)

func (*Input) SetOwnerSubject 

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

func (*Input) SetRuns 

func (input *Input) SetRuns(value []*Run)

func (*Input) SetWriterKeys 

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

type InputHas 

type InputHas struct {
	Internal          bool
	OwnerSubject      bool
	OrphanDetach      bool
	OrphanColumn      bool
	Mode              bool
	DesiredRevision   bool
	ExpectedRequestID bool
	Runs              bool
	WriterKeys        bool
	CurrentWriter     bool
}

type Lifecycle 

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

Lifecycle customizes role Input.Runs.

func (*Lifecycle) AfterQueue 

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

func (*Lifecycle) AfterSequence 

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

func (*Lifecycle) Validate 

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

type Output 

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

Output is the generated output scaffold for writer.

type Run 

type Run struct {
	ShouldDelete        bool       `json:"shouldDelete,omitempty" sqlx:"-" writer:"delete"`
	Revision            int64      `writer:"concurrency" sqlx:"revision,required=true" json:"revision,omitempty"`
	ReportRunId         string     `sqlx:"report_run_id,primaryKey=true,required=true" json:"reportRunId,omitempty"`
	OwnerId             string     `sqlx:"owner_id,required=true" json:"ownerId,omitempty"`
	Materializer        string     `sqlx:"materializer,required=true" json:"materializer,omitempty"`
	RequestedParamsJson []byte     `sqlx:"requested_params_json" json:"requestedParamsJson,omitempty"`
	EffectiveParamsJson []byte     `sqlx:"effective_params_json" json:"effectiveParamsJson,omitempty"`
	Status              string     `sqlx:"status,required=true" json:"status,omitempty"`
	StartedAt           time.Time  `sqlx:"started_at,required=true" json:"startedAt,omitempty"`
	UiRunRequestId      string     `sqlx:"ui_run_request_id,required=true" json:"uiRunRequestId,omitempty"`
	ReportSpecJson      []byte     `sqlx:"report_spec_json" json:"reportSpecJson,omitempty"`
	ReportFillJson      []byte     `sqlx:"report_fill_json" json:"reportFillJson,omitempty"`
	ReportPrintJson     []byte     `sqlx:"report_print_json" json:"reportPrintJson,omitempty"`
	CreatedAt           time.Time  `sqlx:"created_at,required=true" json:"createdAt,omitempty"`
	UpdatedAt           time.Time  `sqlx:"updated_at,required=true" json:"updatedAt,omitempty"`
	ConversationId      *string    `sqlx:"conversation_id,refTable=conversation,refColumn=id" json:"conversationId,omitempty"`
	Origin              *string    `sqlx:"origin" json:"origin,omitempty"`
	BuilderRef          *string    `sqlx:"builder_ref" json:"builderRef,omitempty"`
	PresetId            *string    `sqlx:"preset_id" json:"presetId,omitempty"`
	SourceKind          *string    `sqlx:"source_kind" json:"sourceKind,omitempty"`
	SourceId            *string    `sqlx:"source_id" json:"sourceId,omitempty"`
	FailureCode         *string    `sqlx:"failure_code" json:"failureCode,omitempty"`
	FailureText         *string    `sqlx:"failure_text" json:"failureText,omitempty"`
	CompletedAt         *time.Time `sqlx:"completed_at" json:"completedAt,omitempty"`
	ActivationSource    *string    `sqlx:"activation_source" json:"activationSource,omitempty"`
	AdoptionSource      *string    `sqlx:"adoption_source" json:"adoptionSource,omitempty"`
	ActorId             *string    `sqlx:"actor_id" json:"actorId,omitempty"`
	Has                 *RunHas    `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-" typeName:"RunHas"`
}

Run is generated canonical view metadata for writer.

func (*Run) GetActivationSource 

func (entity *Run) GetActivationSource() *string

func (*Run) GetActorId 

func (entity *Run) GetActorId() *string

func (*Run) GetAdoptionSource 

func (entity *Run) GetAdoptionSource() *string

func (*Run) GetBuilderRef 

func (entity *Run) GetBuilderRef() *string

func (*Run) GetCompletedAt 

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

func (*Run) GetConversationId 

func (entity *Run) GetConversationId() *string

func (*Run) GetCreatedAt 

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

func (*Run) GetEffectiveParamsJson 

func (entity *Run) GetEffectiveParamsJson() []byte

func (*Run) GetFailureCode 

func (entity *Run) GetFailureCode() *string

func (*Run) GetFailureText 

func (entity *Run) GetFailureText() *string

func (*Run) GetMaterializer 

func (entity *Run) GetMaterializer() string

func (*Run) GetOrigin 

func (entity *Run) GetOrigin() *string

func (*Run) GetOwnerId 

func (entity *Run) GetOwnerId() string

func (*Run) GetPresetId 

func (entity *Run) GetPresetId() *string

func (*Run) GetReportFillJson 

func (entity *Run) GetReportFillJson() []byte

func (*Run) GetReportPrintJson 

func (entity *Run) GetReportPrintJson() []byte

func (*Run) GetReportRunId 

func (entity *Run) GetReportRunId() string

func (*Run) GetReportSpecJson 

func (entity *Run) GetReportSpecJson() []byte

func (*Run) GetRequestedParamsJson 

func (entity *Run) GetRequestedParamsJson() []byte

func (*Run) GetRevision 

func (entity *Run) GetRevision() int64

func (*Run) GetShouldDelete 

func (entity *Run) GetShouldDelete() bool

func (*Run) GetSourceId 

func (entity *Run) GetSourceId() *string

func (*Run) GetSourceKind 

func (entity *Run) GetSourceKind() *string

func (*Run) GetStartedAt 

func (entity *Run) GetStartedAt() time.Time

func (*Run) GetStatus 

func (entity *Run) GetStatus() string

func (*Run) GetUiRunRequestId 

func (entity *Run) GetUiRunRequestId() string

func (*Run) GetUpdatedAt 

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

func (*Run) SetActivationSource 

func (entity *Run) SetActivationSource(value *string)

func (*Run) SetActorId 

func (entity *Run) SetActorId(value *string)

func (*Run) SetAdoptionSource 

func (entity *Run) SetAdoptionSource(value *string)

func (*Run) SetBuilderRef 

func (entity *Run) SetBuilderRef(value *string)

func (*Run) SetCompletedAt 

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

func (*Run) SetConversationId 

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

func (*Run) SetCreatedAt 

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

func (*Run) SetEffectiveParamsJson 

func (entity *Run) SetEffectiveParamsJson(value []byte)

func (*Run) SetFailureCode 

func (entity *Run) SetFailureCode(value *string)

func (*Run) SetFailureText 

func (entity *Run) SetFailureText(value *string)

func (*Run) SetMaterializer 

func (entity *Run) SetMaterializer(value string)

func (*Run) SetOrigin 

func (entity *Run) SetOrigin(value *string)

func (*Run) SetOwnerId 

func (entity *Run) SetOwnerId(value string)

func (*Run) SetPresetId 

func (entity *Run) SetPresetId(value *string)

func (*Run) SetReportFillJson 

func (entity *Run) SetReportFillJson(value []byte)

func (*Run) SetReportPrintJson 

func (entity *Run) SetReportPrintJson(value []byte)

func (*Run) SetReportRunId 

func (entity *Run) SetReportRunId(value string)

func (*Run) SetReportSpecJson 

func (entity *Run) SetReportSpecJson(value []byte)

func (*Run) SetRequestedParamsJson 

func (entity *Run) SetRequestedParamsJson(value []byte)

func (*Run) SetRevision 

func (entity *Run) SetRevision(value int64)

func (*Run) SetShouldDelete 

func (entity *Run) SetShouldDelete(value bool)

func (*Run) SetSourceId 

func (entity *Run) SetSourceId(value *string)

func (*Run) SetSourceKind 

func (entity *Run) SetSourceKind(value *string)

func (*Run) SetStartedAt 

func (entity *Run) SetStartedAt(value time.Time)

func (*Run) SetStatus 

func (entity *Run) SetStatus(value string)

func (*Run) SetUiRunRequestId 

func (entity *Run) SetUiRunRequestId(value string)

func (*Run) SetUpdatedAt 

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

type RunHas 

type RunHas struct {
	ShouldDelete        bool
	Revision            bool
	ReportRunId         bool
	OwnerId             bool
	Materializer        bool
	RequestedParamsJson bool
	EffectiveParamsJson bool
	Status              bool
	StartedAt           bool
	UiRunRequestId      bool
	ReportSpecJson      bool
	ReportFillJson      bool
	ReportPrintJson     bool
	CreatedAt           bool
	UpdatedAt           bool
	ConversationId      bool
	Origin              bool
	BuilderRef          bool
	PresetId            bool
	SourceKind          bool
	SourceId            bool
	FailureCode         bool
	FailureText         bool
	CompletedAt         bool
	ActivationSource    bool
	AdoptionSource      bool
	ActorId             bool
}

type WriterComponent 

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

type WriterHandlerCurrentWriterGroupedByActivationSource map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByActivationSource) Has 

func (index WriterHandlerCurrentWriterGroupedByActivationSource) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByActorId 

type WriterHandlerCurrentWriterGroupedByActorId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByActorId) Has 

func (index WriterHandlerCurrentWriterGroupedByActorId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByAdoptionSource 

type WriterHandlerCurrentWriterGroupedByAdoptionSource map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByAdoptionSource) Has 

func (index WriterHandlerCurrentWriterGroupedByAdoptionSource) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByBuilderRef 

type WriterHandlerCurrentWriterGroupedByBuilderRef map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByBuilderRef) Has 

func (index WriterHandlerCurrentWriterGroupedByBuilderRef) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByCompletedAt 

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

func (WriterHandlerCurrentWriterGroupedByCompletedAt) Has 

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

type WriterHandlerCurrentWriterGroupedByConversationId 

type WriterHandlerCurrentWriterGroupedByConversationId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByConversationId) Has 

func (index WriterHandlerCurrentWriterGroupedByConversationId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByCreatedAt 

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

func (WriterHandlerCurrentWriterGroupedByCreatedAt) Has 

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

type WriterHandlerCurrentWriterGroupedByFailureCode 

type WriterHandlerCurrentWriterGroupedByFailureCode map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByFailureCode) Has 

func (index WriterHandlerCurrentWriterGroupedByFailureCode) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByFailureText 

type WriterHandlerCurrentWriterGroupedByFailureText map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByFailureText) Has 

func (index WriterHandlerCurrentWriterGroupedByFailureText) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByMaterializer 

type WriterHandlerCurrentWriterGroupedByMaterializer map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByMaterializer) Has 

func (index WriterHandlerCurrentWriterGroupedByMaterializer) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByOrigin 

type WriterHandlerCurrentWriterGroupedByOrigin map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByOrigin) Has 

func (index WriterHandlerCurrentWriterGroupedByOrigin) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByOwnerId 

type WriterHandlerCurrentWriterGroupedByOwnerId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByOwnerId) Has 

func (index WriterHandlerCurrentWriterGroupedByOwnerId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByPresetId 

type WriterHandlerCurrentWriterGroupedByPresetId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByPresetId) Has 

func (index WriterHandlerCurrentWriterGroupedByPresetId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByReportRunId 

type WriterHandlerCurrentWriterGroupedByReportRunId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByReportRunId) Has 

func (index WriterHandlerCurrentWriterGroupedByReportRunId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByRevision 

type WriterHandlerCurrentWriterGroupedByRevision map[int64][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByRevision) Has 

func (index WriterHandlerCurrentWriterGroupedByRevision) Has(key int64) bool

type WriterHandlerCurrentWriterGroupedBySourceId 

type WriterHandlerCurrentWriterGroupedBySourceId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedBySourceId) Has 

func (index WriterHandlerCurrentWriterGroupedBySourceId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedBySourceKind 

type WriterHandlerCurrentWriterGroupedBySourceKind map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedBySourceKind) Has 

func (index WriterHandlerCurrentWriterGroupedBySourceKind) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByStartedAt 

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

func (WriterHandlerCurrentWriterGroupedByStartedAt) Has 

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

type WriterHandlerCurrentWriterGroupedByStatus 

type WriterHandlerCurrentWriterGroupedByStatus map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByStatus) Has 

func (index WriterHandlerCurrentWriterGroupedByStatus) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByUiRunRequestId 

type WriterHandlerCurrentWriterGroupedByUiRunRequestId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByUiRunRequestId) Has 

func (index WriterHandlerCurrentWriterGroupedByUiRunRequestId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByUpdatedAt 

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

func (WriterHandlerCurrentWriterGroupedByUpdatedAt) Has 

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

type WriterHandlerCurrentWriterIndexedByActivationSource 

type WriterHandlerCurrentWriterIndexedByActivationSource map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByActivationSource) Has 

func (index WriterHandlerCurrentWriterIndexedByActivationSource) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByActorId 

type WriterHandlerCurrentWriterIndexedByActorId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByActorId) Has 

func (index WriterHandlerCurrentWriterIndexedByActorId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByAdoptionSource 

type WriterHandlerCurrentWriterIndexedByAdoptionSource map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByAdoptionSource) Has 

func (index WriterHandlerCurrentWriterIndexedByAdoptionSource) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByBuilderRef 

type WriterHandlerCurrentWriterIndexedByBuilderRef map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByBuilderRef) Has 

func (index WriterHandlerCurrentWriterIndexedByBuilderRef) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByCompletedAt 

type WriterHandlerCurrentWriterIndexedByCompletedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCompletedAt) Has 

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

type WriterHandlerCurrentWriterIndexedByConversationId 

type WriterHandlerCurrentWriterIndexedByConversationId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByConversationId) Has 

func (index WriterHandlerCurrentWriterIndexedByConversationId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByCreatedAt 

type WriterHandlerCurrentWriterIndexedByCreatedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCreatedAt) Has 

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

type WriterHandlerCurrentWriterIndexedByFailureCode 

type WriterHandlerCurrentWriterIndexedByFailureCode map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByFailureCode) Has 

func (index WriterHandlerCurrentWriterIndexedByFailureCode) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByFailureText 

type WriterHandlerCurrentWriterIndexedByFailureText map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByFailureText) Has 

func (index WriterHandlerCurrentWriterIndexedByFailureText) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByMaterializer 

type WriterHandlerCurrentWriterIndexedByMaterializer map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByMaterializer) Has 

func (index WriterHandlerCurrentWriterIndexedByMaterializer) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByOrigin 

type WriterHandlerCurrentWriterIndexedByOrigin map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByOrigin) Has 

func (index WriterHandlerCurrentWriterIndexedByOrigin) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByOwnerId 

type WriterHandlerCurrentWriterIndexedByOwnerId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByOwnerId) Has 

func (index WriterHandlerCurrentWriterIndexedByOwnerId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByPresetId 

type WriterHandlerCurrentWriterIndexedByPresetId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByPresetId) Has 

func (index WriterHandlerCurrentWriterIndexedByPresetId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByReportRunId 

type WriterHandlerCurrentWriterIndexedByReportRunId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByReportRunId) Has 

func (index WriterHandlerCurrentWriterIndexedByReportRunId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByRevision 

type WriterHandlerCurrentWriterIndexedByRevision map[int64]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByRevision) Has 

func (index WriterHandlerCurrentWriterIndexedByRevision) Has(key int64) bool

type WriterHandlerCurrentWriterIndexedBySourceId 

type WriterHandlerCurrentWriterIndexedBySourceId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedBySourceId) Has 

func (index WriterHandlerCurrentWriterIndexedBySourceId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedBySourceKind 

type WriterHandlerCurrentWriterIndexedBySourceKind map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedBySourceKind) Has 

func (index WriterHandlerCurrentWriterIndexedBySourceKind) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByStartedAt 

type WriterHandlerCurrentWriterIndexedByStartedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByStartedAt) Has 

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

type WriterHandlerCurrentWriterIndexedByStatus 

type WriterHandlerCurrentWriterIndexedByStatus map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByStatus) Has 

func (index WriterHandlerCurrentWriterIndexedByStatus) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByUiRunRequestId 

type WriterHandlerCurrentWriterIndexedByUiRunRequestId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByUiRunRequestId) Has 

func (index WriterHandlerCurrentWriterIndexedByUiRunRequestId) 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) GroupByActivationSource 

func (rows WriterHandlerCurrentWriterSlice) GroupByActivationSource() WriterHandlerCurrentWriterGroupedByActivationSource

func (WriterHandlerCurrentWriterSlice) GroupByActorId 

func (rows WriterHandlerCurrentWriterSlice) GroupByActorId() WriterHandlerCurrentWriterGroupedByActorId

func (WriterHandlerCurrentWriterSlice) GroupByAdoptionSource 

func (rows WriterHandlerCurrentWriterSlice) GroupByAdoptionSource() WriterHandlerCurrentWriterGroupedByAdoptionSource

func (WriterHandlerCurrentWriterSlice) GroupByBuilderRef 

func (rows WriterHandlerCurrentWriterSlice) GroupByBuilderRef() WriterHandlerCurrentWriterGroupedByBuilderRef

func (WriterHandlerCurrentWriterSlice) GroupByCompletedAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByCompletedAt() WriterHandlerCurrentWriterGroupedByCompletedAt

func (WriterHandlerCurrentWriterSlice) GroupByConversationId 

func (rows WriterHandlerCurrentWriterSlice) GroupByConversationId() WriterHandlerCurrentWriterGroupedByConversationId

func (WriterHandlerCurrentWriterSlice) GroupByCreatedAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByCreatedAt() WriterHandlerCurrentWriterGroupedByCreatedAt

func (WriterHandlerCurrentWriterSlice) GroupByFailureCode 

func (rows WriterHandlerCurrentWriterSlice) GroupByFailureCode() WriterHandlerCurrentWriterGroupedByFailureCode

func (WriterHandlerCurrentWriterSlice) GroupByFailureText 

func (rows WriterHandlerCurrentWriterSlice) GroupByFailureText() WriterHandlerCurrentWriterGroupedByFailureText

func (WriterHandlerCurrentWriterSlice) GroupByMaterializer 

func (rows WriterHandlerCurrentWriterSlice) GroupByMaterializer() WriterHandlerCurrentWriterGroupedByMaterializer

func (WriterHandlerCurrentWriterSlice) GroupByOrigin 

func (rows WriterHandlerCurrentWriterSlice) GroupByOrigin() WriterHandlerCurrentWriterGroupedByOrigin

func (WriterHandlerCurrentWriterSlice) GroupByOwnerId 

func (rows WriterHandlerCurrentWriterSlice) GroupByOwnerId() WriterHandlerCurrentWriterGroupedByOwnerId

func (WriterHandlerCurrentWriterSlice) GroupByPresetId 

func (rows WriterHandlerCurrentWriterSlice) GroupByPresetId() WriterHandlerCurrentWriterGroupedByPresetId

func (WriterHandlerCurrentWriterSlice) GroupByReportRunId 

func (rows WriterHandlerCurrentWriterSlice) GroupByReportRunId() WriterHandlerCurrentWriterGroupedByReportRunId

func (WriterHandlerCurrentWriterSlice) GroupByRevision 

func (rows WriterHandlerCurrentWriterSlice) GroupByRevision() WriterHandlerCurrentWriterGroupedByRevision

func (WriterHandlerCurrentWriterSlice) GroupBySourceId 

func (rows WriterHandlerCurrentWriterSlice) GroupBySourceId() WriterHandlerCurrentWriterGroupedBySourceId

func (WriterHandlerCurrentWriterSlice) GroupBySourceKind 

func (rows WriterHandlerCurrentWriterSlice) GroupBySourceKind() WriterHandlerCurrentWriterGroupedBySourceKind

func (WriterHandlerCurrentWriterSlice) GroupByStartedAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByStartedAt() WriterHandlerCurrentWriterGroupedByStartedAt

func (WriterHandlerCurrentWriterSlice) GroupByStatus 

func (rows WriterHandlerCurrentWriterSlice) GroupByStatus() WriterHandlerCurrentWriterGroupedByStatus

func (WriterHandlerCurrentWriterSlice) GroupByUiRunRequestId 

func (rows WriterHandlerCurrentWriterSlice) GroupByUiRunRequestId() WriterHandlerCurrentWriterGroupedByUiRunRequestId

func (WriterHandlerCurrentWriterSlice) GroupByUpdatedAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByUpdatedAt() WriterHandlerCurrentWriterGroupedByUpdatedAt

func (WriterHandlerCurrentWriterSlice) IndexByActivationSource 

func (rows WriterHandlerCurrentWriterSlice) IndexByActivationSource() (WriterHandlerCurrentWriterIndexedByActivationSource, error)

func (WriterHandlerCurrentWriterSlice) IndexByActorId 

func (rows WriterHandlerCurrentWriterSlice) IndexByActorId() (WriterHandlerCurrentWriterIndexedByActorId, error)

func (WriterHandlerCurrentWriterSlice) IndexByAdoptionSource 

func (rows WriterHandlerCurrentWriterSlice) IndexByAdoptionSource() (WriterHandlerCurrentWriterIndexedByAdoptionSource, error)

func (WriterHandlerCurrentWriterSlice) IndexByBuilderRef 

func (rows WriterHandlerCurrentWriterSlice) IndexByBuilderRef() (WriterHandlerCurrentWriterIndexedByBuilderRef, error)

func (WriterHandlerCurrentWriterSlice) IndexByCompletedAt 

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

func (WriterHandlerCurrentWriterSlice) IndexByConversationId 

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

func (WriterHandlerCurrentWriterSlice) IndexByCreatedAt 

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

func (WriterHandlerCurrentWriterSlice) IndexByFailureCode 

func (rows WriterHandlerCurrentWriterSlice) IndexByFailureCode() (WriterHandlerCurrentWriterIndexedByFailureCode, error)

func (WriterHandlerCurrentWriterSlice) IndexByFailureText 

func (rows WriterHandlerCurrentWriterSlice) IndexByFailureText() (WriterHandlerCurrentWriterIndexedByFailureText, error)

func (WriterHandlerCurrentWriterSlice) IndexByMaterializer 

func (rows WriterHandlerCurrentWriterSlice) IndexByMaterializer() (WriterHandlerCurrentWriterIndexedByMaterializer, error)

func (WriterHandlerCurrentWriterSlice) IndexByOrigin 

func (rows WriterHandlerCurrentWriterSlice) IndexByOrigin() (WriterHandlerCurrentWriterIndexedByOrigin, error)

func (WriterHandlerCurrentWriterSlice) IndexByOwnerId 

func (rows WriterHandlerCurrentWriterSlice) IndexByOwnerId() (WriterHandlerCurrentWriterIndexedByOwnerId, error)

func (WriterHandlerCurrentWriterSlice) IndexByPresetId 

func (rows WriterHandlerCurrentWriterSlice) IndexByPresetId() (WriterHandlerCurrentWriterIndexedByPresetId, error)

func (WriterHandlerCurrentWriterSlice) IndexByReportRunId 

func (rows WriterHandlerCurrentWriterSlice) IndexByReportRunId() (WriterHandlerCurrentWriterIndexedByReportRunId, error)

func (WriterHandlerCurrentWriterSlice) IndexByRevision 

func (rows WriterHandlerCurrentWriterSlice) IndexByRevision() (WriterHandlerCurrentWriterIndexedByRevision, error)

func (WriterHandlerCurrentWriterSlice) IndexBySourceId 

func (rows WriterHandlerCurrentWriterSlice) IndexBySourceId() (WriterHandlerCurrentWriterIndexedBySourceId, error)

func (WriterHandlerCurrentWriterSlice) IndexBySourceKind 

func (rows WriterHandlerCurrentWriterSlice) IndexBySourceKind() (WriterHandlerCurrentWriterIndexedBySourceKind, error)

func (WriterHandlerCurrentWriterSlice) IndexByStartedAt 

func (rows WriterHandlerCurrentWriterSlice) IndexByStartedAt() (WriterHandlerCurrentWriterIndexedByStartedAt, error)

func (WriterHandlerCurrentWriterSlice) IndexByStatus 

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

func (WriterHandlerCurrentWriterSlice) IndexByUiRunRequestId 

func (rows WriterHandlerCurrentWriterSlice) IndexByUiRunRequestId() (WriterHandlerCurrentWriterIndexedByUiRunRequestId, error)

func (WriterHandlerCurrentWriterSlice) IndexByUpdatedAt 

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

type WriterHandlerReadIndexes 

type WriterHandlerReadIndexes struct {
	CurrentWriter              WriterHandlerCurrentWriterSlice
	CurrentWriterByReportRunId WriterHandlerCurrentWriterIndexedByReportRunId
}

func BuildWriterHandlerReadIndexes 

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

type WriterKeysRow 

type WriterKeysRow struct {
	ReportRunId string `sqlx:"report_run_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.