topic

Documentation

Overview

Package topic is a generated GoMock package.

Index

• type Client
  • func NewClient(opts ...Option) (Client, error)
• type MockClient
  • func NewMockClient(ctrl *gomock.Controller) *MockClient
  • func (m *MockClient) Add(topicName string, consumerSvc *topicpb.ConsumerService) error
  • func (m *MockClient) Delete(topicName string) error
  • func (m *MockClient) EXPECT() *MockClientMockRecorder
  • func (m *MockClient) Get(topicName string) (topic.Topic, error)
  • func (m *MockClient) Init(name string, req *admin.TopicInitRequest) error
• type MockClientMockRecorder
  • func (mr *MockClientMockRecorder) Add(topicName, consumerSvc interface{}) *gomock.Call
  • func (mr *MockClientMockRecorder) Delete(topicName interface{}) *gomock.Call
  • func (mr *MockClientMockRecorder) Get(topicName interface{}) *gomock.Call
  • func (mr *MockClientMockRecorder) Init(name, req interface{}) *gomock.Call
• type Option
  • func WithClient(cl m3admin.Client) Option
  • func WithLogger(logger *zap.Logger) Option
  • func WithURL(u string) Option

Types

type Client

type Client interface {
	Init(name string, req *admin.TopicInitRequest) error
	Get(topicName string) (m3topic.Topic, error)
	Delete(topicName string) error
	Add(topicName string, consumerSvc *topicpb.ConsumerService) error
}

Client provides the interface to interact with the topic APIs.

func NewClient

func NewClient(opts ...Option) (Client, error)

NewClient creates a new topic 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) Add

func (m *MockClient) Add(topicName string, consumerSvc *topicpb.ConsumerService) error

Add mocks base method.

func (*MockClient) Delete

func (m *MockClient) Delete(topicName string) error

Delete 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) Get

func (m *MockClient) Get(topicName string) (topic.Topic, error)

Get mocks base method.

func (*MockClient) Init

func (m *MockClient) Init(name string, req *admin.TopicInitRequest) error

Init mocks base method.

type MockClientMockRecorder

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

MockClientMockRecorder is the mock recorder for MockClient.

func (*MockClientMockRecorder) Add

func (mr *MockClientMockRecorder) Add(topicName, consumerSvc interface{}) *gomock.Call

Add indicates an expected call of Add.

func (*MockClientMockRecorder) Delete

func (mr *MockClientMockRecorder) Delete(topicName interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockClientMockRecorder) Get

func (mr *MockClientMockRecorder) Get(topicName interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockClientMockRecorder) Init

func (mr *MockClientMockRecorder) Init(name, req interface{}) *gomock.Call

Init indicates an expected call of Init.

type Option

type Option interface {
	// contains filtered or unexported methods
}

Option provides an interface that can be used for setter options with the constructor

func WithClient

func WithClient(cl m3admin.Client) Option

WithClient configures an m3admin client.

func WithLogger

func WithLogger(logger *zap.Logger) Option

WithLogger is a setter to override the default logger

func WithURL

func WithURL(u string) Option

WithURL is a setter to override the default URL