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

claim

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

Documentation

Index

Constants

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

func WriterDatlyType() reflect.Type

WriterDatlyType returns the public component type.

func WriterHandlerCurrentWriterIndexByApprovedAtKey

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

func WriterHandlerCurrentWriterIndexByApprovedByUserIdKey

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

func WriterHandlerCurrentWriterIndexByDecisionKey

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

func WriterHandlerCurrentWriterIndexByExpiresAtKey

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

func WriterHandlerCurrentWriterIndexByIdKey

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

func WriterHandlerCurrentWriterIndexByMetadataKey

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

func WriterHandlerCurrentWriterIndexByStatusKey

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

func WriterHandlerCurrentWriterIndexByTimedOutAtKey

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

func WriterHandlerCurrentWriterIndexByUpdatedAtKey

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

func WriterHandlerCurrentWriterIndexByUserIdKey

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

Types

type CurrentWriterView

type CurrentWriterView struct {
	Id               string     `sqlx:"id,primaryKey=true" json:"id,omitempty"`
	UserId           string     `sqlx:"user_id,required=true" json:"userId,omitempty"`
	Status           string     `sqlx:"status,required=true" json:"status,omitempty"`
	Decision         *string    `sqlx:"decision" json:"decision,omitempty"`
	ApprovedByUserId *string    `sqlx:"approved_by_user_id" json:"approvedByUserId,omitempty"`
	ApprovedAt       *time.Time `sqlx:"approved_at" json:"approvedAt,omitempty"`
	UpdatedAt        *time.Time `sqlx:"updated_at" json:"updatedAt,omitempty"`
	Metadata         *string    `sqlx:"metadata" json:"metadata,omitempty"`
	ExpiresAt        *time.Time `sqlx:"expires_at" json:"expiresAt,omitempty"`
	TimedOutAt       *time.Time `sqlx:"timed_out_at" json:"timedOutAt,omitempty"`
}

CurrentWriterView is generated canonical view metadata for writer.

type Input

type Input struct {
	Principal            string               `` /* 129-byte string literal not displayed */
	ExpectedStatus       string               `` /* 138-byte string literal not displayed */
	ExpectedUpdatedAt    *time.Time           `` /* 153-byte string literal not displayed */
	DeadlineClock        *time.Time           `` /* 152-byte string literal not displayed */
	DeadlineElapsedClock *time.Time           `` /* 167-byte string literal not displayed */
	Queues               []*QueueClaim        `` /* 197-byte string literal not displayed */
	WriterKeys           []WriterKeysRow      `` /* 140-byte string literal not displayed */
	CurrentWriter        []*CurrentWriterView `` /* 186-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) SetDeadlineClock

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

func (*Input) SetDeadlineElapsedClock

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

func (*Input) SetExpectedStatus

func (input *Input) SetExpectedStatus(value string)

func (*Input) SetExpectedUpdatedAt

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

func (*Input) SetPrincipal

func (input *Input) SetPrincipal(value string)

func (*Input) SetQueues

func (input *Input) SetQueues(value []*QueueClaim)

func (*Input) SetWriterKeys

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

type InputHas

type InputHas struct {
	Principal            bool
	ExpectedStatus       bool
	ExpectedUpdatedAt    bool
	DeadlineClock        bool
	DeadlineElapsedClock bool
	Queues               bool
	WriterKeys           bool
	CurrentWriter        bool
}

type Output

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

Output is the generated output scaffold for writer.

type QueueClaim

type QueueClaim struct {
	Id               string         `sqlx:"id,primaryKey=true" json:"id,omitempty"`
	UserId           string         `sqlx:"user_id,required=true" json:"userId,omitempty"`
	Status           string         `sqlx:"status,required=true" json:"status,omitempty"`
	Decision         *string        `sqlx:"decision" json:"decision,omitempty"`
	ApprovedByUserId *string        `sqlx:"approved_by_user_id" json:"approvedByUserId,omitempty"`
	ApprovedAt       *time.Time     `sqlx:"approved_at" json:"approvedAt,omitempty"`
	UpdatedAt        *time.Time     `sqlx:"updated_at" json:"updatedAt,omitempty"`
	Metadata         *string        `sqlx:"metadata" json:"metadata,omitempty"`
	ExpiresAt        *time.Time     `sqlx:"expires_at" json:"expiresAt,omitempty"`
	TimedOutAt       *time.Time     `sqlx:"timed_out_at" json:"timedOutAt,omitempty"`
	Has              *QueueClaimHas `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-" typeName:"QueueClaimHas"`
}

QueueClaim is generated canonical view metadata for writer.

func (*QueueClaim) GetApprovedAt

func (entity *QueueClaim) GetApprovedAt() *time.Time

func (*QueueClaim) GetApprovedByUserId

func (entity *QueueClaim) GetApprovedByUserId() *string

func (*QueueClaim) GetDecision

func (entity *QueueClaim) GetDecision() *string

func (*QueueClaim) GetExpiresAt

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

func (*QueueClaim) GetId

func (entity *QueueClaim) GetId() string

func (*QueueClaim) GetMetadata

func (entity *QueueClaim) GetMetadata() *string

func (*QueueClaim) GetStatus

func (entity *QueueClaim) GetStatus() string

func (*QueueClaim) GetTimedOutAt

func (entity *QueueClaim) GetTimedOutAt() *time.Time

func (*QueueClaim) GetUpdatedAt

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

func (*QueueClaim) GetUserId

func (entity *QueueClaim) GetUserId() string

func (*QueueClaim) SetApprovedAt

func (entity *QueueClaim) SetApprovedAt(value *time.Time)

func (*QueueClaim) SetApprovedByUserId

func (entity *QueueClaim) SetApprovedByUserId(value *string)

func (*QueueClaim) SetDecision

func (entity *QueueClaim) SetDecision(value *string)

func (*QueueClaim) SetExpiresAt

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

func (*QueueClaim) SetId

func (entity *QueueClaim) SetId(value string)

func (*QueueClaim) SetMetadata

func (entity *QueueClaim) SetMetadata(value *string)

func (*QueueClaim) SetStatus

func (entity *QueueClaim) SetStatus(value string)

func (*QueueClaim) SetTimedOutAt

func (entity *QueueClaim) SetTimedOutAt(value *time.Time)

func (*QueueClaim) SetUpdatedAt

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

func (*QueueClaim) SetUserId

func (entity *QueueClaim) SetUserId(value string)

type QueueClaimHas

type QueueClaimHas struct {
	Id               bool
	UserId           bool
	Status           bool
	Decision         bool
	ApprovedByUserId bool
	ApprovedAt       bool
	UpdatedAt        bool
	Metadata         bool
	ExpiresAt        bool
	TimedOutAt       bool
}

type WriterComponent

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

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

func (WriterHandlerCurrentWriterGroupedByApprovedAt) Has

type WriterHandlerCurrentWriterGroupedByApprovedByUserId

type WriterHandlerCurrentWriterGroupedByApprovedByUserId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByApprovedByUserId) Has

type WriterHandlerCurrentWriterGroupedByDecision

type WriterHandlerCurrentWriterGroupedByDecision map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByDecision) Has

type WriterHandlerCurrentWriterGroupedByExpiresAt

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

func (WriterHandlerCurrentWriterGroupedByExpiresAt) Has

type WriterHandlerCurrentWriterGroupedById

type WriterHandlerCurrentWriterGroupedById map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedById) Has

type WriterHandlerCurrentWriterGroupedByMetadata

type WriterHandlerCurrentWriterGroupedByMetadata map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByMetadata) Has

type WriterHandlerCurrentWriterGroupedByStatus

type WriterHandlerCurrentWriterGroupedByStatus map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByStatus) Has

type WriterHandlerCurrentWriterGroupedByTimedOutAt

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

func (WriterHandlerCurrentWriterGroupedByTimedOutAt) Has

type WriterHandlerCurrentWriterGroupedByUpdatedAt

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

func (WriterHandlerCurrentWriterGroupedByUpdatedAt) Has

type WriterHandlerCurrentWriterGroupedByUserId

type WriterHandlerCurrentWriterGroupedByUserId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByUserId) Has

type WriterHandlerCurrentWriterIndexedByApprovedAt

type WriterHandlerCurrentWriterIndexedByApprovedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByApprovedAt) Has

type WriterHandlerCurrentWriterIndexedByApprovedByUserId

type WriterHandlerCurrentWriterIndexedByApprovedByUserId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByApprovedByUserId) Has

type WriterHandlerCurrentWriterIndexedByDecision

type WriterHandlerCurrentWriterIndexedByDecision map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByDecision) Has

type WriterHandlerCurrentWriterIndexedByExpiresAt

type WriterHandlerCurrentWriterIndexedByExpiresAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByExpiresAt) Has

type WriterHandlerCurrentWriterIndexedById

type WriterHandlerCurrentWriterIndexedById map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedById) Has

type WriterHandlerCurrentWriterIndexedByMetadata

type WriterHandlerCurrentWriterIndexedByMetadata map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByMetadata) Has

type WriterHandlerCurrentWriterIndexedByStatus

type WriterHandlerCurrentWriterIndexedByStatus map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByStatus) Has

type WriterHandlerCurrentWriterIndexedByTimedOutAt

type WriterHandlerCurrentWriterIndexedByTimedOutAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByTimedOutAt) Has

type WriterHandlerCurrentWriterIndexedByUpdatedAt

type WriterHandlerCurrentWriterIndexedByUpdatedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByUpdatedAt) Has

type WriterHandlerCurrentWriterIndexedByUserId

type WriterHandlerCurrentWriterIndexedByUserId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByUserId) Has

type WriterHandlerCurrentWriterSlice

type WriterHandlerCurrentWriterSlice []*CurrentWriterView

func (WriterHandlerCurrentWriterSlice) GroupByApprovedAt

func (WriterHandlerCurrentWriterSlice) GroupByApprovedByUserId

func (WriterHandlerCurrentWriterSlice) GroupByDecision

func (WriterHandlerCurrentWriterSlice) GroupByExpiresAt

func (WriterHandlerCurrentWriterSlice) GroupById

func (WriterHandlerCurrentWriterSlice) GroupByMetadata

func (WriterHandlerCurrentWriterSlice) GroupByStatus

func (WriterHandlerCurrentWriterSlice) GroupByTimedOutAt

func (WriterHandlerCurrentWriterSlice) GroupByUpdatedAt

func (WriterHandlerCurrentWriterSlice) GroupByUserId

func (WriterHandlerCurrentWriterSlice) IndexByApprovedAt

func (WriterHandlerCurrentWriterSlice) IndexByApprovedByUserId

func (WriterHandlerCurrentWriterSlice) IndexByDecision

func (WriterHandlerCurrentWriterSlice) IndexByExpiresAt

func (WriterHandlerCurrentWriterSlice) IndexById

func (WriterHandlerCurrentWriterSlice) IndexByMetadata

func (WriterHandlerCurrentWriterSlice) IndexByStatus

func (WriterHandlerCurrentWriterSlice) IndexByTimedOutAt

func (WriterHandlerCurrentWriterSlice) IndexByUpdatedAt

func (WriterHandlerCurrentWriterSlice) IndexByUserId

type WriterHandlerReadIndexes

type WriterHandlerReadIndexes struct {
	CurrentWriter     WriterHandlerCurrentWriterSlice
	CurrentWriterById WriterHandlerCurrentWriterIndexedById
}

func BuildWriterHandlerReadIndexes

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

type WriterKeysRow

type WriterKeysRow struct {
	Id string `sqlx:"id"`
}

Jump to

Keyboard shortcuts

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