Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrUndefinedEntity is returned by the Push method of the [Client] when the // given entity name is unknown. ErrUndefinedEntity = errors.New("undefined entity") // ErrEmptyPayload is returned by the Push method of the [Client] when the // given payload is empty. ErrEmptyPayload = errors.New("payload can't be empty") )
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// Contains the mappings beetween the entity names and the corresponding
// underlaying kafka topics.
Topics map[string]string
// contains filtered or unexported fields
}
Client implements an EventStreamClient using Kafka as the event stream system.
func NewClient ¶
func NewClient(user string, password string, broker string, topics map[string]string) (Client, error)
NewClient creates a new Kafka client connected to the a broker using the given credentials and setting the mapping between all the entities and their corresponding topics.
Source Files
Click to show internal directories.
Click to hide internal directories.