nosqlplugin

Documentation

Index

• type DB
• type DomainRow
• type HistoryNodeFilter
• type HistoryNodeRow
• type HistoryTreeFilter
• type HistoryTreeRow
• type NoSQLInternalDomainConfig
• type QueueMessageRow
• type QueueMetadataRow
• type SelectMessagesBetweenRequest
• type SelectMessagesBetweenResponse

Types

type DB

type DB interface {
	PluginName() string
	Close()

	IsConditionFailedError(err error) bool
	gocql.ErrorChecker
	// contains filtered or unexported methods
}

DB defines the API for regular NoSQL operations of a Cadence server

type DomainRow

type DomainRow struct {
	Info                        *persistence.DomainInfo
	Config                      *NoSQLInternalDomainConfig
	ReplicationConfig           *persistence.DomainReplicationConfig
	ConfigVersion               int64
	FailoverVersion             int64
	FailoverNotificationVersion int64
	PreviousFailoverVersion     int64
	FailoverEndTime             *time.Time
	NotificationVersion         int64
	LastUpdatedTime             time.Time
	IsGlobalDomain              bool
}

DomainRow defines the row struct for queue message

type HistoryNodeFilter

type HistoryNodeFilter struct {
	ShardID  int
	TreeID   string
	BranchID string
	// Inclusive
	MinNodeID int64
	// Exclusive
	MaxNodeID     int64
	NextPageToken []byte
	PageSize      int
}

HistoryNodeFilter contains the column names within history_node table that can be used to filter results through a WHERE clause

type HistoryNodeRow

type HistoryNodeRow struct {
	ShardID  int
	TreeID   string
	BranchID string
	NodeID   int64
	// Note: use pointer so that it's easier to multiple by -1 if needed
	TxnID        *int64
	Data         []byte
	DataEncoding string
}

HistoryNodeRow represents a row in history_node table

type HistoryTreeFilter

type HistoryTreeFilter struct {
	ShardID  int
	TreeID   string
	BranchID *string
}

HistoryTreeFilter contains the column names within history_tree table that can be used to filter results through a WHERE clause

type HistoryTreeRow

type HistoryTreeRow struct {
	ShardID         int
	TreeID          string
	BranchID        string
	Ancestors       []*types.HistoryBranchRange
	CreateTimestamp time.Time
	Info            string
}

HistoryTreeRow represents a row in history_tree table

type NoSQLInternalDomainConfig

type NoSQLInternalDomainConfig struct {
	Retention                time.Duration
	EmitMetric               bool                 // deprecated
	ArchivalBucket           string               // deprecated
	ArchivalStatus           types.ArchivalStatus // deprecated
	HistoryArchivalStatus    types.ArchivalStatus
	HistoryArchivalURI       string
	VisibilityArchivalStatus types.ArchivalStatus
	VisibilityArchivalURI    string
	BadBinaries              *persistence.DataBlob
}

NoSQLInternalDomainConfig defines the struct for the domainConfig

type QueueMessageRow

type QueueMessageRow struct {
	QueueType persistence.QueueType
	ID        int64
	Payload   []byte
}

QueueMessageRow defines the row struct for queue message

type QueueMetadataRow

type QueueMetadataRow struct {
	QueueType        persistence.QueueType
	ClusterAckLevels map[string]int64
	Version          int64
}

QueueMetadataRow defines the row struct for metadata

type SelectMessagesBetweenRequest

type SelectMessagesBetweenRequest struct {
	QueueType               persistence.QueueType
	ExclusiveBeginMessageID int64
	InclusiveEndMessageID   int64
	PageSize                int
	NextPageToken           []byte
}

SelectMessagesBetweenRequest is a request struct for SelectMessagesBetween

type SelectMessagesBetweenResponse

type SelectMessagesBetweenResponse struct {
	Rows          []QueueMessageRow
	NextPageToken []byte
}

SelectMessagesBetweenResponse is a response struct for SelectMessagesBetween