kafka

package

v0.2.2 Latest Latest Go to latest Published: Sep 19, 2020 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package kafka is a generated GoMock package.

This section is empty.

This section is empty.

func DefaultConfig() *sarama.Config

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

func NewClient(addr []string) (*Client, error)

func (c *Client) Close() (err error)

func (c *Client) SendMessage(topic string, routeKey string, event []byte) (err error)

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

MockPublisher is a mock of Publisher interface

func NewMockPublisher(ctrl *gomock.Controller) *MockPublisher

NewMockPublisher creates a new mock instance

func (m *MockPublisher) Close() error

Close mocks base method

func (m *MockPublisher) EXPECT() *MockPublisherMockRecorder

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

func (m *MockPublisher) Publish(ctx context.Context, topic, routeKey string, event []byte) error

Publish mocks base method

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

MockPublisherMockRecorder is the mock recorder for MockPublisher

func (mr *MockPublisherMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (mr *MockPublisherMockRecorder) Publish(ctx, topic, routeKey, event interface{}) *gomock.Call

Publish indicates an expected call of Publish

type Publisher interface {
	Publish(ctx context.Context, topic string, routeKey string, event []byte) error
	Close() error
}

func New(cli *Client) (Publisher, error)