sqldb

package

Go to main page

Versions in this module

v0

v0.8.5

Aug 27, 2019

v0.8.3

Aug 14, 2019

v0.7.1

Aug 6, 2019

v0.6.1

Jul 26, 2019

v0.6.0

Jul 24, 2019

v0.5.7

May 8, 2019

Changes in this version

type ActivityInfoMapsRow

+ Data []byte

+ DataEncoding string

+ LastHeartbeatDetails []byte

type BufferedReplicationTaskMapsRow

+ EventStoreVersion int32

+ NewRunEventStoreVersion int32

type ChildExecutionInfoMapsRow

+ Data []byte

+ DataEncoding string

type DomainFilter

+ GreaterThanID *UUID

+ PageSize *int

type DomainRow

+ DataEncoding string

+ IsGlobal bool

type ExecutionsRow

+ Data []byte

+ DataEncoding string

+ type HistoryNodeFilter struct

+ BranchID UUID

+ MaxNodeID *int64

+ MinNodeID *int64

+ PageSize *int

+ ShardID int

+ TreeID UUID

+ type HistoryNodeRow struct

+ BranchID UUID

+ Data []byte

+ DataEncoding string

+ NodeID int64

+ ShardID int

+ TreeID UUID

+ TxnID *int64

+ type HistoryTreeFilter struct

+ BranchID *UUID

+ ShardID int

+ TreeID UUID

+ type HistoryTreeRow struct

+ BranchID UUID

+ Data []byte

+ DataEncoding string

+ InProgress bool

+ ShardID int

+ TreeID UUID

type ReplicationTasksRow

+ Data []byte

+ DataEncoding string

type RequestCancelInfoMapsRow

+ Data []byte

+ DataEncoding string

type ShardsRow

+ Data []byte

+ DataEncoding string

type SignalInfoMapsRow

+ Data []byte

+ DataEncoding string

type TaskListsRow

+ Data []byte

+ DataEncoding string

type TasksRow

+ Data []byte

+ DataEncoding string

type TimerInfoMapsRow

+ Data []byte

+ DataEncoding string

type TimerTasksRow

+ Data []byte

+ DataEncoding string

type TransferTasksRow

+ Data []byte

+ DataEncoding string

type VisibilityRow

+ Encoding string

+ ExecutionTime time.Time

+ Memo []byte

v0.5.4

Mar 8, 2019

Changes in this version

+ type ActivityInfoMapsFilter struct

+ DomainID UUID

+ RunID UUID

+ ScheduleID *int64

+ ShardID int64

+ WorkflowID string

+ type ActivityInfoMapsRow struct

+ ActivityID string

+ Attempt int64

+ BackoffCoefficient float64

+ CancelRequestID int64

+ CancelRequested int64

+ Details *[]byte

+ DomainID UUID

+ ExpirationTime time.Time

+ HasRetryPolicy int64

+ HeartbeatTimeout int64

+ InitInterval int64

+ LastHeartbeatUpdatedTime time.Time

+ MaxAttempts int64

+ MaxInterval int64

+ NonRetriableErrors *[]byte

+ RequestID string

+ RunID UUID

+ ScheduleID int64

+ ScheduleToCloseTimeout int64

+ ScheduleToStartTimeout int64

+ ScheduledEvent []byte

+ ScheduledEventBatchID int64

+ ScheduledEventEncoding string

+ ScheduledTime time.Time

+ ShardID int64

+ StartToCloseTimeout int64

+ StartedEvent *[]byte

+ StartedEventEncoding string

+ StartedID int64

+ StartedIdentity string

+ StartedTime time.Time

+ TaskList string

+ TimerTaskStatus int64

+ Version int64

+ WorkflowID string

+ type BufferedEventsFilter struct

+ DomainID UUID

+ RunID UUID

+ ShardID int

+ WorkflowID string

+ type BufferedEventsRow struct

+ Data []byte

+ DataEncoding string

+ DomainID UUID

+ RunID UUID

+ ShardID int

+ WorkflowID string

+ type BufferedReplicationTaskMapsFilter struct

+ DomainID UUID

+ FirstEventID *int64

+ RunID UUID

+ ShardID int64

+ WorkflowID string

+ type BufferedReplicationTaskMapsRow struct

+ DomainID UUID

+ FirstEventID int64

+ History *[]byte

+ HistoryEncoding string

+ NewRunHistory *[]byte

+ NewRunHistoryEncoding string

+ NextEventID int64

+ RunID UUID

+ ShardID int64

+ Version int64

+ WorkflowID string

+ type ChildExecutionInfoMapsFilter struct

+ DomainID UUID

+ InitiatedID *int64

+ RunID UUID

+ ShardID int64

+ WorkflowID string

+ type ChildExecutionInfoMapsRow struct

+ CreateRequestID string

+ DomainID UUID

+ DomainName string

+ InitiatedEvent *[]byte

+ InitiatedEventBatchID int64

+ InitiatedEventEncoding string

+ InitiatedID int64

+ RunID UUID

+ ShardID int64

+ StartedEvent *[]byte

+ StartedEventEncoding string

+ StartedID int64

+ StartedRunID string

+ StartedWorkflowID string

+ Version int64

+ WorkflowID string

+ WorkflowTypeName string

+ type Conn interface

+ Exec func(query string, args ...interface{}) (sql.Result, error)

+ Get func(dest interface{}, query string, args ...interface{}) error

+ NamedExec func(query string, arg interface{}) (sql.Result, error)

+ Select func(dest interface{}, query string, args ...interface{}) error

+ type CurrentExecutionsFilter struct

+ DomainID UUID

+ RunID UUID

+ ShardID int64

+ WorkflowID string

+ type CurrentExecutionsRow struct

+ CloseStatus int

+ CreateRequestID string

+ DomainID UUID

+ LastWriteVersion int64

+ RunID UUID

+ ShardID int64

+ StartVersion int64

+ State int

+ WorkflowID string

+ type DomainFilter struct

+ ID *UUID

+ Name *string

+ type DomainMetadataRow struct

+ NotificationVersion int64

+ type DomainRow struct

+ ActiveClusterName string

+ ArchivalBucket string

+ ArchivalStatus int

+ Clusters []byte

+ ConfigVersion int64

+ Data []byte

+ Description string

+ EmitMetric bool

+ FailoverNotificationVersion int64

+ FailoverVersion int64

+ ID UUID

+ IsGlobalDomain bool

+ Name string

+ NotificationVersion int64

+ OwnerEmail string

+ Retention int

+ Status int

+ type EventsFilter struct

+ DomainID UUID

+ FirstEventID *int64

+ NextEventID *int64

+ PageSize *int

+ RunID UUID

+ WorkflowID string

+ type EventsRow struct

+ BatchVersion int64

+ Data []byte

+ DataEncoding string

+ DomainID UUID

+ FirstEventID int64

+ RangeID int64

+ RunID UUID

+ TxID int64

+ WorkflowID string

+ type ExecutionsFilter struct

+ DomainID UUID

+ RunID UUID

+ ShardID int

+ WorkflowID string

+ type ExecutionsRow struct

+ Attempt int

+ BackoffCoefficient float64

+ CancelRequestID *string

+ CancelRequested *int64

+ ClientFeatureVersion string

+ ClientImpl string

+ ClientLibraryVersion string

+ CloseStatus int64

+ CompletionEvent *[]byte

+ CompletionEventBatchID *int64

+ CompletionEventEncoding *string

+ CreateRequestID string

+ CronSchedule string

+ CurrentVersion int64

+ DecisionAttempt int64

+ DecisionRequestID string

+ DecisionScheduleID int64

+ DecisionStartedID int64

+ DecisionTaskTimeoutMinutes int64

+ DecisionTimeout int64

+ DecisionTimestamp int64

+ DecisionVersion int64

+ DomainID UUID

+ ExecutionContext *[]byte

+ ExpirationSeconds int

+ ExpirationTime time.Time

+ HasRetryPolicy bool

+ HistorySize int64

+ InitialInterval int

+ InitiatedID *int64

+ LastEventTaskID int64

+ LastFirstEventID int64

+ LastProcessedEvent int64

+ LastReplicationInfo *[]byte

+ LastUpdatedTime time.Time

+ LastWriteEventID *int64

+ LastWriteVersion int64

+ MaximumAttempts int

+ MaximumInterval int

+ NextEventID int64

+ NonRetryableErrors []byte

+ ParentDomainID *UUID

+ ParentRunID *UUID

+ ParentWorkflowID *string

+ RunID UUID

+ ShardID int

+ SignalCount int

+ StartTime time.Time

+ StartVersion int64

+ State int64

+ StickyScheduleToStartTimeout int64

+ StickyTaskList string

+ TaskList string

+ WorkflowID string

+ WorkflowTimeoutSeconds int64

+ WorkflowTypeName string

+ type Interface interface

+ BeginTx func() (Tx, error)

+ Close func() error

+ DriverName func() string

+ type ReplicationTasksFilter struct

+ MaxTaskID *int64

+ MinTaskID *int64

+ PageSize *int

+ ShardID int

+ TaskID *int64

+ type ReplicationTasksRow struct

+ DomainID UUID

+ FirstEventID int64

+ LastReplicationInfo []byte

+ NextEventID int64

+ RunID UUID

+ ScheduledID int64

+ ShardID int

+ TaskID int64

+ TaskType int

+ Version int64

+ WorkflowID string

+ type RequestCancelInfoMapsFilter struct

+ DomainID UUID

+ InitiatedID *int64

+ RunID UUID

+ ShardID int64

+ WorkflowID string

+ type RequestCancelInfoMapsRow struct

+ CancelRequestID string

+ DomainID UUID

+ InitiatedID int64

+ RunID UUID

+ ShardID int64

+ Version int64

+ WorkflowID string

+ type ShardsFilter struct

+ ShardID int64

+ type ShardsRow struct

+ ClusterTimerAckLevel []byte

+ ClusterTransferAckLevel []byte

+ DomainNotificationVersion int64

+ Owner string

+ RangeID int64

+ ReplicationAckLevel int64

+ ShardID int64

+ StolenSinceRenew int64

+ TimerAckLevel time.Time

+ TransferAckLevel int64

+ UpdatedAt time.Time

+ type SignalInfoMapsFilter struct

+ DomainID UUID

+ InitiatedID *int64

+ RunID UUID

+ ShardID int64

+ WorkflowID string

+ type SignalInfoMapsRow struct

+ Control *[]byte

+ DomainID UUID

+ InitiatedID int64

+ Input *[]byte

+ RunID UUID

+ ShardID int64

+ SignalName string

+ SignalRequestID string

+ Version int64

+ WorkflowID string

+ type SignalsRequestedSetsFilter struct

+ DomainID UUID

+ RunID UUID

+ ShardID int64

+ SignalID *string

+ WorkflowID string

+ type SignalsRequestedSetsRow struct

+ DomainID UUID

+ RunID UUID

+ ShardID int64

+ SignalID string

+ WorkflowID string

+ type TaskListsFilter struct

+ DomainID *UUID

+ DomainIDGreaterThan *UUID

+ Name *string

+ NameGreaterThan *string

+ PageSize *int

+ RangeID *int64

+ ShardID int

+ TaskType *int64

+ TaskTypeGreaterThan *int64

+ type TaskListsRow struct

+ AckLevel int64

+ DomainID UUID

+ ExpiryTs time.Time

+ Kind int64

+ LastUpdated time.Time

+ Name string

+ RangeID int64

+ ShardID int

+ TaskType int64

+ type TasksFilter struct

+ DomainID UUID

+ Limit *int

+ MaxTaskID *int64

+ MinTaskID *int64

+ PageSize *int

+ TaskID *int64

+ TaskIDLessThanEquals *int64

+ TaskListName string

+ TaskType int64

+ type TasksRow struct

+ DomainID UUID

+ ExpiryTs time.Time

+ RunID UUID

+ ScheduleID int64

+ TaskID int64

+ TaskListName string

+ TaskType int64

+ WorkflowID string

+ type TimerInfoMapsFilter struct

+ DomainID UUID

+ RunID UUID

+ ShardID int64

+ TimerID *string

+ WorkflowID string

+ type TimerInfoMapsRow struct

+ DomainID UUID

+ ExpiryTime time.Time

+ RunID UUID

+ ShardID int64

+ StartedID int64

+ TaskID int64

+ TimerID string

+ Version int64

+ WorkflowID string

+ type TimerTasksFilter struct

+ MaxVisibilityTimestamp *time.Time

+ MinVisibilityTimestamp *time.Time

+ PageSize *int

+ ShardID int

+ TaskID int64

+ VisibilityTimestamp *time.Time

+ type TimerTasksRow struct

+ DomainID UUID

+ EventID int64

+ RunID UUID

+ ScheduleAttempt int64

+ ShardID int

+ TaskID int64

+ TaskType int

+ TimeoutType int

+ Version int64

+ VisibilityTimestamp time.Time

+ WorkflowID string

+ type TransferTasksFilter struct

+ MaxTaskID *int64

+ MinTaskID *int64

+ ShardID int

+ TaskID *int64

+ type TransferTasksRow struct

+ DomainID UUID

+ RunID UUID

+ ScheduleID int64

+ ShardID int

+ TargetChildWorkflowOnly bool

+ TargetDomainID UUID

+ TargetRunID UUID

+ TargetWorkflowID string

+ TaskID int64

+ TaskList string

+ TaskType int

+ Version int64

+ VisibilityTimestamp time.Time

+ WorkflowID string

+ type Tx interface

+ Commit func() error

+ Rollback func() error

+ type UUID []byte

+ func MustParseUUID(s string) UUID

+ func UUIDPtr(u UUID) *UUID

+ func (u *UUID) Scan(src interface{}) error

+ func (u UUID) String() string

+ func (u UUID) Value() (driver.Value, error)

+ type VisibilityFilter struct

+ CloseStatus *int32

+ Closed bool

+ DomainID string

+ MaxStartTime *time.Time

+ MinStartTime *time.Time

+ PageSize *int

+ RunID *string

+ WorkflowID *string

+ WorkflowTypeName *string

+ type VisibilityRow struct

+ CloseStatus *int32

+ CloseTime *time.Time

+ DomainID string

+ HistoryLength *int64

+ RunID string

+ StartTime time.Time

+ WorkflowID string

+ WorkflowTypeName string

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