client

README

Eventbus SDK for Vanus

Documentation

Overview

Package client is a generated GoMock package.

Index

• func GetEventbusIDIfNotSet(ctx context.Context, endpoints []string, opts *api.EventbusOptions) error
• type Client
  • func Connect(endpoints []string) Client
• type MockClient
  • func NewMockClient(ctrl *gomock.Controller) *MockClient
  • func (m *MockClient) Disconnect(ctx context.Context)
  • func (m *MockClient) EXPECT() *MockClientMockRecorder
  • func (m *MockClient) Eventbus(ctx context.Context, opts ...api.EventbusOption) api.Eventbus
• type MockClientMockRecorder
  • func (mr *MockClientMockRecorder) Disconnect(ctx interface{}) *gomock.Call
  • func (mr *MockClientMockRecorder) Eventbus(ctx interface{}, opts ...interface{}) *gomock.Call

Functions

func GetEventbusIDIfNotSet

func GetEventbusIDIfNotSet(ctx context.Context, endpoints []string, opts *api.EventbusOptions) error

Types

type Client

type Client interface {
	Eventbus(ctx context.Context, opts ...api.EventbusOption) api.Eventbus
	Disconnect(ctx context.Context)
}

func Connect

func Connect(endpoints []string) Client

type MockClient

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

MockClient is a mock of Client interface.

func NewMockClient

func NewMockClient(ctrl *gomock.Controller) *MockClient

NewMockClient creates a new mock instance.

func (*MockClient) Disconnect

func (m *MockClient) Disconnect(ctx context.Context)

Disconnect mocks base method.

func (*MockClient) EXPECT

func (m *MockClient) EXPECT() *MockClientMockRecorder

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

func (*MockClient) Eventbus

func (m *MockClient) Eventbus(ctx context.Context, opts ...api.EventbusOption) api.Eventbus

Eventbus mocks base method.

type MockClientMockRecorder

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

MockClientMockRecorder is the mock recorder for MockClient.

func (*MockClientMockRecorder) Disconnect

func (mr *MockClientMockRecorder) Disconnect(ctx interface{}) *gomock.Call

Disconnect indicates an expected call of Disconnect.

func (*MockClientMockRecorder) Eventbus

func (mr *MockClientMockRecorder) Eventbus(ctx interface{}, opts ...interface{}) *gomock.Call

Eventbus indicates an expected call of Eventbus.