check

Sep 8, 2020

Changes in this version

+ func FormatResults(results TopicCheckResults) string

+ type CheckConfig struct

+ AdminClient *admin.Client

+ CheckLeaders bool

+ ClusterConfig config.ClusterConfig

+ NumRacks int

+ TopicConfig config.TopicConfig

+ ValidateOnly bool

+ type CheckName string

+ const CheckNameConfigCorrect

+ const CheckNameConfigSettingsCorrect

+ const CheckNameConfigsConsistent

+ const CheckNameLeadersCorrect

+ const CheckNamePartitionCountCorrect

+ const CheckNameReplicasInSync

+ const CheckNameReplicationFactorCorrect

+ const CheckNameThrottlesClear

+ const CheckNameTopicExists

+ type TopicCheckResult struct

+ Description string

+ Name CheckName

+ OK bool

+ type TopicCheckResults struct

+ Results []TopicCheckResult

+ func CheckTopic(ctx context.Context, config CheckConfig) (TopicCheckResults, error)

+ func (r *TopicCheckResults) AllOK() bool

+ func (r *TopicCheckResults) AppendResult(result TopicCheckResult)

+ func (r *TopicCheckResults) UpdateLastResult(ok bool, description string)