healthcheck

Documentation

Index

• func GetMissingTablets(client *client.YBClient, tablets []string) ([]string, error)
• func GetReplicatedIndexes(log logr.Logger, client *client.YBClient, streamID string, tablets ...string) (*healthcheck.CDCReplicatedIndexListPB, error)
• func GetReplicationLag(replicationIndexes *healthcheck.CDCReplicatedIndexListPB) *healthcheck.CDCReplicatedIndexListPB
• type CDCProducerReport
  • func NewCDCProducerReport(log logr.Logger, consumerClient *client.YBClient, ...) *CDCProducerReport
  • func (r *CDCProducerReport) RunCheck() error
• type CDCProducerStreamReport
  • func NewCDCProducerStreamReport(log logr.Logger, consumerClient *client.YBClient, ...) (*CDCProducerStreamReport, error)
  • func (r *CDCProducerStreamReport) RunCheck() error

Functions

func GetMissingTablets

func GetMissingTablets(client *client.YBClient, tablets []string) ([]string, error)

func GetReplicatedIndexes

func GetReplicatedIndexes(log logr.Logger, client *client.YBClient, streamID string, tablets ...string) (*healthcheck.CDCReplicatedIndexListPB, error)

func GetReplicationLag

func GetReplicationLag(replicationIndexes *healthcheck.CDCReplicatedIndexListPB) *healthcheck.CDCReplicatedIndexListPB

Types

type CDCProducerReport

type CDCProducerReport struct {
	*healthcheck.CDCProducerReportPB

	Log            logr.Logger
	ConsumerClient *client.YBClient
	ConsumerUUID   string
	Producer       *cdc.ProducerEntryPB
	Config         *config.UniverseConfigPB
}

func NewCDCProducerReport

func NewCDCProducerReport(log logr.Logger, consumerClient *client.YBClient, consumerClusterConfig *config.UniverseConfigPB, consumerUUID string, producerID string, producer *cdc.ProducerEntryPB) *CDCProducerReport

func (*CDCProducerReport) RunCheck

func (r *CDCProducerReport) RunCheck() error

type CDCProducerStreamReport

type CDCProducerStreamReport struct {
	*healthcheck.CDCProducerStreamReportPB

	Log            logr.Logger
	ConsumerClient *client.YBClient
	ProducerClient *client.YBClient
	StreamEntry    *cdc.StreamEntryPB
	ConsumerSchema *master.GetTableSchemaResponsePB
	ProducerSchema *master.GetTableSchemaResponsePB
}

func NewCDCProducerStreamReport

func NewCDCProducerStreamReport(log logr.Logger, consumerClient *client.YBClient, producerClient *client.YBClient, streamID string, streamEntry *cdc.StreamEntryPB) (*CDCProducerStreamReport, error)

func (*CDCProducerStreamReport) RunCheck

func (r *CDCProducerStreamReport) RunCheck() error