Documentation
¶
Index ¶
- Constants
- Variables
- func WriterDatlyType() reflect.Type
- func WriterHandlerCurrentWriterIndexByIdKey(value *CurrentWriterView) (string, bool)
- type CurrentWriterView
- type Input
- func (input *Input) Init(context.Context) error
- func (input *Input) PrepareReadIndexes(ctx context.Context) error
- func (input *Input) ReadIndexes(ctx context.Context) (*WriterHandlerReadIndexes, error)
- func (input *Input) SetCurrentWriter(value []*CurrentWriterView)
- func (input *Input) SetExecutionRunOnly(value bool)
- func (input *Input) SetRuns(value []*RunDelete)
- func (input *Input) SetWriterKeys(value []WriterKeysRow)
- type InputHas
- type Output
- type RunDelete
- type RunDeleteHas
- type WriterComponent
- type WriterHandlerCurrentWriterGroupedById
- type WriterHandlerCurrentWriterIndexedById
- type WriterHandlerCurrentWriterSlice
- type WriterHandlerReadIndexes
- type WriterKeysRow
Constants ¶
View Source
const WriterDatlyResourceNamespace = "datly_run_delete_writer"
DatlyResourceNamespace identifies this package's generated resource filesystem.
Variables ¶
View Source
var WriterDatly = new(WriterComponent)
The public value supports explicit component wiring.
View Source
var WriterDatlyResources embed.FS
Functions ¶
func WriterDatlyType ¶
WriterDatlyType returns the public component type.
func WriterHandlerCurrentWriterIndexByIdKey ¶
func WriterHandlerCurrentWriterIndexByIdKey(value *CurrentWriterView) (string, bool)
Types ¶
type CurrentWriterView ¶
type CurrentWriterView struct {
Id string `validate:"required" sqlx:"id,primaryKey" json:"id"`
}
CurrentWriterView is generated canonical view metadata for writer.
type Input ¶
type Input struct {
ExecutionRunOnly bool `` /* 188-byte string literal not displayed */
Runs []*RunDelete `` /* 188-byte string literal not displayed */
WriterKeys []WriterKeysRow `parameter:"WriterKeys,kind=param,in=Runs,cardinality=Many" codec:"structql,'uri=datly_run_delete_writer:sql/writer_keys.sql'"`
CurrentWriter []*CurrentWriterView `` /* 157-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 ¶
Init limits this private key-only contract to explicit deletion. Ordinary and conditional mutations use the full canonical run writer.
func (*Input) PrepareReadIndexes ¶
func (*Input) ReadIndexes ¶
func (input *Input) ReadIndexes(ctx context.Context) (*WriterHandlerReadIndexes, error)
func (*Input) SetCurrentWriter ¶
func (input *Input) SetCurrentWriter(value []*CurrentWriterView)
func (*Input) SetExecutionRunOnly ¶
func (*Input) SetWriterKeys ¶
func (input *Input) SetWriterKeys(value []WriterKeysRow)
type Output ¶
type Output struct {
Data []*RunDelete `parameter:"Data,kind=output,in=body,dataType=[]*RunDelete" json:"data,omitempty"`
}
Output is the generated output scaffold for writer.
type RunDelete ¶
type RunDelete struct {
ShouldDelete bool `sqlx:"-" writer:"delete" json:"shouldDelete,omitempty"`
Id string `validate:"required" sqlx:"id,primaryKey" json:"id"`
Has *RunDeleteHas `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-" typeName:"RunDeleteHas"`
}
RunDelete is generated canonical view metadata for writer.
func (*RunDelete) GetShouldDelete ¶
func (*RunDelete) SetShouldDelete ¶
type RunDeleteHas ¶
type WriterComponent ¶
type WriterComponent struct {
Contract xdatly.Component[Input, Output] "" /* 172-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 WriterHandlerCurrentWriterGroupedById ¶
type WriterHandlerCurrentWriterGroupedById map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedById) Has ¶
func (index WriterHandlerCurrentWriterGroupedById) Has(key string) bool
type WriterHandlerCurrentWriterIndexedById ¶
type WriterHandlerCurrentWriterIndexedById map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedById) Has ¶
func (index WriterHandlerCurrentWriterIndexedById) Has(key string) bool
type WriterHandlerCurrentWriterSlice ¶
type WriterHandlerCurrentWriterSlice []*CurrentWriterView
func (WriterHandlerCurrentWriterSlice) GroupById ¶
func (rows WriterHandlerCurrentWriterSlice) GroupById() WriterHandlerCurrentWriterGroupedById
func (WriterHandlerCurrentWriterSlice) IndexById ¶
func (rows WriterHandlerCurrentWriterSlice) IndexById() (WriterHandlerCurrentWriterIndexedById, error)
type WriterHandlerReadIndexes ¶
type WriterHandlerReadIndexes struct {
CurrentWriter WriterHandlerCurrentWriterSlice
CurrentWriterById WriterHandlerCurrentWriterIndexedById
}
func BuildWriterHandlerReadIndexes ¶
func BuildWriterHandlerReadIndexes(ctx context.Context, input *Input) (*WriterHandlerReadIndexes, error)
type WriterKeysRow ¶
type WriterKeysRow struct {
Id string `sqlx:"id"`
}
Click to show internal directories.
Click to hide internal directories.