messaging

package
v0.4.14 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 11, 2020 License: MIT Imports: 15 Imported by: 0

Documentation

Overview

Package messaging is a generated GoMock package.

Package messaging is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InitConfig added in v0.4.10 

func InitConfig()

Types

type BrokerReader 

type BrokerReader interface {
	FetchMessage(ctx context.Context) (Message, error)
	CommitMessages(ctx context.Context, msgs ...Message) error
	ReadMessage(ctx context.Context) (Message, error)
	io.Closer
}

BrokerReader interface used for underlying broker implementation

type BrokerWriter 

type BrokerWriter interface {
	WriteMessages(ctx context.Context, msgs ...Message) error
	io.Closer
}

BrokerWriter interface used for underlying broker implementation

type KafkaReader added in v0.4.10 

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

KafkaReader used as a default missy Reader implementation

func NewReader 

func NewReader(brokers []string, groupID string, topic string) *KafkaReader

NewReader based on brokers hosts, consumerGroup and topic. You need to close it after use. (Close()) we are leaving using the missy config for now, because we don't know how we want to configure this yet.

func NewReaderWithDLQ added in v0.4.10 

func NewReaderWithDLQ(brokers []string, groupID string, topic string, dlqTopic string) *KafkaReader

NewReaderWithDLQ a reader with DLQ

func (*KafkaReader) Close added in v0.4.10 

func (mr *KafkaReader) Close() error

Close used to close underlying connection with broker

func (*KafkaReader) Read added in v0.4.10 

func (mr *KafkaReader) Read(msgFunc ReadMessageFunc) error

Read start reading goroutine that calls msgFunc on new message, you need to close it after use

type Message 

type Message struct {
	Topic     string
	Key       []byte
	Value     []byte
	Time      time.Time
	Partition int
	Offset    int64
}

Message is a Kafka message

func (Message) Hash 

func (m Message) Hash(hash hash.Hash) ([]byte, error)

Hash returns bytes array of a hash of a Message using provided hash mechanism

func (Message) HashString 

func (m Message) HashString(hash hash.Hash) (string, error)

HashString returns string representation of a hash of a Message using provided hash mechanism

func (Message) Sha256 

func (m Message) Sha256() ([]byte, error)

Sha256 returns bytes array of a hash of a Message using Sha256 hash mechanism

func (Message) Sha256String 

func (m Message) Sha256String() (string, error)

Sha256String returns string representation of a hash of a Message Sha256 hash mechanism

type MockBrokerReader 

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

MockBrokerReader is a mock of BrokerReader interface

func NewMockBrokerReader 

func NewMockBrokerReader(ctrl *gomock.Controller) *MockBrokerReader

NewMockBrokerReader creates a new mock instance

func (*MockBrokerReader) Close 

func (m *MockBrokerReader) Close() error

Close mocks base method

func (*MockBrokerReader) CommitMessages 

func (m *MockBrokerReader) CommitMessages(ctx context.Context, msgs ...Message) error

CommitMessages mocks base method

func (*MockBrokerReader) EXPECT 

func (m *MockBrokerReader) EXPECT() *MockBrokerReaderMockRecorder

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

func (*MockBrokerReader) FetchMessage 

func (m *MockBrokerReader) FetchMessage(ctx context.Context) (Message, error)

FetchMessage mocks base method

func (*MockBrokerReader) ReadMessage 

func (m *MockBrokerReader) ReadMessage(ctx context.Context) (Message, error)

ReadMessage mocks base method

type MockBrokerReaderMockRecorder 

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

MockBrokerReaderMockRecorder is the mock recorder for MockBrokerReader

func (*MockBrokerReaderMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockBrokerReaderMockRecorder) CommitMessages 

func (mr *MockBrokerReaderMockRecorder) CommitMessages(ctx interface{}, msgs ...interface{}) *gomock.Call

CommitMessages indicates an expected call of CommitMessages

func (*MockBrokerReaderMockRecorder) FetchMessage 

func (mr *MockBrokerReaderMockRecorder) FetchMessage(ctx interface{}) *gomock.Call

FetchMessage indicates an expected call of FetchMessage

func (*MockBrokerReaderMockRecorder) ReadMessage 

func (mr *MockBrokerReaderMockRecorder) ReadMessage(ctx interface{}) *gomock.Call

ReadMessage indicates an expected call of ReadMessage

type MockBrokerWriter 

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

MockBrokerWriter is a mock of BrokerWriter interface

func NewMockBrokerWriter 

func NewMockBrokerWriter(ctrl *gomock.Controller) *MockBrokerWriter

NewMockBrokerWriter creates a new mock instance

func (*MockBrokerWriter) Close 

func (m *MockBrokerWriter) Close() error

Close mocks base method

func (*MockBrokerWriter) EXPECT 

func (m *MockBrokerWriter) EXPECT() *MockBrokerWriterMockRecorder

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

func (*MockBrokerWriter) WriteMessages 

func (m *MockBrokerWriter) WriteMessages(ctx context.Context, msgs ...Message) error

WriteMessages mocks base method

type MockBrokerWriterMockRecorder 

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

MockBrokerWriterMockRecorder is the mock recorder for MockBrokerWriter

func (*MockBrokerWriterMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockBrokerWriterMockRecorder) WriteMessages 

func (mr *MockBrokerWriterMockRecorder) WriteMessages(ctx interface{}, msgs ...interface{}) *gomock.Call

WriteMessages indicates an expected call of WriteMessages

type MockReader 

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

MockReader is a mock of Reader interface

func NewMockReader 

func NewMockReader(ctrl *gomock.Controller) *MockReader

NewMockReader creates a new mock instance

func (*MockReader) Close 

func (m *MockReader) Close() error

Close mocks base method

func (*MockReader) EXPECT 

func (m *MockReader) EXPECT() *MockReaderMockRecorder

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

func (*MockReader) Read 

func (m *MockReader) Read(msgFunc ReadMessageFunc) error

Read mocks base method

type MockReaderMockRecorder 

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

MockReaderMockRecorder is the mock recorder for MockReader

func (*MockReaderMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockReaderMockRecorder) Read 

func (mr *MockReaderMockRecorder) Read(msgFunc interface{}) *gomock.Call

Read indicates an expected call of Read

type MockWriter 

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

MockWriter is a mock of Writer interface

func NewMockWriter 

func NewMockWriter(ctrl *gomock.Controller) *MockWriter

NewMockWriter creates a new mock instance

func (*MockWriter) Close 

func (m *MockWriter) Close() error

Close mocks base method

func (*MockWriter) EXPECT 

func (m *MockWriter) EXPECT() *MockWriterMockRecorder

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

func (*MockWriter) Write 

func (m *MockWriter) Write(key, value []byte) error

Write mocks base method

type MockWriterMockRecorder 

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

MockWriterMockRecorder is the mock recorder for MockWriter

func (*MockWriterMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockWriterMockRecorder) Write 

func (mr *MockWriterMockRecorder) Write(key, value interface{}) *gomock.Call

Write indicates an expected call of Write

type ReadMessageFunc 

type ReadMessageFunc func(msg Message) error

ReadMessageFunc is a message reading callback function, on error message will not be committed to underlying

type Reader 

type Reader interface {
	Read(msgFunc ReadMessageFunc) error
	io.Closer
}

Reader is used to read messages giving callback function

type Writer 

type Writer interface {
	Write(key []byte, value []byte) error
	io.Closer
}

Writer is used to write messages to underlying broker

func NewWriter 

func NewWriter(brokers []string, topic string) Writer

NewWriter based on brokers hosts, consumerGroup and topic. You need to close it after use. (Close()) we are leaving using the missy config for now, because we don't know how we want to configure this yet.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
JackTT - Gopher 🇻🇳