sqlplugin

Sep 6, 2024

Changes in this version

+ var DatabaseUnavailableError = serviceerror.NewUnavailable("no usable database connection found")

type CurrentExecutionsRow

+ StartTime *time.Time

+ type DatabaseHandle struct

+ func NewDatabaseHandle(connect func() (*sqlx.DB, error), needsRefresh func(error) bool, ...) *DatabaseHandle

+ func (h *DatabaseHandle) Close()

+ func (h *DatabaseHandle) Conn() Conn

+ func (h *DatabaseHandle) ConvertError(err error) error

+ func (h *DatabaseHandle) DB() (*sqlx.DB, error)

+ type ListNexusEndpointsRequest struct

+ LastID []byte

+ Limit int

+ type NexusEndpoints interface

+ DeleteFromNexusEndpoints func(ctx context.Context, id []byte) (sql.Result, error)

+ GetNexusEndpointByID func(ctx context.Context, serviceID []byte) (*NexusEndpointsRow, error)

+ GetNexusEndpointsTableVersion func(ctx context.Context) (int64, error)

+ IncrementNexusEndpointsTableVersion func(ctx context.Context, lastKnownTableVersion int64) (sql.Result, error)

+ InitializeNexusEndpointsTableVersion func(ctx context.Context) (sql.Result, error)

+ InsertIntoNexusEndpoints func(ctx context.Context, row *NexusEndpointsRow) (sql.Result, error)

+ ListNexusEndpoints func(ctx context.Context, request *ListNexusEndpointsRequest) ([]NexusEndpointsRow, error)

+ UpdateNexusEndpoint func(ctx context.Context, row *NexusEndpointsRow) (sql.Result, error)

+ type NexusEndpointsRow struct

+ Data []byte

+ DataEncoding string

+ ID []byte

+ Version int64

May 31, 2024

Changes in this version

+ var ErrInvalidKeywordListDataType = errors.New("Unexpected data type in keyword list")

type DbKind

+ func (k DbKind) String() string

+ type ListNexusIncomingServicesRequest struct

+ LastServiceID []byte

+ Limit int

+ type NexusIncomingServices interface

+ DeleteFromNexusIncomingServices func(ctx context.Context, serviceID []byte) (sql.Result, error)

+ GetNexusIncomingServiceByID func(ctx context.Context, serviceID []byte) (*NexusIncomingServicesRow, error)

+ GetNexusIncomingServicesTableVersion func(ctx context.Context) (int64, error)

+ IncrementNexusIncomingServicesTableVersion func(ctx context.Context, lastKnownTableVersion int64) (sql.Result, error)

+ InitializeNexusIncomingServicesTableVersion func(ctx context.Context) (sql.Result, error)

+ InsertIntoNexusIncomingServices func(ctx context.Context, row *NexusIncomingServicesRow) (sql.Result, error)

+ ListNexusIncomingServices func(ctx context.Context, request *ListNexusIncomingServicesRequest) ([]NexusIncomingServicesRow, error)

+ UpdateNexusIncomingService func(ctx context.Context, row *NexusIncomingServicesRow) (sql.Result, error)

+ type NexusIncomingServicesRow struct

+ Data []byte

+ DataEncoding string

+ ServiceID []byte

+ Version int64

type VisibilityRow

+ RootRunID string

+ RootWorkflowID string

Mar 22, 2024

Changes in this version

+ type QueueV2Filter struct

+ Partition int

+ QueueName string

+ QueueType persistence.QueueV2Type

+ type QueueV2Message interface

+ GetLastEnqueuedMessageIDForUpdateV2 func(ctx context.Context, filter QueueV2Filter) (int64, error)

+ InsertIntoQueueV2Messages func(ctx context.Context, row []QueueV2MessageRow) (sql.Result, error)

+ RangeDeleteFromQueueV2Messages func(ctx context.Context, filter QueueV2MessagesFilter) (sql.Result, error)

+ RangeSelectFromQueueV2Messages func(ctx context.Context, filter QueueV2MessagesFilter) ([]QueueV2MessageRow, error)

+ type QueueV2MessageRow struct

+ MessageEncoding string

+ MessageID int64

+ MessagePayload []byte

+ QueueName string

+ QueuePartition int64

+ QueueType persistence.QueueV2Type

+ type QueueV2MessagesFilter struct

+ MaxMessageID int64

+ MinMessageID int64

+ PageSize int

+ Partition int64

+ QueueName string

+ QueueType persistence.QueueV2Type

+ type QueueV2Metadata interface

+ InsertIntoQueueV2Metadata func(ctx context.Context, row *QueueV2MetadataRow) (sql.Result, error)

+ SelectFromQueueV2Metadata func(ctx context.Context, filter QueueV2MetadataFilter) (*QueueV2MetadataRow, error)

+ SelectFromQueueV2MetadataForUpdate func(ctx context.Context, filter QueueV2MetadataFilter) (*QueueV2MetadataRow, error)

+ SelectNameFromQueueV2Metadata func(ctx context.Context, filter QueueV2MetadataTypeFilter) ([]QueueV2MetadataRow, error)

+ UpdateQueueV2Metadata func(ctx context.Context, row *QueueV2MetadataRow) (sql.Result, error)

+ type QueueV2MetadataFilter struct

+ QueueName string

+ QueueType persistence.QueueV2Type

+ type QueueV2MetadataRow struct

+ MetadataEncoding string

+ MetadataPayload []byte

+ QueueName string

+ QueueType persistence.QueueV2Type

+ type QueueV2MetadataTypeFilter struct

+ PageOffset int64

+ PageSize int

+ QueueType persistence.QueueV2Type

type VisibilityRow

+ ExecutionDuration *time.Duration

+ ParentRunID *string

+ ParentWorkflowID *string

+ StateTransitionCount *int64

Feb 29, 2024 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 22, 2024 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 22, 2024 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 2, 2024 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 12, 2024 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 7, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 30, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 28, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 22, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 13, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 3, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 1, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 31, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 13, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 6, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 1, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 5, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type Visibility

+ CountGroupByFromVisibility func(ctx context.Context, filter VisibilitySelectFilter) ([]VisibilityCountRow, error)

+ type VisibilityCountRow struct

+ Count int64

+ GroupValues []any

+ func ParseCountGroupByRows(rows *sql.Rows, groupBy []string) ([]VisibilityCountRow, error)

type VisibilitySelectFilter

+ GroupBy []string

Aug 28, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 21, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 14, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 14, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 14, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 8, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 28, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 24, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 14, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 1, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 23, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ type AddToBuildIdToTaskQueueMapping struct

+ BuildIds []string

+ NamespaceID []byte

+ TaskQueueName string

+ type CountTaskQueuesByBuildIdRequest struct

+ BuildID string

+ NamespaceID []byte

+ type GetTaskQueueUserDataRequest struct

+ NamespaceID []byte

+ TaskQueueName string

+ type GetTaskQueuesByBuildIdRequest struct

+ BuildID string

+ NamespaceID []byte

+ type ListTaskQueueUserDataEntriesRequest struct

+ LastTaskQueueName string

+ Limit int

+ NamespaceID []byte

type MatchingTaskQueue

+ AddToBuildIdToTaskQueueMapping func(ctx context.Context, request AddToBuildIdToTaskQueueMapping) error

+ CountTaskQueuesByBuildId func(ctx context.Context, request *CountTaskQueuesByBuildIdRequest) (int, error)

+ GetTaskQueueUserData func(ctx context.Context, request *GetTaskQueueUserDataRequest) (*VersionedBlob, error)

+ GetTaskQueuesByBuildId func(ctx context.Context, request *GetTaskQueuesByBuildIdRequest) ([]string, error)

+ ListTaskQueueUserDataEntries func(ctx context.Context, request *ListTaskQueueUserDataEntriesRequest) ([]TaskQueueUserDataEntry, error)

+ RemoveFromBuildIdToTaskQueueMapping func(ctx context.Context, request RemoveFromBuildIdToTaskQueueMapping) error

+ UpdateTaskQueueUserData func(ctx context.Context, request *UpdateTaskQueueDataRequest) error

+ type RemoveFromBuildIdToTaskQueueMapping struct

+ BuildIds []string

+ NamespaceID []byte

+ TaskQueueName string

+ type TaskQueueUserDataEntry struct

+ TaskQueueName string

+ type UpdateTaskQueueDataRequest struct

+ Data []byte

+ DataEncoding string

+ NamespaceID []byte

+ TaskQueueName string

+ Version int64

+ type VersionedBlob struct

+ Data []byte

+ DataEncoding string

+ Version int64

type VisibilityRow

+ HistorySizeBytes *int64

Jul 13, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

May 15, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 17, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 29, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 17, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ var DbFields = getDbFields()

+ func BuildNamedPlaceholder(fields ...string) string

+ func GenerateSelectQuery(filter *VisibilitySelectFilter, convertToDbDateTime func(time.Time) time.Time) error

type Conn

+ PrepareNamedContext func(ctx context.Context, query string) (*sqlx.NamedStmt, error)

type DB

+ DbName func() string

type Visibility

+ CountFromVisibility func(ctx context.Context, filter VisibilitySelectFilter) (int64, error)

type VisibilityRow

+ SearchAttributes *VisibilitySearchAttributes

+ type VisibilitySearchAttributes map[string]interface

+ func (vsa *VisibilitySearchAttributes) Scan(src interface{}) error

+ func (vsa VisibilitySearchAttributes) Value() (driver.Value, error)

type VisibilitySelectFilter

+ Query string

+ QueryArgs []interface{}

Jan 13, 2023 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 1, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ type HistoryImmediateTask interface

+ DeleteFromHistoryImmediateTasks func(ctx context.Context, filter HistoryImmediateTasksFilter) (sql.Result, error)

+ InsertIntoHistoryImmediateTasks func(ctx context.Context, rows []HistoryImmediateTasksRow) (sql.Result, error)

+ RangeDeleteFromHistoryImmediateTasks func(ctx context.Context, filter HistoryImmediateTasksRangeFilter) (sql.Result, error)

+ RangeSelectFromHistoryImmediateTasks func(ctx context.Context, filter HistoryImmediateTasksRangeFilter) ([]HistoryImmediateTasksRow, error)

+ SelectFromHistoryImmediateTasks func(ctx context.Context, filter HistoryImmediateTasksFilter) ([]HistoryImmediateTasksRow, error)

+ type HistoryImmediateTasksFilter struct

+ CategoryID int32

+ ShardID int32

+ TaskID int64

+ type HistoryImmediateTasksRangeFilter struct

+ CategoryID int32

+ ExclusiveMaxTaskID int64

+ InclusiveMinTaskID int64

+ PageSize int

+ ShardID int32

+ type HistoryImmediateTasksRow struct

+ CategoryID int32

+ Data []byte

+ DataEncoding string

+ ShardID int32

+ TaskID int64

+ type HistoryScheduledTask interface

+ DeleteFromHistoryScheduledTasks func(ctx context.Context, filter HistoryScheduledTasksFilter) (sql.Result, error)

+ InsertIntoHistoryScheduledTasks func(ctx context.Context, rows []HistoryScheduledTasksRow) (sql.Result, error)

+ RangeDeleteFromHistoryScheduledTasks func(ctx context.Context, filter HistoryScheduledTasksRangeFilter) (sql.Result, error)

+ RangeSelectFromHistoryScheduledTasks func(ctx context.Context, filter HistoryScheduledTasksRangeFilter) ([]HistoryScheduledTasksRow, error)

+ SelectFromHistoryScheduledTasks func(ctx context.Context, filter HistoryScheduledTasksFilter) ([]HistoryScheduledTasksRow, error)

+ type HistoryScheduledTasksFilter struct

+ CategoryID int32

+ ShardID int32

+ TaskID int64

+ VisibilityTimestamp time.Time

+ type HistoryScheduledTasksRangeFilter struct

+ CategoryID int32

+ ExclusiveMaxVisibilityTimestamp time.Time

+ InclusiveMinTaskID int64

+ InclusiveMinVisibilityTimestamp time.Time

+ PageSize int

+ ShardID int32

+ type HistoryScheduledTasksRow struct

+ CategoryID int32

+ Data []byte

+ DataEncoding string

+ ShardID int32

+ TaskID int64

+ VisibilityTimestamp time.Time

type Visibility

+ GetFromVisibility func(ctx context.Context, filter VisibilityGetFilter) (*VisibilityRow, error)

+ type VisibilityGetFilter struct

+ NamespaceID string

+ RunID string

Nov 15, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 31, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 20, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 18, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type HistoryTree

+ PaginateBranchesFromHistoryTree func(ctx context.Context, filter HistoryTreeBranchPage) ([]HistoryTreeRow, error)

+ type HistoryTreeBranchPage struct

+ BranchID primitives.UUID

+ Limit int

+ ShardID int32

+ TreeID primitives.UUID

Oct 10, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 16, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 14, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 30, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 16, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 17, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 2, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 11, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 17, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 11, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

May 5, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 19, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 11, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type HistoryNodeSelectFilter

+ MaxTxnID int64

+ ReverseOrder bool

type ReplicationDLQTasksRangeFilter

+ ExclusiveMaxTaskID int64

+ InclusiveMinTaskID int64

type ReplicationTasksRangeFilter

+ ExclusiveMaxTaskID int64

+ InclusiveMinTaskID int64

type TasksFilter

+ ExclusiveMaxTaskID *int64

+ InclusiveMinTaskID *int64

type TimerTasksRangeFilter

+ ExclusiveMaxVisibilityTimestamp time.Time

+ InclusiveMinTaskID int64

+ InclusiveMinVisibilityTimestamp time.Time

type TransferTasksRangeFilter

+ ExclusiveMaxTaskID int64

+ InclusiveMinTaskID int64

+ PageSize int

type VisibilityRow

+ TaskQueue string

type VisibilityTasksRangeFilter

+ ExclusiveMaxTaskID int64

+ InclusiveMinTaskID int64

+ PageSize int

Mar 4, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 1, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 9, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 4, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 11, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 21, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 18, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 10, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 20, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 13, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type ClusterMetadata

+ DeleteClusterMetadata func(ctx context.Context, filter *ClusterMetadataFilter) (sql.Result, error)

+ GetClusterMetadataV1 func(ctx context.Context) (*ClusterMetadataRow, error)

+ ListClusterMetadata func(ctx context.Context, filter *ClusterMetadataFilter) ([]ClusterMetadataRow, error)

+ SaveClusterMetadataV1 func(ctx context.Context, row *ClusterMetadataRow) (sql.Result, error)

+ WriteLockGetClusterMetadataV1 func(ctx context.Context) (*ClusterMetadataRow, error)

+ type ClusterMetadataFilter struct

+ ClusterName string

+ PageSize *int

type ClusterMetadataRow

+ ClusterName string

+ type HistoryTieredStorageTask interface

+ DeleteFromTieredStorageTasks func(ctx context.Context, filter TieredStorageTasksFilter) (sql.Result, error)

+ InsertIntoTieredStorageTasks func(ctx context.Context, rows []TieredStorageTasksRow) (sql.Result, error)

+ RangeDeleteFromTieredStorageTasks func(ctx context.Context, filter TieredStorageTasksRangeFilter) (sql.Result, error)

+ RangeSelectFromTieredStorageTasks func(ctx context.Context, filter TieredStorageTasksRangeFilter) ([]TieredStorageTasksRow, error)

+ SelectFromTieredStorageTasks func(ctx context.Context, filter TieredStorageTasksFilter) ([]TieredStorageTasksRow, error)

+ type TieredStorageTasksFilter struct

+ ShardID int32

+ TaskID int64

+ type TieredStorageTasksRangeFilter struct

+ MaxTaskID int64

+ MinTaskID int64

+ ShardID int32

+ type TieredStorageTasksRow struct

+ Data []byte

+ DataEncoding string

+ ShardID int32

+ TaskID int64

Feb 10, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 12, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 20, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 4, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 20, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 29, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 4, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 16, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 31, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 6, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 22, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 20, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type QueueMetadataRow

+ Version int64

Jun 24, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 23, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 8, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 2, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 23, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

May 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

May 5, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 27, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ type ExecutionVersion struct

+ DBRecordVersion int64

+ NextEventID int64

type ExecutionsRow

+ DBRecordVersion int64

type HistoryNode

+ RangeDeleteFromHistoryNode func(ctx context.Context, filter HistoryNodeDeleteFilter) (sql.Result, error)

+ RangeSelectFromHistoryNode func(ctx context.Context, filter HistoryNodeSelectFilter) ([]HistoryNodeRow, error)

type HistoryNodeRow

+ PrevTxnID int64

type HistoryNodeSelectFilter

+ MetadataOnly bool

+ MinTxnID int64

Apr 15, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 29, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 23, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 15, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 23, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 16, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 15, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 23, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 13, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 30, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 26, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 25, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 22, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 23, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type AdminDB

+ ExpectedVersion func() string

+ VerifyVersion func() error

+ type DbKind int

+ const DbKindMain

+ const DbKindUnknown

+ const DbKindVisibility

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 13, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 26, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 25, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 22, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 30, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 22, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ type HistoryVisibilityTask interface

+ DeleteFromVisibilityTasks func(ctx context.Context, filter VisibilityTasksFilter) (sql.Result, error)

+ InsertIntoVisibilityTasks func(ctx context.Context, rows []VisibilityTasksRow) (sql.Result, error)

+ RangeDeleteFromVisibilityTasks func(ctx context.Context, filter VisibilityTasksRangeFilter) (sql.Result, error)

+ RangeSelectFromVisibilityTasks func(ctx context.Context, filter VisibilityTasksRangeFilter) ([]VisibilityTasksRow, error)

+ SelectFromVisibilityTasks func(ctx context.Context, filter VisibilityTasksFilter) ([]VisibilityTasksRow, error)

+ type VisibilityTasksFilter struct

+ ShardID int32

+ TaskID int64

+ type VisibilityTasksRangeFilter struct

+ MaxTaskID int64

+ MinTaskID int64

+ ShardID int32

+ type VisibilityTasksRow struct

+ Data []byte

+ DataEncoding string

+ ShardID int32

+ TaskID int64

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 25, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 30, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 10, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 9, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ type ActivityInfoMapsAllFilter struct

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int32

+ WorkflowID string

type ActivityInfoMapsFilter

+ ScheduleIDs []int64

+ type ChildExecutionInfoMapsAllFilter struct

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int32

+ WorkflowID string

type ChildExecutionInfoMapsFilter

+ InitiatedIDs []int64

type Conn

+ ExecContext func(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ GetContext func(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ NamedExecContext func(ctx context.Context, query string, arg interface{}) (sql.Result, error)

+ Rebind func(query string) string

+ SelectContext func(ctx context.Context, dest interface{}, query string, args ...interface{}) error

type HistoryExecutionActivity

+ DeleteAllFromActivityInfoMaps func(ctx context.Context, filter ActivityInfoMapsAllFilter) (sql.Result, error)

+ SelectAllFromActivityInfoMaps func(ctx context.Context, filter ActivityInfoMapsAllFilter) ([]ActivityInfoMapsRow, error)

type HistoryExecutionChildWorkflow

+ DeleteAllFromChildExecutionInfoMaps func(ctx context.Context, filter ChildExecutionInfoMapsAllFilter) (sql.Result, error)

+ SelectAllFromChildExecutionInfoMaps func(ctx context.Context, filter ChildExecutionInfoMapsAllFilter) ([]ChildExecutionInfoMapsRow, error)

type HistoryExecutionRequestCancel

+ DeleteAllFromRequestCancelInfoMaps func(ctx context.Context, filter RequestCancelInfoMapsAllFilter) (sql.Result, error)

+ SelectAllFromRequestCancelInfoMaps func(ctx context.Context, filter RequestCancelInfoMapsAllFilter) ([]RequestCancelInfoMapsRow, error)

type HistoryExecutionSignal

+ DeleteAllFromSignalInfoMaps func(ctx context.Context, filter SignalInfoMapsAllFilter) (sql.Result, error)

+ SelectAllFromSignalInfoMaps func(ctx context.Context, filter SignalInfoMapsAllFilter) ([]SignalInfoMapsRow, error)

type HistoryExecutionSignalRequest

+ DeleteAllFromSignalsRequestedSets func(ctx context.Context, filter SignalsRequestedSetsAllFilter) (sql.Result, error)

+ SelectAllFromSignalsRequestedSets func(ctx context.Context, filter SignalsRequestedSetsAllFilter) ([]SignalsRequestedSetsRow, error)

type HistoryExecutionTimer

+ DeleteAllFromTimerInfoMaps func(ctx context.Context, filter TimerInfoMapsAllFilter) (sql.Result, error)

+ SelectAllFromTimerInfoMaps func(ctx context.Context, filter TimerInfoMapsAllFilter) ([]TimerInfoMapsRow, error)

+ type QueueMessageRow struct

+ MessageEncoding string

+ MessageID int64

+ MessagePayload []byte

+ QueueType persistence.QueueType

+ type QueueMetadata interface

+ InsertIntoQueueMetadata func(ctx context.Context, row *QueueMetadataRow) (sql.Result, error)

+ LockQueueMetadata func(ctx context.Context, filter QueueMetadataFilter) (*QueueMetadataRow, error)

+ SelectFromQueueMetadata func(ctx context.Context, filter QueueMetadataFilter) (*QueueMetadataRow, error)

+ UpdateQueueMetadata func(ctx context.Context, row *QueueMetadataRow) (sql.Result, error)

+ type QueueMetadataFilter struct

+ QueueType persistence.QueueType

type QueueMetadataRow

+ DataEncoding string

+ type RequestCancelInfoMapsAllFilter struct

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int32

+ WorkflowID string

type RequestCancelInfoMapsFilter

+ InitiatedIDs []int64

+ type SignalInfoMapsAllFilter struct

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int32

+ WorkflowID string

type SignalInfoMapsFilter

+ InitiatedIDs []int64

+ type SignalsRequestedSetsAllFilter struct

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int32

+ WorkflowID string

type SignalsRequestedSetsFilter

+ SignalIDs []string

+ type TimerInfoMapsAllFilter struct

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int32

+ WorkflowID string

type TimerInfoMapsFilter

+ TimerIDs []string

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 20, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 16, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 11, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ const EmptyMessageID

+ const MaxMessageID

+ const MinMessageID

+ type QueueMessage interface

+ DeleteFromMessages func(filter QueueMessagesFilter) (sql.Result, error)

+ GetAckLevels func(queueType persistence.QueueType, forUpdate bool) (map[string]int64, error)

+ GetLastEnqueuedMessageIDForUpdate func(queueType persistence.QueueType) (int64, error)

+ InsertAckLevel func(queueType persistence.QueueType, messageID int64, clusterName string) error

+ InsertIntoMessages func(row []QueueRow) (sql.Result, error)

+ RangeDeleteFromMessages func(filter QueueMessagesRangeFilter) (sql.Result, error)

+ RangeSelectFromMessages func(filter QueueMessagesRangeFilter) ([]QueueRow, error)

+ SelectFromMessages func(filter QueueMessagesFilter) ([]QueueRow, error)

+ UpdateAckLevels func(queueType persistence.QueueType, clusterAckLevels map[string]int64) error

+ type QueueMessagesFilter struct

+ MessageID int64

+ QueueType persistence.QueueType

+ type QueueMessagesRangeFilter struct

+ MaxMessageID int64

+ MinMessageID int64

+ PageSize int

+ QueueType persistence.QueueType

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 20, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 27, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ type AdminCRUD interface

+ CreateDatabase func(database string) error

+ CreateSchemaVersionTables func() error

+ DropAllTables func(database string) error

+ DropDatabase func(database string) error

+ DropTable func(table string) error

+ Exec func(stmt string, args ...interface{}) error

+ ListTables func(database string) ([]string, error)

+ ReadSchemaVersion func(database string) (string, error)

+ UpdateSchemaVersion func(database string, newVersion string, minCompatibleVersion string) error

+ WriteSchemaUpdateLog func(oldVersion string, newVersion string, manifestMD5 string, desc string) error

+ type ClusterMetadata interface

+ GetClusterMembers func(filter *ClusterMembershipFilter) ([]ClusterMembershipRow, error)

+ GetClusterMetadata func() (*ClusterMetadataRow, error)

+ PruneClusterMembership func(filter *PruneClusterMembershipFilter) (sql.Result, error)

+ SaveClusterMetadata func(row *ClusterMetadataRow) (sql.Result, error)

+ UpsertClusterMembership func(row *ClusterMembershipRow) (sql.Result, error)

+ WriteLockGetClusterMetadata func() (*ClusterMetadataRow, error)

+ type HistoryReplicationDLQTask interface

+ DeleteFromReplicationDLQTasks func(filter ReplicationDLQTasksFilter) (sql.Result, error)

+ InsertIntoReplicationDLQTasks func(row []ReplicationDLQTasksRow) (sql.Result, error)

+ RangeDeleteFromReplicationDLQTasks func(filter ReplicationDLQTasksRangeFilter) (sql.Result, error)

+ RangeSelectFromReplicationDLQTasks func(filter ReplicationDLQTasksRangeFilter) ([]ReplicationDLQTasksRow, error)

+ SelectFromReplicationDLQTasks func(filter ReplicationDLQTasksFilter) ([]ReplicationDLQTasksRow, error)

type HistoryReplicationTask

+ RangeSelectFromReplicationTasks func(filter ReplicationTasksRangeFilter) ([]ReplicationTasksRow, error)

+ type Queue interface

+ DeleteMessage func(queueType persistence.QueueType, messageID int64) (sql.Result, error)

+ DeleteMessagesBefore func(queueType persistence.QueueType, messageID int64) (sql.Result, error)

+ GetAckLevels func(queueType persistence.QueueType, forUpdate bool) (map[string]int64, error)

+ GetLastEnqueuedMessageIDForUpdate func(queueType persistence.QueueType) (int64, error)

+ GetMessagesBetween func(queueType persistence.QueueType, firstMessageID int64, lastMessageID int64, ...) ([]QueueRow, error)

+ GetMessagesFromQueue func(queueType persistence.QueueType, lastMessageID int64, maxRows int) ([]QueueRow, error)

+ InsertAckLevel func(queueType persistence.QueueType, messageID int64, clusterName string) error

+ InsertIntoQueue func(row *QueueRow) (sql.Result, error)

+ RangeDeleteMessages func(queueType persistence.QueueType, exclusiveBeginMessageID int64, ...) (sql.Result, error)

+ UpdateAckLevels func(queueType persistence.QueueType, clusterAckLevels map[string]int64) error

+ type ReplicationDLQTasksFilter struct

+ ShardID int32

+ SourceClusterName string

+ TaskID int64

+ type ReplicationDLQTasksRangeFilter struct

+ MaxTaskID int64

+ MinTaskID int64

+ PageSize int

+ ShardID int32

+ SourceClusterName string

+ type ReplicationDLQTasksRow struct

+ Data []byte

+ DataEncoding string

+ ShardID int32

+ SourceClusterName string

+ TaskID int64

+ type ReplicationTasksRangeFilter struct

+ MaxTaskID int64

+ MinTaskID int64

+ PageSize int

+ ShardID int32

+ type TableCRUD interface

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 20, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 14, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ type ActivityInfoMapsDeleteFilter struct

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ScheduleID *int64

+ ShardID int32

+ WorkflowID string

+ type ActivityInfoMapsSelectFilter struct

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int32

+ WorkflowID string

+ type ChildExecutionInfoMapsDeleteFilter struct

+ InitiatedID *int64

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int32

+ WorkflowID string

+ type ChildExecutionInfoMapsSelectFilter struct

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int32

+ WorkflowID string

type ClusterMetadataRow

+ Data []byte

+ DataEncoding string

+ Version int64

+ type HistoryExecution interface

+ DeleteFromCurrentExecutions func(filter CurrentExecutionsFilter) (sql.Result, error)

+ DeleteFromExecutions func(filter ExecutionsFilter) (sql.Result, error)

+ InsertIntoCurrentExecutions func(row *CurrentExecutionsRow) (sql.Result, error)

+ InsertIntoExecutions func(row *ExecutionsRow) (sql.Result, error)

+ LockCurrentExecutions func(filter CurrentExecutionsFilter) (*CurrentExecutionsRow, error)

+ LockCurrentExecutionsJoinExecutions func(filter CurrentExecutionsFilter) ([]CurrentExecutionsRow, error)

+ ReadLockExecutions func(filter ExecutionsFilter) (int64, error)

+ SelectFromCurrentExecutions func(filter CurrentExecutionsFilter) (*CurrentExecutionsRow, error)

+ SelectFromExecutions func(filter ExecutionsFilter) (*ExecutionsRow, error)

+ UpdateCurrentExecutions func(row *CurrentExecutionsRow) (sql.Result, error)

+ UpdateExecutions func(row *ExecutionsRow) (sql.Result, error)

+ WriteLockExecutions func(filter ExecutionsFilter) (int64, error)

+ type HistoryExecutionActivity interface

+ DeleteFromActivityInfoMaps func(filter ActivityInfoMapsDeleteFilter) (sql.Result, error)

+ ReplaceIntoActivityInfoMaps func(rows []ActivityInfoMapsRow) (sql.Result, error)

+ SelectFromActivityInfoMaps func(filter ActivityInfoMapsSelectFilter) ([]ActivityInfoMapsRow, error)

+ type HistoryExecutionBuffer interface

+ DeleteFromBufferedEvents func(filter *BufferedEventsFilter) (sql.Result, error)

+ InsertIntoBufferedEvents func(rows []BufferedEventsRow) (sql.Result, error)

+ SelectFromBufferedEvents func(filter *BufferedEventsFilter) ([]BufferedEventsRow, error)

+ type HistoryExecutionChildWorkflow interface

+ DeleteFromChildExecutionInfoMaps func(filter ChildExecutionInfoMapsDeleteFilter) (sql.Result, error)

+ ReplaceIntoChildExecutionInfoMaps func(rows []ChildExecutionInfoMapsRow) (sql.Result, error)

+ SelectFromChildExecutionInfoMaps func(filter ChildExecutionInfoMapsSelectFilter) ([]ChildExecutionInfoMapsRow, error)

+ type HistoryExecutionRequestCancel interface

+ DeleteFromRequestCancelInfoMaps func(filter RequestCancelInfoMapsDeleteFilter) (sql.Result, error)

+ ReplaceIntoRequestCancelInfoMaps func(rows []RequestCancelInfoMapsRow) (sql.Result, error)

+ SelectFromRequestCancelInfoMaps func(filter RequestCancelInfoMapsSelectFilter) ([]RequestCancelInfoMapsRow, error)

+ type HistoryExecutionSignal interface

+ DeleteFromSignalInfoMaps func(filter SignalInfoMapsDeleteFilter) (sql.Result, error)

+ ReplaceIntoSignalInfoMaps func(rows []SignalInfoMapsRow) (sql.Result, error)

+ SelectFromSignalInfoMaps func(filter SignalInfoMapsSelectFilter) ([]SignalInfoMapsRow, error)

+ type HistoryExecutionSignalRequest interface

+ DeleteFromSignalsRequestedSets func(filter SignalsRequestedSetsDeleteFilter) (sql.Result, error)

+ ReplaceIntoSignalsRequestedSets func(rows []SignalsRequestedSetsRow) (sql.Result, error)

+ SelectFromSignalsRequestedSets func(filter SignalsRequestedSetsSelectFilter) ([]SignalsRequestedSetsRow, error)

+ type HistoryExecutionTimer interface

+ DeleteFromTimerInfoMaps func(filter TimerInfoMapsDeleteFilter) (sql.Result, error)

+ ReplaceIntoTimerInfoMaps func(rows []TimerInfoMapsRow) (sql.Result, error)

+ SelectFromTimerInfoMaps func(filter TimerInfoMapsSelectFilter) ([]TimerInfoMapsRow, error)

+ type HistoryNode interface

+ DeleteFromHistoryNode func(filter HistoryNodeDeleteFilter) (sql.Result, error)

+ InsertIntoHistoryNode func(row *HistoryNodeRow) (sql.Result, error)

+ SelectFromHistoryNode func(filter HistoryNodeSelectFilter) ([]HistoryNodeRow, error)

+ type HistoryNodeDeleteFilter struct

+ BranchID primitives.UUID

+ MinNodeID int64

+ ShardID int32

+ TreeID primitives.UUID

+ type HistoryNodeSelectFilter struct

+ BranchID primitives.UUID

+ MaxNodeID int64

+ MinNodeID int64

+ PageSize int

+ ShardID int32

+ TreeID primitives.UUID

+ type HistoryReplicationTask interface

+ DeleteFromReplicationTasks func(filter *ReplicationTasksFilter) (sql.Result, error)

+ DeleteMessageFromReplicationTasksDLQ func(filter *ReplicationTasksDLQFilter) (sql.Result, error)

+ InsertIntoReplicationTasks func(rows []ReplicationTasksRow) (sql.Result, error)

+ InsertIntoReplicationTasksDLQ func(row *ReplicationTaskDLQRow) (sql.Result, error)

+ RangeDeleteFromReplicationTasks func(filter *ReplicationTasksFilter) (sql.Result, error)

+ RangeDeleteMessageFromReplicationTasksDLQ func(filter *ReplicationTasksDLQFilter) (sql.Result, error)

+ SelectFromReplicationTasks func(filter *ReplicationTasksFilter) ([]ReplicationTasksRow, error)

+ SelectFromReplicationTasksDLQ func(filter *ReplicationTasksDLQFilter) ([]ReplicationTasksRow, error)

+ type HistoryShard interface

+ InsertIntoShards func(rows *ShardsRow) (sql.Result, error)

+ ReadLockShards func(filter *ShardsFilter) (int64, error)

+ SelectFromShards func(filter *ShardsFilter) (*ShardsRow, error)

+ UpdateShards func(row *ShardsRow) (sql.Result, error)

+ WriteLockShards func(filter *ShardsFilter) (int64, error)

+ type HistoryTimerTask interface

+ DeleteFromTimerTasks func(filter TimerTasksFilter) (sql.Result, error)

+ InsertIntoTimerTasks func(rows []TimerTasksRow) (sql.Result, error)

+ RangeDeleteFromTimerTasks func(filter TimerTasksRangeFilter) (sql.Result, error)

+ RangeSelectFromTimerTasks func(filter TimerTasksRangeFilter) ([]TimerTasksRow, error)

+ SelectFromTimerTasks func(filter TimerTasksFilter) ([]TimerTasksRow, error)

+ type HistoryTransferTask interface

+ DeleteFromTransferTasks func(filter TransferTasksFilter) (sql.Result, error)

+ InsertIntoTransferTasks func(rows []TransferTasksRow) (sql.Result, error)

+ RangeDeleteFromTransferTasks func(filter TransferTasksRangeFilter) (sql.Result, error)

+ RangeSelectFromTransferTasks func(filter TransferTasksRangeFilter) ([]TransferTasksRow, error)

+ SelectFromTransferTasks func(filter TransferTasksFilter) ([]TransferTasksRow, error)

+ type HistoryTree interface

+ DeleteFromHistoryTree func(filter HistoryTreeDeleteFilter) (sql.Result, error)

+ InsertIntoHistoryTree func(row *HistoryTreeRow) (sql.Result, error)

+ SelectFromHistoryTree func(filter HistoryTreeSelectFilter) ([]HistoryTreeRow, error)

+ type HistoryTreeDeleteFilter struct

+ BranchID primitives.UUID

+ ShardID int32

+ TreeID primitives.UUID

+ type HistoryTreeSelectFilter struct

+ ShardID int32

+ TreeID primitives.UUID

+ type MatchingTask interface

+ DeleteFromTasks func(filter *TasksFilter) (sql.Result, error)

+ InsertIntoTasks func(rows []TasksRow) (sql.Result, error)

+ SelectFromTasks func(filter *TasksFilter) ([]TasksRow, error)

+ type MatchingTaskQueue interface

+ DeleteFromTaskQueues func(filter *TaskQueuesFilter) (sql.Result, error)

+ InsertIntoTaskQueues func(row *TaskQueuesRow) (sql.Result, error)

+ LockTaskQueues func(filter *TaskQueuesFilter) (int64, error)

+ ReplaceIntoTaskQueues func(row *TaskQueuesRow) (sql.Result, error)

+ SelectFromTaskQueues func(filter *TaskQueuesFilter) ([]TaskQueuesRow, error)

+ UpdateTaskQueues func(row *TaskQueuesRow) (sql.Result, error)

+ type Namespace interface

+ DeleteFromNamespace func(filter *NamespaceFilter) (sql.Result, error)

+ InsertIntoNamespace func(rows *NamespaceRow) (sql.Result, error)

+ LockNamespaceMetadata func() (*NamespaceMetadataRow, error)

+ SelectFromNamespace func(filter *NamespaceFilter) ([]NamespaceRow, error)

+ SelectFromNamespaceMetadata func() (*NamespaceMetadataRow, error)

+ UpdateNamespace func(row *NamespaceRow) (sql.Result, error)

+ UpdateNamespaceMetadata func(row *NamespaceMetadataRow) (sql.Result, error)

+ type RequestCancelInfoMapsDeleteFilter struct

+ InitiatedID *int64

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int32

+ WorkflowID string

+ type RequestCancelInfoMapsSelectFilter struct

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int32

+ WorkflowID string

+ type SignalInfoMapsDeleteFilter struct

+ InitiatedID *int64

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int32

+ WorkflowID string

+ type SignalInfoMapsSelectFilter struct

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int32

+ WorkflowID string

+ type SignalsRequestedSetsDeleteFilter struct

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int32

+ SignalID *string

+ WorkflowID string

+ type SignalsRequestedSetsSelectFilter struct

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int32

+ WorkflowID string

+ type TimerInfoMapsDeleteFilter struct

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int32

+ TimerID *string

+ WorkflowID string

+ type TimerInfoMapsSelectFilter struct

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int32

+ WorkflowID string

+ type TimerTasksRangeFilter struct

+ MaxVisibilityTimestamp time.Time

+ MinVisibilityTimestamp time.Time

+ PageSize int

+ ShardID int32

+ TaskID int64

+ type TransferTasksRangeFilter struct

+ MaxTaskID int64

+ MinTaskID int64

+ ShardID int32

+ type Visibility interface

+ DeleteFromVisibility func(filter VisibilityDeleteFilter) (sql.Result, error)

+ InsertIntoVisibility func(row *VisibilityRow) (sql.Result, error)

+ ReplaceIntoVisibility func(row *VisibilityRow) (sql.Result, error)

+ SelectFromVisibility func(filter VisibilitySelectFilter) ([]VisibilityRow, error)

+ type VisibilityDeleteFilter struct

+ NamespaceID string

+ RunID string

+ type VisibilitySelectFilter struct

+ MaxTime *time.Time

+ MinTime *time.Time

+ NamespaceID string

+ PageSize *int

+ RunID *string

+ Status int32

+ WorkflowID *string

+ WorkflowTypeName *string

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 30, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 28, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 22, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 17, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 31, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type ClusterMembershipFilter

+ HostIDGreaterThan []byte

type TaskQueuesFilter

+ RangeHash uint32

+ RangeHashGreaterThanEqualTo uint32

+ RangeHashLessThanEqualTo uint32

+ TaskQueueID []byte

+ TaskQueueIDGreaterThan []byte

type TaskQueuesRow

+ RangeHash uint32

+ TaskQueueID []byte

type TasksFilter

+ RangeHash uint32

+ TaskQueueID []byte

type TasksRow

+ RangeHash uint32

+ TaskQueueID []byte

Jul 15, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ type ActivityInfoMapsFilter struct

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ScheduleID *int64

+ ShardID int64

+ WorkflowID string

+ type ActivityInfoMapsRow struct

+ Data []byte

+ DataEncoding string

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ScheduleID int64

+ ShardID int64

+ WorkflowID string

+ type AdminDB interface

+ Close func() error

+ PluginName func() string

+ type BufferedEventsFilter struct

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int

+ WorkflowID string

+ type BufferedEventsRow struct

+ Data []byte

+ DataEncoding string

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int

+ WorkflowID string

+ type ChildExecutionInfoMapsFilter struct

+ InitiatedID *int64

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int64

+ WorkflowID string

+ type ChildExecutionInfoMapsRow struct

+ Data []byte

+ DataEncoding string

+ InitiatedID int64

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int64

+ WorkflowID string

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

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int64

+ WorkflowID string

+ type CurrentExecutionsRow struct

+ CreateRequestID string

+ LastWriteVersion int64

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int64

+ StartVersion int64

+ State enumsspb.WorkflowExecutionState

+ Status enumspb.WorkflowExecutionStatus

+ WorkflowID string

+ type DB interface

+ BeginTx func() (Tx, error)

+ Close func() error

+ IsDupEntryError func(err error) bool

+ PluginName func() string

+ type EventsFilter struct

+ FirstEventID *int64

+ NamespaceID primitives.UUID

+ NextEventID *int64

+ PageSize *int

+ RunID primitives.UUID

+ WorkflowID string

+ type EventsRow struct

+ BatchVersion int64

+ Data []byte

+ DataEncoding string

+ FirstEventID int64

+ NamespaceID primitives.UUID

+ RangeID int64

+ RunID primitives.UUID

+ TxID int64

+ WorkflowID string

+ type ExecutionsFilter struct

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int

+ WorkflowID string

+ type ExecutionsRow struct

+ Data []byte

+ DataEncoding string

+ LastWriteVersion int64

+ NamespaceID primitives.UUID

+ NextEventID int64

+ RunID primitives.UUID

+ ShardID int

+ State []byte

+ StateEncoding string

+ VersionHistories []byte

+ VersionHistoriesEncoding string

+ WorkflowID string

+ type HistoryNodeFilter struct

+ BranchID primitives.UUID

+ MaxNodeID *int64

+ MinNodeID *int64

+ PageSize *int

+ ShardID int

+ TreeID primitives.UUID

+ type HistoryNodeRow struct

+ BranchID primitives.UUID

+ Data []byte

+ DataEncoding string

+ NodeID int64

+ ShardID int

+ TreeID primitives.UUID

+ TxnID *int64

+ type HistoryTreeFilter struct

+ BranchID primitives.UUID

+ ShardID int

+ TreeID primitives.UUID

+ type HistoryTreeRow struct

+ BranchID primitives.UUID

+ Data []byte

+ DataEncoding string

+ ShardID int

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

+ NotificationVersion int64

+ type Plugin interface

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

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

+ type PruneClusterMembershipFilter struct

+ MaxRecordsAffected int

+ PruneRecordsBefore time.Time

+ type QueueMetadataRow struct

+ Data []byte

+ QueueType persistence.QueueType

+ type QueueRow struct

+ MessageID int64

+ MessagePayload []byte

+ QueueType persistence.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

+ InitiatedID *int64

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int64

+ WorkflowID string

+ type RequestCancelInfoMapsRow struct

+ Data []byte

+ DataEncoding string

+ InitiatedID int64

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int64

+ WorkflowID string

+ type ShardsFilter struct

+ ShardID int64

+ type ShardsRow struct

+ Data []byte

+ DataEncoding string

+ RangeID int64

+ ShardID int64

+ type SignalInfoMapsFilter struct

+ InitiatedID *int64

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int64

+ WorkflowID string

+ type SignalInfoMapsRow struct

+ Data []byte

+ DataEncoding string

+ InitiatedID int64

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int64

+ WorkflowID string

+ type SignalsRequestedSetsFilter struct

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int64

+ SignalID *string

+ WorkflowID string

+ type SignalsRequestedSetsRow struct

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int64

+ SignalID string

+ WorkflowID string

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

+ Limit *int

+ MaxTaskID *int64

+ MinTaskID *int64

+ NamespaceID primitives.UUID

+ PageSize *int

+ TaskID *int64

+ TaskIDLessThanEquals *int64

+ TaskQueueName string

+ TaskType int64

+ type TasksRow struct

+ Data []byte

+ DataEncoding string

+ NamespaceID primitives.UUID

+ TaskID int64

+ TaskQueueName string

+ TaskType int64

+ type TimerInfoMapsFilter struct

+ NamespaceID primitives.UUID

+ RunID primitives.UUID

+ ShardID int64

+ TimerID *string

+ WorkflowID string

+ type TimerInfoMapsRow struct

+ Data []byte

+ DataEncoding string

+ NamespaceID primitives.UUID

+ RunID primitives.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 VisibilityFilter struct

+ MaxStartTime *time.Time

+ MinStartTime *time.Time

+ NamespaceID string

+ PageSize *int

+ RunID *string

+ Status int32

+ WorkflowID *string

+ WorkflowTypeName *string

+ type VisibilityRow struct

+ CloseTime *time.Time

+ Encoding string

+ ExecutionTime time.Time

+ HistoryLength *int64

+ Memo []byte

+ NamespaceID string

+ RunID string

+ StartTime time.Time

+ Status int32

+ WorkflowID string

+ WorkflowTypeName string