mgmt

Documentation

Index

• Constants
• func ConfigReplaceFromFile(ctx context.Context, strmprov rkcy.StreamProvider, platform string, ...)
• func ConfigReplaceFromJson(ctx context.Context, strmprov rkcy.StreamProvider, platform string, ...) error
• func ConsumeACETopic(ctx context.Context, wg *sync.WaitGroup, strmprov rkcy.StreamProvider, ...)
• func ConsumeConcernAdminTopic(ctx context.Context, wg *sync.WaitGroup, strmprov rkcy.StreamProvider, ...)
• func ConsumeConfigTopic(ctx context.Context, wg *sync.WaitGroup, strmprov rkcy.StreamProvider, ...)
• func ConsumeConsumersTopic(ctx context.Context, wg *sync.WaitGroup, strmprov rkcy.StreamProvider, ...)
• func ConsumeMgmtTopic(ctx context.Context, wg *sync.WaitGroup, strmprov rkcy.StreamProvider, ...)
• func ConsumePlatformTopic(ctx context.Context, wg *sync.WaitGroup, strmprov rkcy.StreamProvider, ...)
• func ConsumeProducersTopic(ctx context.Context, wg *sync.WaitGroup, strmprov rkcy.StreamProvider, ...)
• func FindMostRecentMatching(ctx context.Context, strmprov rkcy.StreamProvider, brokers string, ...) (bool, int64, error)
• func PlatformReplaceFromFile(ctx context.Context, strmprov rkcy.StreamProvider, platform string, ...)
• func PlatformReplaceFromJson(ctx context.Context, strmprov rkcy.StreamProvider, platform string, ...) error
• type ConcernAdminMessage
• type ConfigPublishMessage
• type ConsumerMessage
• type FindResult
• type MatchLoc
• type PlatformMessage
• type ProducerMessage
• type RawMessage

Constants

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

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
}