Documentation
¶
Index ¶
- Constants
- Variables
- func LifecycleDatlyType() reflect.Type
- func WriterDatlyType() reflect.Type
- func WriterHandlerCurrentWriterIndexByCreatedAtKey(value *CurrentWriterView) (time.Time, bool)
- func WriterHandlerCurrentWriterIndexByEncTokenKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByLeaseOwnerKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByLeaseUntilKey(value *CurrentWriterView) (time.Time, bool)
- func WriterHandlerCurrentWriterIndexByProviderKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByRefreshStatusKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByUpdatedAtKey(value *CurrentWriterView) (time.Time, bool)
- func WriterHandlerCurrentWriterIndexByUserIdKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByVersionKey(value *CurrentWriterView) (int64, bool)
- type CurrentWriterView
- type Input
- func (input *Input) Init(ctx 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) SetExpectedEncToken(value string)
- func (input *Input) SetExpectedLeaseOwner(value string)
- func (input *Input) SetExpectedVersion(value int64)
- func (input *Input) SetLeaseMode(value string)
- func (input *Input) SetMode(value string)
- func (input *Input) SetToken(value *Token)
- func (input *Input) SetWriterKeys(value []WriterKeysRow)
- type InputHas
- type Lifecycle
- func (hooks *Lifecycle) AfterQueue(ctx context.Context, entity *Token, ...) error
- func (hooks *Lifecycle) AfterSequence(ctx context.Context, entity *Token, ...) error
- func (hooks *Lifecycle) Finalize(ctx context.Context, input *Input, output *Output, outcome xhandler.Outcome) error
- func (hooks *Lifecycle) Init(ctx context.Context, entity *Token, ...) error
- func (hooks *Lifecycle) Validate(ctx context.Context, entity *Token, ...) error
- type Output
- type Token
- func (entity *Token) GetCreatedAt() time.Time
- func (entity *Token) GetEncToken() string
- func (entity *Token) GetLeaseOwner() *string
- func (entity *Token) GetLeaseUntil() *time.Time
- func (entity *Token) GetProvider() string
- func (entity *Token) GetRefreshStatus() string
- func (entity *Token) GetUpdatedAt() *time.Time
- func (entity *Token) GetUserId() string
- func (entity *Token) GetVersion() int64
- func (entity *Token) SetCreatedAt(value time.Time)
- func (entity *Token) SetEncToken(value string)
- func (entity *Token) SetLeaseOwner(value *string)
- func (entity *Token) SetLeaseUntil(value *time.Time)
- func (entity *Token) SetProvider(value string)
- func (entity *Token) SetRefreshStatus(value string)
- func (entity *Token) SetUpdatedAt(value *time.Time)
- func (entity *Token) SetUserId(value string)
- func (entity *Token) SetVersion(value int64)
- type TokenHas
- type WriterComponent
- type WriterHandlerCurrentWriterGroupedByCreatedAt
- type WriterHandlerCurrentWriterGroupedByEncToken
- type WriterHandlerCurrentWriterGroupedByKey
- type WriterHandlerCurrentWriterGroupedByLeaseOwner
- type WriterHandlerCurrentWriterGroupedByLeaseUntil
- type WriterHandlerCurrentWriterGroupedByProvider
- type WriterHandlerCurrentWriterGroupedByRefreshStatus
- type WriterHandlerCurrentWriterGroupedByUpdatedAt
- type WriterHandlerCurrentWriterGroupedByUserId
- type WriterHandlerCurrentWriterGroupedByVersion
- type WriterHandlerCurrentWriterIndexedByCreatedAt
- type WriterHandlerCurrentWriterIndexedByEncToken
- type WriterHandlerCurrentWriterIndexedByKey
- type WriterHandlerCurrentWriterIndexedByLeaseOwner
- type WriterHandlerCurrentWriterIndexedByLeaseUntil
- type WriterHandlerCurrentWriterIndexedByProvider
- type WriterHandlerCurrentWriterIndexedByRefreshStatus
- type WriterHandlerCurrentWriterIndexedByUpdatedAt
- type WriterHandlerCurrentWriterIndexedByUserId
- type WriterHandlerCurrentWriterIndexedByVersion
- type WriterHandlerCurrentWriterKey
- type WriterHandlerCurrentWriterSlice
- func (rows WriterHandlerCurrentWriterSlice) GroupByCreatedAt() WriterHandlerCurrentWriterGroupedByCreatedAt
- func (rows WriterHandlerCurrentWriterSlice) GroupByEncToken() WriterHandlerCurrentWriterGroupedByEncToken
- func (rows WriterHandlerCurrentWriterSlice) GroupByKey() WriterHandlerCurrentWriterGroupedByKey
- func (rows WriterHandlerCurrentWriterSlice) GroupByLeaseOwner() WriterHandlerCurrentWriterGroupedByLeaseOwner
- func (rows WriterHandlerCurrentWriterSlice) GroupByLeaseUntil() WriterHandlerCurrentWriterGroupedByLeaseUntil
- func (rows WriterHandlerCurrentWriterSlice) GroupByProvider() WriterHandlerCurrentWriterGroupedByProvider
- func (rows WriterHandlerCurrentWriterSlice) GroupByRefreshStatus() WriterHandlerCurrentWriterGroupedByRefreshStatus
- func (rows WriterHandlerCurrentWriterSlice) GroupByUpdatedAt() WriterHandlerCurrentWriterGroupedByUpdatedAt
- func (rows WriterHandlerCurrentWriterSlice) GroupByUserId() WriterHandlerCurrentWriterGroupedByUserId
- func (rows WriterHandlerCurrentWriterSlice) GroupByVersion() WriterHandlerCurrentWriterGroupedByVersion
- func (rows WriterHandlerCurrentWriterSlice) IndexByCreatedAt() (WriterHandlerCurrentWriterIndexedByCreatedAt, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByEncToken() (WriterHandlerCurrentWriterIndexedByEncToken, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByKey() (WriterHandlerCurrentWriterIndexedByKey, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByLeaseOwner() (WriterHandlerCurrentWriterIndexedByLeaseOwner, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByLeaseUntil() (WriterHandlerCurrentWriterIndexedByLeaseUntil, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByProvider() (WriterHandlerCurrentWriterIndexedByProvider, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByRefreshStatus() (WriterHandlerCurrentWriterIndexedByRefreshStatus, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByUpdatedAt() (WriterHandlerCurrentWriterIndexedByUpdatedAt, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByUserId() (WriterHandlerCurrentWriterIndexedByUserId, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByVersion() (WriterHandlerCurrentWriterIndexedByVersion, error)
- type WriterHandlerReadIndexes
- type WriterKeysRow
Constants ¶
View Source
const WriterDatlyResourceNamespace = "oauth_token_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 WriterDatlyType ¶
WriterDatlyType returns the public component type.
func WriterHandlerCurrentWriterIndexByCreatedAtKey ¶
func WriterHandlerCurrentWriterIndexByCreatedAtKey(value *CurrentWriterView) (time.Time, bool)
func WriterHandlerCurrentWriterIndexByEncTokenKey ¶
func WriterHandlerCurrentWriterIndexByEncTokenKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByLeaseOwnerKey ¶
func WriterHandlerCurrentWriterIndexByLeaseOwnerKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByLeaseUntilKey ¶
func WriterHandlerCurrentWriterIndexByLeaseUntilKey(value *CurrentWriterView) (time.Time, bool)
func WriterHandlerCurrentWriterIndexByProviderKey ¶
func WriterHandlerCurrentWriterIndexByProviderKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByRefreshStatusKey ¶
func WriterHandlerCurrentWriterIndexByRefreshStatusKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByUpdatedAtKey ¶
func WriterHandlerCurrentWriterIndexByUpdatedAtKey(value *CurrentWriterView) (time.Time, bool)
func WriterHandlerCurrentWriterIndexByUserIdKey ¶
func WriterHandlerCurrentWriterIndexByUserIdKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByVersionKey ¶
func WriterHandlerCurrentWriterIndexByVersionKey(value *CurrentWriterView) (int64, bool)
Types ¶
type CurrentWriterView ¶
type CurrentWriterView struct {
UserId string `sqlx:"user_id,primaryKey,refTable=users,refColumn=id,required=true" json:"userId,omitempty"`
Provider string `sqlx:"provider,primaryKey,required=true" json:"provider,omitempty"`
EncToken string `json:"encToken,omitempty" sqlx:"enc_token,required=true"`
CreatedAt time.Time `format:"2006-01-02 15:04:05" sqlx:"created_at,required=true" json:"createdAt,omitempty"`
UpdatedAt *time.Time `format:"2006-01-02 15:04:05" sqlx:"updated_at" json:"updatedAt,omitempty"`
Version int64 `json:"version" sqlx:"version,required=true"`
RefreshStatus string `json:"refreshStatus" sqlx:"refresh_status,required=true"`
LeaseOwner *string `json:"leaseOwner" sqlx:"lease_owner"`
LeaseUntil *time.Time `json:"leaseUntil" sqlx:"lease_until"`
}
CurrentWriterView is generated canonical view metadata for writer.
type Input ¶
type Input struct {
Token *Token `` /* 191-byte string literal not displayed */
Mode string `parameter:"Mode,kind=query,in=mode,dataType=string,required=false"`
ExpectedVersion int64 `` /* 138-byte string literal not displayed */
ExpectedLeaseOwner string `` /* 149-byte string literal not displayed */
ExpectedEncToken string `` /* 143-byte string literal not displayed */
LeaseMode string `` /* 179-byte string literal not displayed */
WriterKeys []WriterKeysRow `` /* 127-byte string literal not displayed */
CurrentWriter []*CurrentWriterView `` /* 171-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 keeps mutation modes on an existing composite identity. Missing rows are no-ops for clear/release/CAS instead of becoming incomplete inserts.
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) SetExpectedEncToken ¶
func (*Input) SetExpectedLeaseOwner ¶
func (*Input) SetExpectedVersion ¶
func (*Input) SetLeaseMode ¶
func (*Input) SetWriterKeys ¶
func (input *Input) SetWriterKeys(value []WriterKeysRow)
type Lifecycle ¶
type Lifecycle struct {
Input *Input `bind:"kind=input"`
}
Lifecycle customizes role Input.Token.
func (*Lifecycle) AfterQueue ¶
func (*Lifecycle) AfterSequence ¶
type Output ¶
type Output struct {
Data *Token `parameter:"Data,kind=output,in=body,dataType=*Token" json:"data,omitempty"`
}
Output is the generated output scaffold for writer.
type Token ¶
type Token struct {
UserId string `sqlx:"user_id,primaryKey,refTable=users,refColumn=id,required=true" json:"userId,omitempty"`
Provider string `sqlx:"provider,primaryKey,required=true" json:"provider,omitempty"`
EncToken string `json:"encToken,omitempty" sqlx:"enc_token,required=true"`
CreatedAt time.Time `format:"2006-01-02 15:04:05" sqlx:"created_at,required=true" json:"createdAt,omitempty"`
UpdatedAt *time.Time `format:"2006-01-02 15:04:05" sqlx:"updated_at" json:"updatedAt,omitempty"`
Version int64 `json:"version" sqlx:"version,required=true"`
RefreshStatus string `json:"refreshStatus" sqlx:"refresh_status,required=true"`
LeaseOwner *string `json:"leaseOwner" sqlx:"lease_owner"`
LeaseUntil *time.Time `json:"leaseUntil" sqlx:"lease_until"`
Has *TokenHas `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-" typeName:"TokenHas"`
}
Token is generated canonical view metadata for writer.
func (*Token) GetCreatedAt ¶
func (*Token) GetEncToken ¶
func (*Token) GetLeaseOwner ¶
func (*Token) GetLeaseUntil ¶
func (*Token) GetProvider ¶
func (*Token) GetRefreshStatus ¶
func (*Token) GetUpdatedAt ¶
func (*Token) GetVersion ¶
func (*Token) SetCreatedAt ¶
func (*Token) SetEncToken ¶
func (*Token) SetLeaseOwner ¶
func (*Token) SetLeaseUntil ¶
func (*Token) SetProvider ¶
func (*Token) SetRefreshStatus ¶
func (*Token) SetUpdatedAt ¶
func (*Token) SetVersion ¶
type WriterComponent ¶
type WriterComponent struct {
Contract xdatly.Component[Input, Output] "" /* 167-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 WriterHandlerCurrentWriterGroupedByCreatedAt ¶
type WriterHandlerCurrentWriterGroupedByCreatedAt map[time.Time][]*CurrentWriterView
type WriterHandlerCurrentWriterGroupedByEncToken ¶
type WriterHandlerCurrentWriterGroupedByEncToken map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByEncToken) Has ¶
func (index WriterHandlerCurrentWriterGroupedByEncToken) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByKey ¶
type WriterHandlerCurrentWriterGroupedByKey map[WriterHandlerCurrentWriterKey][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByKey) Has ¶
func (index WriterHandlerCurrentWriterGroupedByKey) Has(key WriterHandlerCurrentWriterKey) bool
type WriterHandlerCurrentWriterGroupedByLeaseOwner ¶
type WriterHandlerCurrentWriterGroupedByLeaseOwner map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByLeaseOwner) Has ¶
func (index WriterHandlerCurrentWriterGroupedByLeaseOwner) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByLeaseUntil ¶
type WriterHandlerCurrentWriterGroupedByLeaseUntil map[time.Time][]*CurrentWriterView
type WriterHandlerCurrentWriterGroupedByProvider ¶
type WriterHandlerCurrentWriterGroupedByProvider map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByProvider) Has ¶
func (index WriterHandlerCurrentWriterGroupedByProvider) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByRefreshStatus ¶
type WriterHandlerCurrentWriterGroupedByRefreshStatus map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByRefreshStatus) Has ¶
func (index WriterHandlerCurrentWriterGroupedByRefreshStatus) Has(key string) bool
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 WriterHandlerCurrentWriterGroupedByVersion ¶
type WriterHandlerCurrentWriterGroupedByVersion map[int64][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByVersion) Has ¶
func (index WriterHandlerCurrentWriterGroupedByVersion) Has(key int64) bool
type WriterHandlerCurrentWriterIndexedByCreatedAt ¶
type WriterHandlerCurrentWriterIndexedByCreatedAt map[time.Time]*CurrentWriterView
type WriterHandlerCurrentWriterIndexedByEncToken ¶
type WriterHandlerCurrentWriterIndexedByEncToken map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByEncToken) Has ¶
func (index WriterHandlerCurrentWriterIndexedByEncToken) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByKey ¶
type WriterHandlerCurrentWriterIndexedByKey map[WriterHandlerCurrentWriterKey]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByKey) Has ¶
func (index WriterHandlerCurrentWriterIndexedByKey) Has(key WriterHandlerCurrentWriterKey) bool
type WriterHandlerCurrentWriterIndexedByLeaseOwner ¶
type WriterHandlerCurrentWriterIndexedByLeaseOwner map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByLeaseOwner) Has ¶
func (index WriterHandlerCurrentWriterIndexedByLeaseOwner) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByLeaseUntil ¶
type WriterHandlerCurrentWriterIndexedByLeaseUntil map[time.Time]*CurrentWriterView
type WriterHandlerCurrentWriterIndexedByProvider ¶
type WriterHandlerCurrentWriterIndexedByProvider map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByProvider) Has ¶
func (index WriterHandlerCurrentWriterIndexedByProvider) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByRefreshStatus ¶
type WriterHandlerCurrentWriterIndexedByRefreshStatus map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByRefreshStatus) Has ¶
func (index WriterHandlerCurrentWriterIndexedByRefreshStatus) Has(key string) bool
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 WriterHandlerCurrentWriterIndexedByVersion ¶
type WriterHandlerCurrentWriterIndexedByVersion map[int64]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByVersion) Has ¶
func (index WriterHandlerCurrentWriterIndexedByVersion) Has(key int64) bool
type WriterHandlerCurrentWriterKey ¶
func WriterHandlerCurrentWriterIndexByKeyKey ¶
func WriterHandlerCurrentWriterIndexByKeyKey(value *CurrentWriterView) (WriterHandlerCurrentWriterKey, bool)
type WriterHandlerCurrentWriterSlice ¶
type WriterHandlerCurrentWriterSlice []*CurrentWriterView
func (WriterHandlerCurrentWriterSlice) GroupByCreatedAt ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByCreatedAt() WriterHandlerCurrentWriterGroupedByCreatedAt
func (WriterHandlerCurrentWriterSlice) GroupByEncToken ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByEncToken() WriterHandlerCurrentWriterGroupedByEncToken
func (WriterHandlerCurrentWriterSlice) GroupByKey ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByKey() WriterHandlerCurrentWriterGroupedByKey
func (WriterHandlerCurrentWriterSlice) GroupByLeaseOwner ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByLeaseOwner() WriterHandlerCurrentWriterGroupedByLeaseOwner
func (WriterHandlerCurrentWriterSlice) GroupByLeaseUntil ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByLeaseUntil() WriterHandlerCurrentWriterGroupedByLeaseUntil
func (WriterHandlerCurrentWriterSlice) GroupByProvider ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByProvider() WriterHandlerCurrentWriterGroupedByProvider
func (WriterHandlerCurrentWriterSlice) GroupByRefreshStatus ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByRefreshStatus() WriterHandlerCurrentWriterGroupedByRefreshStatus
func (WriterHandlerCurrentWriterSlice) GroupByUpdatedAt ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByUpdatedAt() WriterHandlerCurrentWriterGroupedByUpdatedAt
func (WriterHandlerCurrentWriterSlice) GroupByUserId ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByUserId() WriterHandlerCurrentWriterGroupedByUserId
func (WriterHandlerCurrentWriterSlice) GroupByVersion ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByVersion() WriterHandlerCurrentWriterGroupedByVersion
func (WriterHandlerCurrentWriterSlice) IndexByCreatedAt ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByCreatedAt() (WriterHandlerCurrentWriterIndexedByCreatedAt, error)
func (WriterHandlerCurrentWriterSlice) IndexByEncToken ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByEncToken() (WriterHandlerCurrentWriterIndexedByEncToken, error)
func (WriterHandlerCurrentWriterSlice) IndexByKey ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByKey() (WriterHandlerCurrentWriterIndexedByKey, error)
func (WriterHandlerCurrentWriterSlice) IndexByLeaseOwner ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByLeaseOwner() (WriterHandlerCurrentWriterIndexedByLeaseOwner, error)
func (WriterHandlerCurrentWriterSlice) IndexByLeaseUntil ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByLeaseUntil() (WriterHandlerCurrentWriterIndexedByLeaseUntil, error)
func (WriterHandlerCurrentWriterSlice) IndexByProvider ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByProvider() (WriterHandlerCurrentWriterIndexedByProvider, error)
func (WriterHandlerCurrentWriterSlice) IndexByRefreshStatus ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByRefreshStatus() (WriterHandlerCurrentWriterIndexedByRefreshStatus, error)
func (WriterHandlerCurrentWriterSlice) IndexByUpdatedAt ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByUpdatedAt() (WriterHandlerCurrentWriterIndexedByUpdatedAt, error)
func (WriterHandlerCurrentWriterSlice) IndexByUserId ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByUserId() (WriterHandlerCurrentWriterIndexedByUserId, error)
func (WriterHandlerCurrentWriterSlice) IndexByVersion ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByVersion() (WriterHandlerCurrentWriterIndexedByVersion, error)
type WriterHandlerReadIndexes ¶
type WriterHandlerReadIndexes struct {
CurrentWriter WriterHandlerCurrentWriterSlice
CurrentWriterByKey WriterHandlerCurrentWriterIndexedByKey
}
func BuildWriterHandlerReadIndexes ¶
func BuildWriterHandlerReadIndexes(ctx context.Context, input *Input) (*WriterHandlerReadIndexes, error)
type WriterKeysRow ¶
Click to show internal directories.
Click to hide internal directories.