sdk

Documentation

Overview

Package sdk is a generated GoMock package.

Index

• Variables
• func NewClientFactory(hostPort string, tlsConfig *tls.Config, metricsHandler metrics.MetricsHandler, ...) *clientFactory
• func NewWorkerFactory() *workerFactory
• type ClientFactory
• type MetricsHandler
  • func NewMetricsHandler(provider metrics.MetricsHandler) *MetricsHandler
  • func (m *MetricsHandler) Counter(name string) sdkclient.MetricsCounter
  • func (m *MetricsHandler) Gauge(name string) sdkclient.MetricsGauge
  • func (m *MetricsHandler) Timer(name string) sdkclient.MetricsTimer
  • func (m *MetricsHandler) WithTags(tags map[string]string) sdkclient.MetricsHandler
• type MockClientFactory
  • func NewMockClientFactory(ctrl *gomock.Controller) *MockClientFactory
  • func (m *MockClientFactory) EXPECT() *MockClientFactoryMockRecorder
  • func (m *MockClientFactory) GetSystemClient() client.Client
  • func (m *MockClientFactory) NewClient(options client.Options) client.Client
• type MockClientFactoryMockRecorder
  • func (mr *MockClientFactoryMockRecorder) GetSystemClient() *gomock.Call
  • func (mr *MockClientFactoryMockRecorder) NewClient(options interface{}) *gomock.Call
• type MockWorkerFactory
  • func NewMockWorkerFactory(ctrl *gomock.Controller) *MockWorkerFactory
  • func (m *MockWorkerFactory) EXPECT() *MockWorkerFactoryMockRecorder
  • func (m *MockWorkerFactory) New(client client.Client, taskQueue string, options worker.Options) worker.Worker
• type MockWorkerFactoryMockRecorder
  • func (mr *MockWorkerFactoryMockRecorder) New(client, taskQueue, options interface{}) *gomock.Call
• type WorkerFactory

Variables

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(),
		converter.NewProtoPayloadConverter(),
		converter.NewProtoJSONPayloadConverter(),
		converter.NewJSONPayloadConverter(),
	)
)

Functions

func NewClientFactory

func NewClientFactory(
	hostPort string,
	tlsConfig *tls.Config,
	metricsHandler metrics.MetricsHandler,
	logger log.Logger,
) *clientFactory

func NewWorkerFactory

func NewWorkerFactory() *workerFactory

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
}

type MetricsHandler

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

func NewMetricsHandler

func NewMetricsHandler(provider metrics.MetricsHandler) *MetricsHandler

func (*MetricsHandler) Counter

func (m *MetricsHandler) Counter(name string) sdkclient.MetricsCounter

func (*MetricsHandler) Gauge

func (m *MetricsHandler) Gauge(name string) sdkclient.MetricsGauge

func (*MetricsHandler) Timer

func (m *MetricsHandler) Timer(name string) sdkclient.MetricsTimer

func (*MetricsHandler) WithTags

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

func (m *MockClientFactory) GetSystemClient() client.Client

GetSystemClient mocks base method.

func (*MockClientFactory) NewClient

func (m *MockClientFactory) NewClient(options client.Options) client.Client

NewClient mocks base method.

type MockClientFactoryMockRecorder

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

MockClientFactoryMockRecorder is the mock recorder for MockClientFactory.

func (*MockClientFactoryMockRecorder) GetSystemClient

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.

type MockWorkerFactory

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

MockWorkerFactory is a mock of WorkerFactory interface.

func NewMockWorkerFactory

func NewMockWorkerFactory(ctrl *gomock.Controller) *MockWorkerFactory

NewMockWorkerFactory creates a new mock instance.

func (*MockWorkerFactory) EXPECT

func (m *MockWorkerFactory) EXPECT() *MockWorkerFactoryMockRecorder

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

func (*MockWorkerFactory) New

func (m *MockWorkerFactory) New(client client.Client, taskQueue string, options worker.Options) worker.Worker

New mocks base method.

type MockWorkerFactoryMockRecorder

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

MockWorkerFactoryMockRecorder is the mock recorder for MockWorkerFactory.

func (*MockWorkerFactoryMockRecorder) New

func (mr *MockWorkerFactoryMockRecorder) New(client, taskQueue, options interface{}) *gomock.Call

New indicates an expected call of New.

type WorkerFactory

type WorkerFactory interface {
	New(client sdkclient.Client, taskQueue string, options sdkworker.Options) sdkworker.Worker
}