history

Documentation

Overview

Package history is a generated GoMock package.

Index

• Constants
• func DecodeClusterShardMD(clusterShardMD metadata.MD) (_ ClusterShardID, _ ClusterShardID, _ error)
• func EncodeClusterShardMD(sourceClusterShardID ClusterShardID, targetClusterShardID ClusterShardID) metadata.MD
• func NewClient(dc *dynamicconfig.Collection, ...) historyservice.HistoryServiceClient
• func NewMetricClient(client historyservice.HistoryServiceClient, metricsHandler metrics.Handler, ...) historyservice.HistoryServiceClient
• func NewRetryableClient(client historyservice.HistoryServiceClient, policy backoff.RetryPolicy, ...) historyservice.HistoryServiceClient
• type ClusterShardID
• type MockconnectionPool
  • func NewMockconnectionPool(ctrl *gomock.Controller) *MockconnectionPool
  • func (m *MockconnectionPool) EXPECT() *MockconnectionPoolMockRecorder
• type MockconnectionPoolMockRecorder

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(
	dc *dynamicconfig.Collection,
	historyServiceResolver membership.ServiceResolver,
	logger log.Logger,
	numberOfShards int32,
	rpcFactory common.RPCFactory,
	timeout time.Duration,
) 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
}

type MockconnectionPool

type MockconnectionPool struct {
	// contains filtered or unexported fields
}

MockconnectionPool is a mock of connectionPool interface.

func NewMockconnectionPool

func NewMockconnectionPool(ctrl *gomock.Controller) *MockconnectionPool

NewMockconnectionPool creates a new mock instance.

func (*MockconnectionPool) EXPECT

func (m *MockconnectionPool) EXPECT() *MockconnectionPoolMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockconnectionPoolMockRecorder

type MockconnectionPoolMockRecorder struct {
	// contains filtered or unexported fields
}

MockconnectionPoolMockRecorder is the mock recorder for MockconnectionPool.