sqlplugin

package

Go to main page

Versions in this module

v0

v0.26.0

Jun 28, 2020

Changes in this version

+ type TaskQueuesFilter struct

+ Name *string

+ NameGreaterThan *string

+ NamespaceID *primitives.UUID

+ NamespaceIDGreaterThan *primitives.UUID

+ PageSize *int

+ RangeID *int64

+ ShardID int

+ TaskType *int64

+ TaskTypeGreaterThan *int64

+ type TaskQueuesRow struct

+ Data []byte

+ DataEncoding string

+ Name string

+ NamespaceID primitives.UUID

+ RangeID int64

+ ShardID int

+ TaskType int64

type TasksFilter

+ TaskQueueName string

type TasksRow

+ TaskQueueName string

v0.25.0

Jun 25, 2020

v0.23.1

May 20, 2020

v0.23.0

May 16, 2020

Changes in this version

type NamespaceRow

+ NotificationVersion int64

v0.21.1

Apr 6, 2020

v0.21.0

Apr 4, 2020

Changes in this version

type ActivityInfoMapsFilter

+ NamespaceID primitives.UUID

type ActivityInfoMapsRow

+ NamespaceID primitives.UUID

type BufferedEventsFilter

+ NamespaceID primitives.UUID

type BufferedEventsRow

+ NamespaceID primitives.UUID

type ChildExecutionInfoMapsFilter

+ NamespaceID primitives.UUID

type ChildExecutionInfoMapsRow

+ NamespaceID primitives.UUID

type CurrentExecutionsFilter

+ NamespaceID primitives.UUID

type CurrentExecutionsRow

+ NamespaceID primitives.UUID

+ Status executionpb.WorkflowExecutionStatus

type EventsFilter

+ NamespaceID primitives.UUID

type EventsRow

+ NamespaceID primitives.UUID

type ExecutionsFilter

+ NamespaceID primitives.UUID

type ExecutionsRow

+ NamespaceID primitives.UUID

+ type NamespaceFilter struct

+ GreaterThanID *primitives.UUID

+ ID *primitives.UUID

+ Name *string

+ PageSize *int

+ type NamespaceMetadataRow struct

+ NotificationVersion int64

+ type NamespaceRow struct

+ Data []byte

+ DataEncoding string

+ ID primitives.UUID

+ IsGlobal bool

+ Name string

type RequestCancelInfoMapsFilter

+ NamespaceID primitives.UUID

type RequestCancelInfoMapsRow

+ NamespaceID primitives.UUID

type SignalInfoMapsFilter

+ NamespaceID primitives.UUID

type SignalInfoMapsRow

+ NamespaceID primitives.UUID

type SignalsRequestedSetsFilter

+ NamespaceID primitives.UUID

type SignalsRequestedSetsRow

+ NamespaceID primitives.UUID

type TaskListsFilter

+ NamespaceID *primitives.UUID

+ NamespaceIDGreaterThan *primitives.UUID

type TaskListsRow

+ NamespaceID primitives.UUID

type TasksFilter

+ NamespaceID primitives.UUID

type TasksRow

+ NamespaceID primitives.UUID

type TimerInfoMapsFilter

+ NamespaceID primitives.UUID

type TimerInfoMapsRow

+ NamespaceID primitives.UUID

type VisibilityFilter

+ NamespaceID string

+ Status *int32

type VisibilityRow

+ NamespaceID string

+ Status *int32

v0.20.0

Mar 22, 2020

Changes in this version

+ type ClusterMembershipFilter struct

+ HostIDEquals []byte

+ InsertionOrderGreaterThan uint64

+ LastHeartbeatAfter time.Time

+ MaxRecordCount int

+ RPCAddressEquals string

+ RecordExpiryAfter time.Time

+ RoleEquals persistence.ServiceType

+ SessionStartedAfter time.Time

+ type ClusterMembershipRow struct

+ HostID []byte

+ InsertionOrder uint64

+ LastHeartbeat time.Time

+ RPCAddress string

+ RPCPort uint16

+ RecordExpiry time.Time

+ Role persistence.ServiceType

+ SessionStart time.Time

type ExecutionsRow

+ State []byte

+ StateEncoding string

+ type PruneClusterMembershipFilter struct

+ MaxRecordsAffected int

+ PruneRecordsBefore time.Time

v0.10.0

Feb 5, 2020

Changes in this version

+ type ActivityInfoMapsFilter struct

+ DomainID UUID

+ RunID UUID

+ ScheduleID *int64

+ ShardID int64

+ WorkflowID string

+ type ActivityInfoMapsRow struct

+ Data []byte

+ DataEncoding string

+ DomainID UUID

+ LastHeartbeatDetails []byte

+ LastHeartbeatUpdatedTime time.Time

+ RunID UUID

+ ScheduleID int64

+ ShardID int64

+ WorkflowID string

+ type AdminDB interface

+ Close func() error

+ PluginName func() 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 ChildExecutionInfoMapsFilter struct

+ DomainID UUID

+ InitiatedID *int64

+ RunID UUID

+ ShardID int64

+ WorkflowID string

+ type ChildExecutionInfoMapsRow struct

+ Data []byte

+ DataEncoding string

+ DomainID UUID

+ InitiatedID int64

+ RunID UUID

+ ShardID int64

+ WorkflowID string

+ type ClusterMetadataRow struct

+ ImmutableData []byte

+ ImmutableDataEncoding 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 DB interface

+ BeginTx func() (Tx, error)

+ Close func() error

+ IsDupEntryError func(err error) bool

+ PluginName func() string

+ type DomainFilter struct

+ GreaterThanID *UUID

+ ID *UUID

+ Name *string

+ PageSize *int

+ type DomainMetadataRow struct

+ NotificationVersion int64

+ type DomainRow struct

+ Data []byte

+ DataEncoding string

+ ID UUID

+ IsGlobal bool

+ Name string

+ 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

+ Data []byte

+ DataEncoding string

+ DomainID UUID

+ LastWriteVersion int64

+ NextEventID int64

+ RunID UUID

+ ShardID int

+ VersionHistories []byte

+ VersionHistoriesEncoding string

+ WorkflowID 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

+ ShardID int

+ TreeID UUID

+ type Plugin interface

+ CreateAdminDB func(cfg *config.SQL) (AdminDB, error)

+ CreateDB func(cfg *config.SQL) (DB, error)

+ type QueueMetadataRow struct

+ Data []byte

+ QueueType common.QueueType

+ type QueueRow struct

+ MessageID int

+ MessagePayload []byte

+ QueueType common.QueueType

+ type ReplicationTaskDLQRow struct

+ Data []byte

+ DataEncoding string

+ ShardID int

+ SourceClusterName string

+ TaskID int64

+ type ReplicationTasksDLQFilter struct

+ SourceClusterName string

+ type ReplicationTasksFilter struct

+ InclusiveEndTaskID int64

+ MaxTaskID int64

+ MinTaskID int64

+ PageSize int

+ ShardID int

+ TaskID int64

+ type ReplicationTasksRow struct

+ Data []byte

+ DataEncoding string

+ ShardID int

+ TaskID int64

+ type RequestCancelInfoMapsFilter struct

+ DomainID UUID

+ InitiatedID *int64

+ RunID UUID

+ ShardID int64

+ WorkflowID string

+ type RequestCancelInfoMapsRow struct

+ Data []byte

+ DataEncoding string

+ DomainID UUID

+ InitiatedID int64

+ RunID UUID

+ ShardID int64

+ WorkflowID string

+ type ShardsFilter struct

+ ShardID int64

+ type ShardsRow struct

+ Data []byte

+ DataEncoding string

+ RangeID int64

+ ShardID int64

+ type SignalInfoMapsFilter struct

+ DomainID UUID

+ InitiatedID *int64

+ RunID UUID

+ ShardID int64

+ WorkflowID string

+ type SignalInfoMapsRow struct

+ Data []byte

+ DataEncoding string

+ DomainID UUID

+ InitiatedID int64

+ RunID UUID

+ ShardID 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

+ Data []byte

+ DataEncoding string

+ DomainID UUID

+ 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

+ Data []byte

+ DataEncoding string

+ DomainID UUID

+ TaskID int64

+ TaskListName string

+ TaskType int64

+ type TimerInfoMapsFilter struct

+ DomainID UUID

+ RunID UUID

+ ShardID int64

+ TimerID *string

+ WorkflowID string

+ type TimerInfoMapsRow struct

+ Data []byte

+ DataEncoding string

+ DomainID UUID

+ RunID UUID

+ ShardID int64

+ TimerID string

+ WorkflowID string

+ type TimerTasksFilter struct

+ MaxVisibilityTimestamp *time.Time

+ MinVisibilityTimestamp *time.Time

+ PageSize *int

+ ShardID int

+ TaskID int64

+ VisibilityTimestamp *time.Time

+ type TimerTasksRow struct

+ Data []byte

+ DataEncoding string

+ ShardID int

+ TaskID int64

+ VisibilityTimestamp time.Time

+ type TransferTasksFilter struct

+ MaxTaskID *int64

+ MinTaskID *int64

+ ShardID int

+ TaskID *int64

+ type TransferTasksRow struct

+ Data []byte

+ DataEncoding string

+ ShardID int

+ TaskID int64

+ 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

+ Encoding string

+ ExecutionTime time.Time

+ HistoryLength *int64

+ Memo []byte

+ RunID string

+ StartTime time.Time

+ WorkflowID string

+ WorkflowTypeName string

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