kafkaHelper

package

v0.0.0-...-3beb7e2 Latest Latest Go to latest Published: Jan 14, 2022 License: GPL-2.0 Imports: 10 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/visitskyworld/dia-data

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func GetElements(topic int, offset int64, nbElements int) ([]interface{}, error)
func GetLastElement(topic int) (interface{}, error)
func GetLastElementWithRetryOnError(topic int) interface{}
func GetTopic(topic int) string
func IsTopicEmpty(topic int) bool
func NewReader(topic int) *kafka.Reader
func NewReaderNextMessage(topic int) *kafka.Reader
func NewReaderXElementsBeforeLastMessage(topic int, x int64) *kafka.Reader
func NewSyncWriter(topic int) *kafka.Writer
func NewWriter(topic int) *kafka.Writer
func ReadOffset(topic int) (int64, error)
func ReadOffsetWithRetryOnError(topic int) (offset int64)
func WriteMessage(w *kafka.Writer, m KafkaMessage) error
type Config
type KafkaMessage
type KafkaMessageWithAHash

Constants ¶

View Source

const (
	TopicIndexBlock      = 0
	TopicFiltersBlock    = 1
	TopicTrades          = 2
	TopicTradesBlock     = 3
	TopicSuppliesBlock   = 7
	TopicIndexBlock2     = 8
	TopicIndexBlockDaily = 11

	TopicOptionOrderBook = 13
)

Variables ¶

This section is empty.

Functions ¶

func GetElements ¶

func GetElements(topic int, offset int64, nbElements int) ([]interface{}, error)

func GetLastElement ¶

func GetLastElement(topic int) (interface{}, error)

func GetLastElementWithRetryOnError ¶

func GetLastElementWithRetryOnError(topic int) interface{}

func GetTopic ¶

func GetTopic(topic int) string

func IsTopicEmpty ¶

func IsTopicEmpty(topic int) bool

func NewReader ¶

func NewReader(topic int) *kafka.Reader

func NewReaderNextMessage ¶

func NewReaderNextMessage(topic int) *kafka.Reader

func NewReaderXElementsBeforeLastMessage ¶

func NewReaderXElementsBeforeLastMessage(topic int, x int64) *kafka.Reader

func NewSyncWriter ¶

func NewSyncWriter(topic int) *kafka.Writer

func NewWriter ¶

func NewWriter(topic int) *kafka.Writer

func ReadOffset ¶

func ReadOffset(topic int) (int64, error)

WithRetryOnError

func ReadOffsetWithRetryOnError ¶

func ReadOffsetWithRetryOnError(topic int) (offset int64)

func WriteMessage ¶

func WriteMessage(w *kafka.Writer, m KafkaMessage) error

Types ¶

type Config ¶

type Config struct {
	KafkaUrl []string
}

var KafkaConfig Config

type KafkaMessage ¶

type KafkaMessage interface {
	MarshalBinary() ([]byte, error)
}

type KafkaMessageWithAHash ¶

type KafkaMessageWithAHash interface {
	Hash() string
}

Source Files ¶

View all Source files

Kafka.go

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