mgmt

package
v0.0.0-...-160e8be Latest Latest
Warning

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

 Go to latest Published: May 28, 2022 License: MPL-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CONTINUE FindResult = 0
	FOUND               = 1
	STOP                = 2
)

Variables

This section is empty.

Functions

func ConfigReplaceFromFile 

func ConfigReplaceFromFile(
	ctx context.Context,
	strmprov rkcy.StreamProvider,
	platform string,
	environment string,
	adminBrokers string,
	configFilePath string,
)

func ConfigReplaceFromJson 

func ConfigReplaceFromJson(
	ctx context.Context,
	strmprov rkcy.StreamProvider,
	platform string,
	environment string,
	adminBrokers string,
	configJson []byte,
) error

func ConsumeACETopic 

func ConsumeACETopic(
	ctx context.Context,
	wg *sync.WaitGroup,
	strmprov rkcy.StreamProvider,
	platform string,
	environment string,
	adminBrokers string,
	concern string,
	aceTopic rkcy.StandardTopicName,
	match rkcypb.Directive,
	startMatchLoc MatchLoc,
	handler func(rawMsg *RawMessage),
	readyCh chan<- bool,
)

consumeACETopic behaves much like consumeMgmtTopic, but is intended to operate upon Admin, Complete, and Error topics belonging to concerns which are always single partition but may contain divergent generational definitions. The platform topic is read as well, and if the ACE topic being consumed changes definitions, consumeACETopic will automatically adjust to the new current topic definition.

func ConsumeConcernAdminTopic 

func ConsumeConcernAdminTopic(
	ctx context.Context,
	wg *sync.WaitGroup,
	strmprov rkcy.StreamProvider,
	platform string,
	environment string,
	adminBrokers string,
	ch chan<- *ConcernAdminMessage,
	concern string,
	readyCh chan<- bool,
)

func ConsumeConfigTopic 

func ConsumeConfigTopic(
	ctx context.Context,
	wg *sync.WaitGroup,
	strmprov rkcy.StreamProvider,
	platform string,
	environment string,
	adminBrokers string,
	chPublish chan<- *ConfigPublishMessage,
	readyCh chan<- bool,
)

func ConsumeConsumersTopic 

func ConsumeConsumersTopic(
	ctx context.Context,
	wg *sync.WaitGroup,
	strmprov rkcy.StreamProvider,
	platform string,
	environment string,
	adminBrokers string,
	ch chan<- *ConsumerMessage,
	readyCh chan<- bool,
)

func ConsumeMgmtTopic 

func ConsumeMgmtTopic(
	ctx context.Context,
	wg *sync.WaitGroup,
	strmprov rkcy.StreamProvider,
	adminBrokers string,
	fullTopic string,
	match rkcypb.Directive,
	startMatchLoc MatchLoc,
	handler func(rawMsg *RawMessage),
	readyCh chan<- bool,
)

consumeMgmtTopic is intended for single paritition topics used in the management of the system. Examples include platform, consumers, producers, and config topics.

func ConsumePlatformTopic 

func ConsumePlatformTopic(
	ctx context.Context,
	wg *sync.WaitGroup,
	strmprov rkcy.StreamProvider,
	platform string,
	environment string,
	adminBrokers string,
	ch chan<- *PlatformMessage,
	readyCh chan<- bool,
)

func ConsumeProducersTopic 

func ConsumeProducersTopic(
	ctx context.Context,
	wg *sync.WaitGroup,
	strmprov rkcy.StreamProvider,
	platform string,
	environment string,
	adminBrokers string,
	ch chan<- *ProducerMessage,
	readyCh chan<- bool,
)

func FindMostRecentMatching 

func FindMostRecentMatching(
	ctx context.Context,
	strmprov rkcy.StreamProvider,
	brokers string,
	fullTopic string,
	partition int32,
	match rkcypb.Directive,
	matchLoc MatchLoc,
) (bool, int64, error)

func PlatformReplaceFromFile 

func PlatformReplaceFromFile(
	ctx context.Context,
	strmprov rkcy.StreamProvider,
	platform string,
	environment string,
	adminBrokers string,
	platformFilePath string,
)

func PlatformReplaceFromJson 

func PlatformReplaceFromJson(
	ctx context.Context,
	strmprov rkcy.StreamProvider,
	platform string,
	environment string,
	adminBrokers string,
	platformDefJson []byte,
) error

Types

type ConcernAdminMessage 

type ConcernAdminMessage struct {
	Directive             rkcypb.Directive
	Timestamp             time.Time
	Offset                int64
	ConcernAdminDirective *rkcypb.ConcernAdminDirective
}

type ConfigPublishMessage 

type ConfigPublishMessage struct {
	Directive rkcypb.Directive
	Timestamp time.Time
	Offset    int64
	Config    *rkcypb.Config
}

type ConsumerMessage 

type ConsumerMessage struct {
	Directive         rkcypb.Directive
	Timestamp         time.Time
	Offset            int64
	ConsumerDirective *rkcypb.ConsumerDirective
}

type FindResult 

type FindResult int

type MatchLoc 

type MatchLoc int
const (
	PAST_LAST_MATCH MatchLoc = 0
	AT_LAST_MATCH            = 1
)

type PlatformMessage 

type PlatformMessage struct {
	Directive    rkcypb.Directive
	Timestamp    time.Time
	Offset       int64
	NewRtPlatDef *rkcy.RtPlatformDef
	OldRtPlatDef *rkcy.RtPlatformDef
}

type ProducerMessage 

type ProducerMessage struct {
	Directive         rkcypb.Directive
	ProducerDirective *rkcypb.ProducerDirective
	Timestamp         time.Time
	Offset            int64
}

type RawMessage 

type RawMessage struct {
	Directive   rkcypb.Directive
	Value       []byte
	Offset      int64
	Timestamp   time.Time
	TraceParent string
}

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.