Documentation
¶
Index ¶
- Constants
- Variables
- func WriterDatlyType() reflect.Type
- func WriterHandlerCurrentWriterIndexByApprovedAtKey(value *CurrentWriterView) (time.Time, bool)
- func WriterHandlerCurrentWriterIndexByApprovedByUserIdKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByDecisionKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByExpiresAtKey(value *CurrentWriterView) (time.Time, bool)
- func WriterHandlerCurrentWriterIndexByIdKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByMetadataKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByStatusKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByTimedOutAtKey(value *CurrentWriterView) (time.Time, bool)
- func WriterHandlerCurrentWriterIndexByUpdatedAtKey(value *CurrentWriterView) (time.Time, bool)
- func WriterHandlerCurrentWriterIndexByUserIdKey(value *CurrentWriterView) (string, bool)
- type CurrentWriterView
- type Input
- 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) SetDeadlineClock(value *time.Time)
- func (input *Input) SetDeadlineElapsedClock(value *time.Time)
- func (input *Input) SetExpectedStatus(value string)
- func (input *Input) SetExpectedUpdatedAt(value *time.Time)
- func (input *Input) SetPrincipal(value string)
- func (input *Input) SetQueues(value []*QueueClaim)
- func (input *Input) SetWriterKeys(value []WriterKeysRow)
- type InputHas
- type Output
- type QueueClaim
- func (entity *QueueClaim) GetApprovedAt() *time.Time
- func (entity *QueueClaim) GetApprovedByUserId() *string
- func (entity *QueueClaim) GetDecision() *string
- func (entity *QueueClaim) GetExpiresAt() *time.Time
- func (entity *QueueClaim) GetId() string
- func (entity *QueueClaim) GetMetadata() *string
- func (entity *QueueClaim) GetStatus() string
- func (entity *QueueClaim) GetTimedOutAt() *time.Time
- func (entity *QueueClaim) GetUpdatedAt() *time.Time
- func (entity *QueueClaim) GetUserId() string
- func (entity *QueueClaim) SetApprovedAt(value *time.Time)
- func (entity *QueueClaim) SetApprovedByUserId(value *string)
- func (entity *QueueClaim) SetDecision(value *string)
- func (entity *QueueClaim) SetExpiresAt(value *time.Time)
- func (entity *QueueClaim) SetId(value string)
- func (entity *QueueClaim) SetMetadata(value *string)
- func (entity *QueueClaim) SetStatus(value string)
- func (entity *QueueClaim) SetTimedOutAt(value *time.Time)
- func (entity *QueueClaim) SetUpdatedAt(value *time.Time)
- func (entity *QueueClaim) SetUserId(value string)
- type QueueClaimHas
- type WriterComponent
- type WriterHandlerCurrentWriterGroupedByApprovedAt
- type WriterHandlerCurrentWriterGroupedByApprovedByUserId
- type WriterHandlerCurrentWriterGroupedByDecision
- type WriterHandlerCurrentWriterGroupedByExpiresAt
- type WriterHandlerCurrentWriterGroupedById
- type WriterHandlerCurrentWriterGroupedByMetadata
- type WriterHandlerCurrentWriterGroupedByStatus
- type WriterHandlerCurrentWriterGroupedByTimedOutAt
- type WriterHandlerCurrentWriterGroupedByUpdatedAt
- type WriterHandlerCurrentWriterGroupedByUserId
- type WriterHandlerCurrentWriterIndexedByApprovedAt
- type WriterHandlerCurrentWriterIndexedByApprovedByUserId
- type WriterHandlerCurrentWriterIndexedByDecision
- type WriterHandlerCurrentWriterIndexedByExpiresAt
- type WriterHandlerCurrentWriterIndexedById
- type WriterHandlerCurrentWriterIndexedByMetadata
- type WriterHandlerCurrentWriterIndexedByStatus
- type WriterHandlerCurrentWriterIndexedByTimedOutAt
- type WriterHandlerCurrentWriterIndexedByUpdatedAt
- type WriterHandlerCurrentWriterIndexedByUserId
- type WriterHandlerCurrentWriterSlice
- func (rows WriterHandlerCurrentWriterSlice) GroupByApprovedAt() WriterHandlerCurrentWriterGroupedByApprovedAt
- func (rows WriterHandlerCurrentWriterSlice) GroupByApprovedByUserId() WriterHandlerCurrentWriterGroupedByApprovedByUserId
- func (rows WriterHandlerCurrentWriterSlice) GroupByDecision() WriterHandlerCurrentWriterGroupedByDecision
- func (rows WriterHandlerCurrentWriterSlice) GroupByExpiresAt() WriterHandlerCurrentWriterGroupedByExpiresAt
- func (rows WriterHandlerCurrentWriterSlice) GroupById() WriterHandlerCurrentWriterGroupedById
- func (rows WriterHandlerCurrentWriterSlice) GroupByMetadata() WriterHandlerCurrentWriterGroupedByMetadata
- func (rows WriterHandlerCurrentWriterSlice) GroupByStatus() WriterHandlerCurrentWriterGroupedByStatus
- func (rows WriterHandlerCurrentWriterSlice) GroupByTimedOutAt() WriterHandlerCurrentWriterGroupedByTimedOutAt
- func (rows WriterHandlerCurrentWriterSlice) GroupByUpdatedAt() WriterHandlerCurrentWriterGroupedByUpdatedAt
- func (rows WriterHandlerCurrentWriterSlice) GroupByUserId() WriterHandlerCurrentWriterGroupedByUserId
- func (rows WriterHandlerCurrentWriterSlice) IndexByApprovedAt() (WriterHandlerCurrentWriterIndexedByApprovedAt, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByApprovedByUserId() (WriterHandlerCurrentWriterIndexedByApprovedByUserId, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByDecision() (WriterHandlerCurrentWriterIndexedByDecision, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByExpiresAt() (WriterHandlerCurrentWriterIndexedByExpiresAt, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexById() (WriterHandlerCurrentWriterIndexedById, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByMetadata() (WriterHandlerCurrentWriterIndexedByMetadata, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByStatus() (WriterHandlerCurrentWriterIndexedByStatus, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByTimedOutAt() (WriterHandlerCurrentWriterIndexedByTimedOutAt, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByUpdatedAt() (WriterHandlerCurrentWriterIndexedByUpdatedAt, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByUserId() (WriterHandlerCurrentWriterIndexedByUserId, error)
- type WriterHandlerReadIndexes
- type WriterKeysRow
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 ¶
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) ReadIndexes ¶
func (input *Input) ReadIndexes(ctx context.Context) (*WriterHandlerReadIndexes, error)
func (*Input) SetCurrentWriter ¶
func (input *Input) SetCurrentWriter(value []*CurrentWriterView)
func (*Input) SetDeadlineClock ¶
func (*Input) SetDeadlineElapsedClock ¶
func (*Input) SetExpectedStatus ¶
func (*Input) SetExpectedUpdatedAt ¶
func (*Input) SetPrincipal ¶
func (*Input) SetQueues ¶
func (input *Input) SetQueues(value []*QueueClaim)
func (*Input) SetWriterKeys ¶
func (input *Input) SetWriterKeys(value []WriterKeysRow)
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 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
type WriterHandlerCurrentWriterGroupedByApprovedByUserId ¶
type WriterHandlerCurrentWriterGroupedByApprovedByUserId map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByApprovedByUserId) Has ¶
func (index WriterHandlerCurrentWriterGroupedByApprovedByUserId) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByDecision ¶
type WriterHandlerCurrentWriterGroupedByDecision map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByDecision) Has ¶
func (index WriterHandlerCurrentWriterGroupedByDecision) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByExpiresAt ¶
type WriterHandlerCurrentWriterGroupedByExpiresAt map[time.Time][]*CurrentWriterView
type WriterHandlerCurrentWriterGroupedById ¶
type WriterHandlerCurrentWriterGroupedById map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedById) Has ¶
func (index WriterHandlerCurrentWriterGroupedById) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByMetadata ¶
type WriterHandlerCurrentWriterGroupedByMetadata map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByMetadata) Has ¶
func (index WriterHandlerCurrentWriterGroupedByMetadata) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByStatus ¶
type WriterHandlerCurrentWriterGroupedByStatus map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByStatus) Has ¶
func (index WriterHandlerCurrentWriterGroupedByStatus) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByTimedOutAt ¶
type WriterHandlerCurrentWriterGroupedByTimedOutAt map[time.Time][]*CurrentWriterView
type WriterHandlerCurrentWriterGroupedByUpdatedAt ¶
type WriterHandlerCurrentWriterGroupedByUpdatedAt map[time.Time][]*CurrentWriterView
type WriterHandlerCurrentWriterGroupedByUserId ¶
type WriterHandlerCurrentWriterGroupedByUserId map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByUserId) Has ¶
func (index WriterHandlerCurrentWriterGroupedByUserId) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByApprovedAt ¶
type WriterHandlerCurrentWriterIndexedByApprovedAt map[time.Time]*CurrentWriterView
type WriterHandlerCurrentWriterIndexedByApprovedByUserId ¶
type WriterHandlerCurrentWriterIndexedByApprovedByUserId map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByApprovedByUserId) Has ¶
func (index WriterHandlerCurrentWriterIndexedByApprovedByUserId) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByDecision ¶
type WriterHandlerCurrentWriterIndexedByDecision map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByDecision) Has ¶
func (index WriterHandlerCurrentWriterIndexedByDecision) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByExpiresAt ¶
type WriterHandlerCurrentWriterIndexedByExpiresAt map[time.Time]*CurrentWriterView
type WriterHandlerCurrentWriterIndexedById ¶
type WriterHandlerCurrentWriterIndexedById map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedById) Has ¶
func (index WriterHandlerCurrentWriterIndexedById) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByMetadata ¶
type WriterHandlerCurrentWriterIndexedByMetadata map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByMetadata) Has ¶
func (index WriterHandlerCurrentWriterIndexedByMetadata) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByStatus ¶
type WriterHandlerCurrentWriterIndexedByStatus map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByStatus) Has ¶
func (index WriterHandlerCurrentWriterIndexedByStatus) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByTimedOutAt ¶
type WriterHandlerCurrentWriterIndexedByTimedOutAt map[time.Time]*CurrentWriterView
type WriterHandlerCurrentWriterIndexedByUpdatedAt ¶
type WriterHandlerCurrentWriterIndexedByUpdatedAt map[time.Time]*CurrentWriterView
type WriterHandlerCurrentWriterIndexedByUserId ¶
type WriterHandlerCurrentWriterIndexedByUserId map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByUserId) Has ¶
func (index WriterHandlerCurrentWriterIndexedByUserId) Has(key string) bool
type WriterHandlerCurrentWriterSlice ¶
type WriterHandlerCurrentWriterSlice []*CurrentWriterView
func (WriterHandlerCurrentWriterSlice) GroupByApprovedAt ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByApprovedAt() WriterHandlerCurrentWriterGroupedByApprovedAt
func (WriterHandlerCurrentWriterSlice) GroupByApprovedByUserId ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByApprovedByUserId() WriterHandlerCurrentWriterGroupedByApprovedByUserId
func (WriterHandlerCurrentWriterSlice) GroupByDecision ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByDecision() WriterHandlerCurrentWriterGroupedByDecision
func (WriterHandlerCurrentWriterSlice) GroupByExpiresAt ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByExpiresAt() WriterHandlerCurrentWriterGroupedByExpiresAt
func (WriterHandlerCurrentWriterSlice) GroupById ¶
func (rows WriterHandlerCurrentWriterSlice) GroupById() WriterHandlerCurrentWriterGroupedById
func (WriterHandlerCurrentWriterSlice) GroupByMetadata ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByMetadata() WriterHandlerCurrentWriterGroupedByMetadata
func (WriterHandlerCurrentWriterSlice) GroupByStatus ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByStatus() WriterHandlerCurrentWriterGroupedByStatus
func (WriterHandlerCurrentWriterSlice) GroupByTimedOutAt ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByTimedOutAt() WriterHandlerCurrentWriterGroupedByTimedOutAt
func (WriterHandlerCurrentWriterSlice) GroupByUpdatedAt ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByUpdatedAt() WriterHandlerCurrentWriterGroupedByUpdatedAt
func (WriterHandlerCurrentWriterSlice) GroupByUserId ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByUserId() WriterHandlerCurrentWriterGroupedByUserId
func (WriterHandlerCurrentWriterSlice) IndexByApprovedAt ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByApprovedAt() (WriterHandlerCurrentWriterIndexedByApprovedAt, error)
func (WriterHandlerCurrentWriterSlice) IndexByApprovedByUserId ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByApprovedByUserId() (WriterHandlerCurrentWriterIndexedByApprovedByUserId, error)
func (WriterHandlerCurrentWriterSlice) IndexByDecision ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByDecision() (WriterHandlerCurrentWriterIndexedByDecision, error)
func (WriterHandlerCurrentWriterSlice) IndexByExpiresAt ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByExpiresAt() (WriterHandlerCurrentWriterIndexedByExpiresAt, error)
func (WriterHandlerCurrentWriterSlice) IndexById ¶
func (rows WriterHandlerCurrentWriterSlice) IndexById() (WriterHandlerCurrentWriterIndexedById, error)
func (WriterHandlerCurrentWriterSlice) IndexByMetadata ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByMetadata() (WriterHandlerCurrentWriterIndexedByMetadata, error)
func (WriterHandlerCurrentWriterSlice) IndexByStatus ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByStatus() (WriterHandlerCurrentWriterIndexedByStatus, error)
func (WriterHandlerCurrentWriterSlice) IndexByTimedOutAt ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByTimedOutAt() (WriterHandlerCurrentWriterIndexedByTimedOutAt, error)
func (WriterHandlerCurrentWriterSlice) IndexByUpdatedAt ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByUpdatedAt() (WriterHandlerCurrentWriterIndexedByUpdatedAt, error)
func (WriterHandlerCurrentWriterSlice) IndexByUserId ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByUserId() (WriterHandlerCurrentWriterIndexedByUserId, 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.