kafka

package

v0.4.2 Latest Latest Go to latest Published: Aug 31, 2023 License: Apache-2.0 Imports: 4 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

Repository

github.com/Octops/agones-event-broadcaster

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func CheckEmpty(source, newValue string) string
func GetTopicIDFromHeader(envelope *events.Envelope) (string, bool)
type Config
- func (c *Config) ApplyDefaults()
type KafkaBroker
- func NewKafkaBroker(config *Config) (*KafkaBroker, error)

Constants ¶

View Source

const (
	TOPIC_ID_HEADER_KEY   = "kafka_topic_id"
	EVENT_TYPE_HEADER_KEY = "kafka_event_type"
	DEFAULT_TOPIC_ID      = "gameserver.events"
)

Variables ¶

This section is empty.

Functions ¶

func CheckEmpty ¶

func CheckEmpty(source, newValue string) string

CheckEmpty is a helper function that will check if source is empty and assign newValue if so

func GetTopicIDFromHeader ¶

func GetTopicIDFromHeader(envelope *events.Envelope) (string, bool)

Types ¶

type Config ¶

type Config struct {
	GenericTopicID   string
	OnAddTopicID     string
	OnUpdateTopicID  string
	OnDeleteTopicID  string
	APIKey           string
	APISecret        string
	BootstrapServers string
}

func (*Config) ApplyDefaults ¶

func (c *Config) ApplyDefaults()

ApplyDefaults sets default values for the Config used by the KafkaBroker

type KafkaBroker ¶

type KafkaBroker struct {
	*Config
	*kafka.Producer
	*kafka.AdminClient
}

func NewKafkaBroker ¶

func NewKafkaBroker(config *Config) (*KafkaBroker, error)

func (*KafkaBroker) BuildEnvelope ¶

func (k *KafkaBroker) BuildEnvelope(event events.Event) (*events.Envelope, error)

func (*KafkaBroker) SendMessage ¶

func (k *KafkaBroker) SendMessage(envelope *events.Envelope) error

func (*KafkaBroker) SetEnvelopeHeader ¶

func (k *KafkaBroker) SetEnvelopeHeader(event events.Event, envelope *events.Envelope)

Source Files ¶

View all Source files

kafka.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL