util

Documentation

Index

• func GetTopicName(topic, topicPrefix string, tableID abstract.TablePartID) string
• func UnquotedFQTNWithPartID(tablePartID abstract.TablePartID) string
• type TimingsStatCollector
  • func NewTimingsStatCollector() *TimingsStatCollector
  • func (t *TimingsStatCollector) Finished(tableID abstract.TablePartID)
  • func (t *TimingsStatCollector) FoundWriter(tableID abstract.TablePartID)
  • func (t *TimingsStatCollector) GetResults() []log.Field
  • func (t *TimingsStatCollector) Started(tableID abstract.TablePartID)
• type TopicDefinition
  • func NewTopicDefinition(topicName, topicPrefix string) (*TopicDefinition, error)

Functions

func GetTopicName

func GetTopicName(topic, topicPrefix string, tableID abstract.TablePartID) string

func UnquotedFQTNWithPartID

func UnquotedFQTNWithPartID(tablePartID abstract.TablePartID) string

Types

type TimingsStatCollector

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

func NewTimingsStatCollector

func NewTimingsStatCollector() *TimingsStatCollector

func (*TimingsStatCollector) Finished

func (t *TimingsStatCollector) Finished(tableID abstract.TablePartID)

func (*TimingsStatCollector) FoundWriter

func (t *TimingsStatCollector) FoundWriter(tableID abstract.TablePartID)

func (*TimingsStatCollector) GetResults

func (t *TimingsStatCollector) GetResults() []log.Field

func (*TimingsStatCollector) Started

func (t *TimingsStatCollector) Started(tableID abstract.TablePartID)

type TopicDefinition

type TopicDefinition struct {
	FullPath   string
	PrefixPath string
}

func NewTopicDefinition

func NewTopicDefinition(topicName, topicPrefix string) (*TopicDefinition, error)