healthcheck

package
v0.0.0-...-c201ef6 Latest Latest
Warning

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

 Go to latest Published: Aug 16, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_yugatool_healthcheck_cdc_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CDCProducerReportPB 

type CDCProducerReportPB struct {
	ProducerId              *string                       `protobuf:"bytes,1,req,name=producer_id,json=producerId" json:"producer_id,omitempty"`
	ProducerMasterAddresses []*common.HostPortPB          `protobuf:"bytes,2,rep,name=producer_master_addresses,json=producerMasterAddresses" json:"producer_master_addresses,omitempty"`
	Errors                  *CDCProducerReportPBErrorlist `protobuf:"bytes,3,opt,name=errors" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*CDCProducerReportPB) Descriptor deprecated 

func (*CDCProducerReportPB) Descriptor() ([]byte, []int)

Deprecated: Use CDCProducerReportPB.ProtoReflect.Descriptor instead.

func (*CDCProducerReportPB) GetErrors 

func (x *CDCProducerReportPB) GetErrors() *CDCProducerReportPBErrorlist

func (*CDCProducerReportPB) GetProducerId 

func (x *CDCProducerReportPB) GetProducerId() string

func (*CDCProducerReportPB) GetProducerMasterAddresses 

func (x *CDCProducerReportPB) GetProducerMasterAddresses() []*common.HostPortPB

func (*CDCProducerReportPB) MarshalJSON 

func (m *CDCProducerReportPB) MarshalJSON() ([]byte, error)

func (*CDCProducerReportPB) ProtoMessage 

func (*CDCProducerReportPB) ProtoMessage()

func (*CDCProducerReportPB) ProtoReflect 

func (x *CDCProducerReportPB) ProtoReflect() protoreflect.Message

func (*CDCProducerReportPB) Reset 

func (x *CDCProducerReportPB) Reset()

func (*CDCProducerReportPB) String 

func (x *CDCProducerReportPB) String() string

func (*CDCProducerReportPB) UnmarshalJSON 

func (m *CDCProducerReportPB) UnmarshalJSON(b []byte) error

type CDCProducerReportPBErrorlist 

type CDCProducerReportPBErrorlist struct {
	MastersReferenceSelf *bool                        `protobuf:"varint,1,opt,name=masters_reference_self,json=mastersReferenceSelf" json:"masters_reference_self,omitempty"`
	StreamReports        []*CDCProducerStreamReportPB `protobuf:"bytes,2,rep,name=stream_reports,json=streamReports" json:"stream_reports,omitempty"`
	// contains filtered or unexported fields
}

TODO: should reimplemented to be a list of app status errors

func (*CDCProducerReportPBErrorlist) Descriptor deprecated 

func (*CDCProducerReportPBErrorlist) Descriptor() ([]byte, []int)

Deprecated: Use CDCProducerReportPBErrorlist.ProtoReflect.Descriptor instead.

func (*CDCProducerReportPBErrorlist) GetMastersReferenceSelf 

func (x *CDCProducerReportPBErrorlist) GetMastersReferenceSelf() bool

func (*CDCProducerReportPBErrorlist) GetStreamReports 

func (x *CDCProducerReportPBErrorlist) GetStreamReports() []*CDCProducerStreamReportPB

func (*CDCProducerReportPBErrorlist) ProtoMessage 

func (*CDCProducerReportPBErrorlist) ProtoMessage()

func (*CDCProducerReportPBErrorlist) ProtoReflect 

func (x *CDCProducerReportPBErrorlist) ProtoReflect() protoreflect.Message

func (*CDCProducerReportPBErrorlist) Reset 

func (x *CDCProducerReportPBErrorlist) Reset()

func (*CDCProducerReportPBErrorlist) String 

func (x *CDCProducerReportPBErrorlist) String() string

type CDCProducerStreamReportPB 

type CDCProducerStreamReportPB struct {
	Table               *master.TableIdentifierPB           `protobuf:"bytes,1,req,name=table" json:"table,omitempty"`
	ConsumerTableId     *string                             `protobuf:"bytes,2,req,name=consumer_table_id,json=consumerTableId" json:"consumer_table_id,omitempty"`
	ProducerTableId     *string                             `protobuf:"bytes,3,req,name=producer_table_id,json=producerTableId" json:"producer_table_id,omitempty"`
	StreamId            *string                             `protobuf:"bytes,4,req,name=stream_id,json=streamId" json:"stream_id,omitempty"`
	ConsumerTabletCount *uint32                             `protobuf:"varint,5,req,name=consumer_tablet_count,json=consumerTabletCount" json:"consumer_tablet_count,omitempty"`
	ProducerTabletCount *uint32                             `protobuf:"varint,6,req,name=producer_tablet_count,json=producerTabletCount" json:"producer_tablet_count,omitempty"`
	Errors              *CDCProducerStreamReportPBErrorlist `protobuf:"bytes,7,opt,name=errors" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*CDCProducerStreamReportPB) Descriptor deprecated 

func (*CDCProducerStreamReportPB) Descriptor() ([]byte, []int)

Deprecated: Use CDCProducerStreamReportPB.ProtoReflect.Descriptor instead.

func (*CDCProducerStreamReportPB) GetConsumerTableId 

func (x *CDCProducerStreamReportPB) GetConsumerTableId() string

func (*CDCProducerStreamReportPB) GetConsumerTabletCount 

func (x *CDCProducerStreamReportPB) GetConsumerTabletCount() uint32

func (*CDCProducerStreamReportPB) GetErrors 

func (x *CDCProducerStreamReportPB) GetErrors() *CDCProducerStreamReportPBErrorlist

func (*CDCProducerStreamReportPB) GetProducerTableId 

func (x *CDCProducerStreamReportPB) GetProducerTableId() string

func (*CDCProducerStreamReportPB) GetProducerTabletCount 

func (x *CDCProducerStreamReportPB) GetProducerTabletCount() uint32

func (*CDCProducerStreamReportPB) GetStreamId 

func (x *CDCProducerStreamReportPB) GetStreamId() string

func (*CDCProducerStreamReportPB) GetTable 

func (x *CDCProducerStreamReportPB) GetTable() *master.TableIdentifierPB

func (*CDCProducerStreamReportPB) MarshalJSON 

func (m *CDCProducerStreamReportPB) MarshalJSON() ([]byte, error)

func (*CDCProducerStreamReportPB) ProtoMessage 

func (*CDCProducerStreamReportPB) ProtoMessage()

func (*CDCProducerStreamReportPB) ProtoReflect 

func (x *CDCProducerStreamReportPB) ProtoReflect() protoreflect.Message

func (*CDCProducerStreamReportPB) Reset 

func (x *CDCProducerStreamReportPB) Reset()

func (*CDCProducerStreamReportPB) String 

func (x *CDCProducerStreamReportPB) String() string

func (*CDCProducerStreamReportPB) UnmarshalJSON 

func (m *CDCProducerStreamReportPB) UnmarshalJSON(b []byte) error

type CDCProducerStreamReportPBErrorlist 

type CDCProducerStreamReportPBErrorlist struct {
	ConsumerSchemaError       *master.MasterErrorPB     `protobuf:"bytes,1,opt,name=consumer_schema_error,json=consumerSchemaError" json:"consumer_schema_error,omitempty"`
	ProducerSchemaError       *master.MasterErrorPB     `protobuf:"bytes,2,opt,name=producer_schema_error,json=producerSchemaError" json:"producer_schema_error,omitempty"`
	MissingTabletsConsumer    []string                  `protobuf:"bytes,3,rep,name=missing_tablets_consumer,json=missingTabletsConsumer" json:"missing_tablets_consumer,omitempty"`
	MissingTabletsProducer    []string                  `protobuf:"bytes,4,rep,name=missing_tablets_producer,json=missingTabletsProducer" json:"missing_tablets_producer,omitempty"`
	TabletsWithReplicationLag *CDCReplicatedIndexListPB `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

TODO: should reimplemented to be a list of app status errors

func (*CDCProducerStreamReportPBErrorlist) Descriptor deprecated 

func (*CDCProducerStreamReportPBErrorlist) Descriptor() ([]byte, []int)

Deprecated: Use CDCProducerStreamReportPBErrorlist.ProtoReflect.Descriptor instead.

func (*CDCProducerStreamReportPBErrorlist) GetConsumerSchemaError 

func (x *CDCProducerStreamReportPBErrorlist) GetConsumerSchemaError() *master.MasterErrorPB

func (*CDCProducerStreamReportPBErrorlist) GetMissingTabletsConsumer 

func (x *CDCProducerStreamReportPBErrorlist) GetMissingTabletsConsumer() []string

func (*CDCProducerStreamReportPBErrorlist) GetMissingTabletsProducer 

func (x *CDCProducerStreamReportPBErrorlist) GetMissingTabletsProducer() []string

func (*CDCProducerStreamReportPBErrorlist) GetProducerSchemaError 

func (x *CDCProducerStreamReportPBErrorlist) GetProducerSchemaError() *master.MasterErrorPB

func (*CDCProducerStreamReportPBErrorlist) GetTabletsWithReplicationLag 

func (x *CDCProducerStreamReportPBErrorlist) GetTabletsWithReplicationLag() *CDCReplicatedIndexListPB

func (*CDCProducerStreamReportPBErrorlist) ProtoMessage 

func (*CDCProducerStreamReportPBErrorlist) ProtoMessage()

func (*CDCProducerStreamReportPBErrorlist) ProtoReflect 

func (x *CDCProducerStreamReportPBErrorlist) ProtoReflect() protoreflect.Message

func (*CDCProducerStreamReportPBErrorlist) Reset 

func (x *CDCProducerStreamReportPBErrorlist) Reset()

func (*CDCProducerStreamReportPBErrorlist) String 

func (x *CDCProducerStreamReportPBErrorlist) String() string

type CDCReplicatedIndexListPB 

type CDCReplicatedIndexListPB struct {
	ReplicatedIndexList []*CDCReplicatedIndexPB `protobuf:"bytes,1,rep,name=replicated_index_list,json=replicatedIndexList" json:"replicated_index_list,omitempty"`
	// contains filtered or unexported fields
}

func (*CDCReplicatedIndexListPB) Descriptor deprecated 

func (*CDCReplicatedIndexListPB) Descriptor() ([]byte, []int)

Deprecated: Use CDCReplicatedIndexListPB.ProtoReflect.Descriptor instead.

func (*CDCReplicatedIndexListPB) GetReplicatedIndexList 

func (x *CDCReplicatedIndexListPB) GetReplicatedIndexList() []*CDCReplicatedIndexPB

func (*CDCReplicatedIndexListPB) MarshalJSON 

func (m *CDCReplicatedIndexListPB) MarshalJSON() ([]byte, error)

func (*CDCReplicatedIndexListPB) ProtoMessage 

func (*CDCReplicatedIndexListPB) ProtoMessage()

func (*CDCReplicatedIndexListPB) ProtoReflect 

func (x *CDCReplicatedIndexListPB) ProtoReflect() protoreflect.Message

func (*CDCReplicatedIndexListPB) Reset 

func (x *CDCReplicatedIndexListPB) Reset()

func (*CDCReplicatedIndexListPB) String 

func (x *CDCReplicatedIndexListPB) String() string

func (*CDCReplicatedIndexListPB) UnmarshalJSON 

func (m *CDCReplicatedIndexListPB) UnmarshalJSON(b []byte) error

type CDCReplicatedIndexPB 

type CDCReplicatedIndexPB struct {
	Tablet             *string      `protobuf:"bytes,1,req,name=tablet" json:"tablet,omitempty"`
	LatestOpid         *util.OpIdPB `protobuf:"bytes,2,req,name=latest_opid,json=latestOpid" json:"latest_opid,omitempty"`
	CheckpointLocation *util.OpIdPB `protobuf:"bytes,3,req,name=checkpoint_location,json=checkpointLocation" json:"checkpoint_location,omitempty"`
	// contains filtered or unexported fields
}

func (*CDCReplicatedIndexPB) Descriptor deprecated 

func (*CDCReplicatedIndexPB) Descriptor() ([]byte, []int)

Deprecated: Use CDCReplicatedIndexPB.ProtoReflect.Descriptor instead.

func (*CDCReplicatedIndexPB) GetCheckpointLocation 

func (x *CDCReplicatedIndexPB) GetCheckpointLocation() *util.OpIdPB

func (*CDCReplicatedIndexPB) GetLatestOpid 

func (x *CDCReplicatedIndexPB) GetLatestOpid() *util.OpIdPB

func (*CDCReplicatedIndexPB) GetTablet 

func (x *CDCReplicatedIndexPB) GetTablet() string

func (*CDCReplicatedIndexPB) MarshalJSON 

func (m *CDCReplicatedIndexPB) MarshalJSON() ([]byte, error)

func (*CDCReplicatedIndexPB) ProtoMessage 

func (*CDCReplicatedIndexPB) ProtoMessage()

func (*CDCReplicatedIndexPB) ProtoReflect 

func (x *CDCReplicatedIndexPB) ProtoReflect() protoreflect.Message

func (*CDCReplicatedIndexPB) Reset 

func (x *CDCReplicatedIndexPB) Reset()

func (*CDCReplicatedIndexPB) String 

func (x *CDCReplicatedIndexPB) String() string

func (*CDCReplicatedIndexPB) UnmarshalJSON 

func (m *CDCReplicatedIndexPB) UnmarshalJSON(b []byte) error

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.