history

Documentation

Overview

Package history is a generated GoMock package.

Index

• Constants
• func DecodeClusterShardMD(getter headers.HeaderGetter) (client ClusterShardID, server ClusterShardID, err 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 MockRPCFactory
  • func NewMockRPCFactory(ctrl *gomock.Controller) *MockRPCFactory
  • func (m *MockRPCFactory) CreateInternodeGRPCConnection(rpcAddress string) *grpc.ClientConn
  • func (m *MockRPCFactory) EXPECT() *MockRPCFactoryMockRecorder
• type MockRPCFactoryMockRecorder
  • func (mr *MockRPCFactoryMockRecorder) CreateInternodeGRPCConnection(rpcAddress any) *gomock.Call
• type MockconnectionPool
  • func NewMockconnectionPool(ctrl *gomock.Controller) *MockconnectionPool
  • func (m *MockconnectionPool) EXPECT() *MockconnectionPoolMockRecorder
• type MockconnectionPoolMockRecorder
• type RPCFactory

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(
	getter headers.HeaderGetter,
) (client ClusterShardID, server ClusterShardID, err 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 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 MockRPCFactory

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

MockRPCFactory is a mock of RPCFactory interface.

func NewMockRPCFactory

func NewMockRPCFactory(ctrl *gomock.Controller) *MockRPCFactory

NewMockRPCFactory creates a new mock instance.

func (*MockRPCFactory) CreateInternodeGRPCConnection

func (m *MockRPCFactory) CreateInternodeGRPCConnection(rpcAddress string) *grpc.ClientConn

CreateInternodeGRPCConnection mocks base method.

func (*MockRPCFactory) EXPECT

func (m *MockRPCFactory) EXPECT() *MockRPCFactoryMockRecorder

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

type MockRPCFactoryMockRecorder

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

MockRPCFactoryMockRecorder is the mock recorder for MockRPCFactory.

func (*MockRPCFactoryMockRecorder) CreateInternodeGRPCConnection

func (mr *MockRPCFactoryMockRecorder) CreateInternodeGRPCConnection(rpcAddress any) *gomock.Call

CreateInternodeGRPCConnection indicates an expected call of CreateInternodeGRPCConnection.

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.

type RPCFactory

type RPCFactory interface {
	CreateInternodeGRPCConnection(rpcAddress string) *grpc.ClientConn
}

RPCFactory is a subset of the go.temporal.io/server/common/rpc.RPCFactory interface to make testing easier.