history

Documentation

Index

• Constants
• func DecodeClusterShardMD(clusterShardMD metadata.MD) (_ ClusterShardID, _ ClusterShardID, _ error)
• func EncodeClusterShardMD(sourceClusterShardID ClusterShardID, targetClusterShardID ClusterShardID) metadata.MD
• func NewClient(numberOfShards int32, timeout time.Duration, clients common.ClientCache, ...) historyservice.HistoryServiceClient
• func NewMetricClient(client historyservice.HistoryServiceClient, metricsHandler metrics.Handler, ...) historyservice.HistoryServiceClient
• func NewRetryableClient(client historyservice.HistoryServiceClient, policy backoff.RetryPolicy, ...) historyservice.HistoryServiceClient
• type ClusterShardID

Constants

const (
	MetadataKeyClientClusterID = "temporal-client-cluster-id"
	MetadataKeyClientShardID   = "temporal-client-shard-id"
	MetadataKeyServerClusterID = "temporal-server-cluster-id"
	MetadataKeyServerShardID   = "temporal-server-shard-id"
)

const (
	// DefaultTimeout is the default timeout used to make calls
	DefaultTimeout = time.Second * 30 * debug.TimeoutMultiplier
)

Functions

func DecodeClusterShardMD

func DecodeClusterShardMD(
	clusterShardMD metadata.MD,
) (_ ClusterShardID, _ ClusterShardID, _ error)

func EncodeClusterShardMD

func EncodeClusterShardMD(
	sourceClusterShardID ClusterShardID,
	targetClusterShardID ClusterShardID,
) metadata.MD

func NewClient

func NewClient(
	numberOfShards int32,
	timeout time.Duration,
	clients common.ClientCache,
	logger log.Logger,
) historyservice.HistoryServiceClient

NewClient creates a new history service gRPC client

func NewMetricClient

func NewMetricClient(
	client historyservice.HistoryServiceClient,
	metricsHandler metrics.Handler,
	logger log.Logger,
	throttledLogger log.Logger,
) historyservice.HistoryServiceClient

NewMetricClient creates a new instance of historyservice.HistoryServiceClient that emits metrics

func NewRetryableClient

func NewRetryableClient(client historyservice.HistoryServiceClient, policy backoff.RetryPolicy, isRetryable backoff.IsRetryable) historyservice.HistoryServiceClient

NewRetryableClient creates a new instance of historyservice.HistoryServiceClient with retry policy

Types

type ClusterShardID

type ClusterShardID struct {
	ClusterID int32
	ShardID   int32
}