Documentation ¶
Overview ¶
Package sdk is a generated GoMock package.
Index ¶
- Variables
- func NewClientFactory(hostPort string, tlsConfig *tls.Config, metricsHandler metrics.Handler, ...) *clientFactory
- type ClientFactory
- type MetricsHandler
- type MockClientFactory
- func (m *MockClientFactory) EXPECT() *MockClientFactoryMockRecorder
- func (m *MockClientFactory) GetSystemClient() client.Client
- func (m *MockClientFactory) NewClient(options client.Options) client.Client
- func (m *MockClientFactory) NewWorker(client client.Client, taskQueue string, options worker.Options) worker.Worker
- type MockClientFactoryMockRecorder
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // PreferProtoDataConverter is like the default data converter defined in the SDK, except // that it prefers encoding proto messages with the binary encoding instead of json. PreferProtoDataConverter = converter.NewCompositeDataConverter( converter.NewNilPayloadConverter(), converter.NewByteSlicePayloadConverter(), newProtoPayloadConverter(), converter.NewProtoJSONPayloadConverter(), converter.NewJSONPayloadConverter(), ) )
Functions ¶
func NewClientFactory ¶
func NewClientFactory( hostPort string, tlsConfig *tls.Config, metricsHandler metrics.Handler, logger log.Logger, stickyCacheSize dynamicconfig.IntPropertyFn, ) *clientFactory
Types ¶
type ClientFactory ¶
type ClientFactory interface { // options must include Namespace and should not include: HostPort, ConnectionOptions, // MetricsHandler, or Logger (they will be overwritten) NewClient(options sdkclient.Options) sdkclient.Client GetSystemClient() sdkclient.Client NewWorker(client sdkclient.Client, taskQueue string, options sdkworker.Options) sdkworker.Worker }
type MetricsHandler ¶ added in v1.15.0
type MetricsHandler struct {
// contains filtered or unexported fields
}
func NewMetricsHandler ¶ added in v1.17.0
func NewMetricsHandler(provider metrics.Handler) *MetricsHandler
func (*MetricsHandler) Counter ¶ added in v1.15.0
func (m *MetricsHandler) Counter(name string) sdkclient.MetricsCounter
func (*MetricsHandler) Gauge ¶ added in v1.15.0
func (m *MetricsHandler) Gauge(name string) sdkclient.MetricsGauge
func (*MetricsHandler) Timer ¶ added in v1.15.0
func (m *MetricsHandler) Timer(name string) sdkclient.MetricsTimer
func (*MetricsHandler) WithTags ¶ added in v1.15.0
func (m *MetricsHandler) WithTags(tags map[string]string) sdkclient.MetricsHandler
type MockClientFactory ¶
type MockClientFactory struct {
// contains filtered or unexported fields
}
MockClientFactory is a mock of ClientFactory interface.
func NewMockClientFactory ¶
func NewMockClientFactory(ctrl *gomock.Controller) *MockClientFactory
NewMockClientFactory creates a new mock instance.
func (*MockClientFactory) EXPECT ¶
func (m *MockClientFactory) EXPECT() *MockClientFactoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockClientFactory) GetSystemClient ¶ added in v1.16.0
func (m *MockClientFactory) GetSystemClient() client.Client
GetSystemClient mocks base method.
type MockClientFactoryMockRecorder ¶
type MockClientFactoryMockRecorder struct {
// contains filtered or unexported fields
}
MockClientFactoryMockRecorder is the mock recorder for MockClientFactory.
func (*MockClientFactoryMockRecorder) GetSystemClient ¶ added in v1.16.0
func (mr *MockClientFactoryMockRecorder) GetSystemClient() *gomock.Call
GetSystemClient indicates an expected call of GetSystemClient.
func (*MockClientFactoryMockRecorder) NewClient ¶
func (mr *MockClientFactoryMockRecorder) NewClient(options interface{}) *gomock.Call
NewClient indicates an expected call of NewClient.
func (*MockClientFactoryMockRecorder) NewWorker ¶ added in v1.20.0
func (mr *MockClientFactoryMockRecorder) NewWorker(client, taskQueue, options interface{}) *gomock.Call
NewWorker indicates an expected call of NewWorker.
Click to show internal directories.
Click to hide internal directories.