Documentation ¶
Index ¶
- Variables
- type Bootstrap
- func (*Bootstrap) Descriptor() ([]byte, []int)deprecated
- func (x *Bootstrap) GetCanal() *Canal
- func (x *Bootstrap) GetData() *Data
- func (x *Bootstrap) GetLogger() *log.Conf
- func (x *Bootstrap) GetMonitor() *Monitor
- func (x *Bootstrap) GetReg() *registry.Conf
- func (x *Bootstrap) GetServer() *Server
- func (x *Bootstrap) GetService() *Service
- func (x *Bootstrap) GetTrace() *tracing.Conf
- func (*Bootstrap) ProtoMessage()
- func (x *Bootstrap) ProtoReflect() protoreflect.Message
- func (x *Bootstrap) Reset()
- func (x *Bootstrap) String() string
- func (m *Bootstrap) Validate() error
- type BootstrapValidationError
- type Canal
- func (*Canal) Descriptor() ([]byte, []int)deprecated
- func (x *Canal) GetHbaseInstances() []*Canal_HBaseIns
- func (x *Canal) GetInstances() []*Canal_Ins
- func (x *Canal) GetTidbInstances() []*Canal_TiDBIns
- func (*Canal) ProtoMessage()
- func (x *Canal) ProtoReflect() protoreflect.Message
- func (x *Canal) Reset()
- func (x *Canal) String() string
- func (m *Canal) Validate() error
- type CanalEv
- type CanalValidationError
- type Canal_Addition
- func (*Canal_Addition) Descriptor() ([]byte, []int)deprecated
- func (x *Canal_Addition) GetOmitField() []string
- func (x *Canal_Addition) GetPrimaryKey() []string
- func (*Canal_Addition) ProtoMessage()
- func (x *Canal_Addition) ProtoReflect() protoreflect.Message
- func (x *Canal_Addition) Reset()
- func (x *Canal_Addition) String() string
- func (m *Canal_Addition) Validate() error
- type Canal_AdditionValidationError
- func (e Canal_AdditionValidationError) Cause() error
- func (e Canal_AdditionValidationError) Error() string
- func (e Canal_AdditionValidationError) ErrorName() string
- func (e Canal_AdditionValidationError) Field() string
- func (e Canal_AdditionValidationError) Key() bool
- func (e Canal_AdditionValidationError) Reason() string
- type Canal_CTable
- func (*Canal_CTable) Descriptor() ([]byte, []int)deprecated
- func (x *Canal_CTable) GetName() string
- func (x *Canal_CTable) GetOmitAction() []string
- func (x *Canal_CTable) GetOmitField() []string
- func (x *Canal_CTable) GetPrimaryKey() []string
- func (x *Canal_CTable) GetTables() []string
- func (*Canal_CTable) ProtoMessage()
- func (x *Canal_CTable) ProtoReflect() protoreflect.Message
- func (x *Canal_CTable) Reset()
- func (x *Canal_CTable) String() string
- func (m *Canal_CTable) Validate() error
- type Canal_CTableValidationError
- func (e Canal_CTableValidationError) Cause() error
- func (e Canal_CTableValidationError) Error() string
- func (e Canal_CTableValidationError) ErrorName() string
- func (e Canal_CTableValidationError) Field() string
- func (e Canal_CTableValidationError) Key() bool
- func (e Canal_CTableValidationError) Reason() string
- type Canal_Database
- func (db *Canal_Database) CheckTable(addr, user, passwd string) (err error)
- func (*Canal_Database) Descriptor() ([]byte, []int)deprecated
- func (x *Canal_Database) GetCtables() []*Canal_CTable
- func (x *Canal_Database) GetDatabus() *Kafka
- func (x *Canal_Database) GetInfoc() *Canal_Database_Infoc
- func (x *Canal_Database) GetSchema() string
- func (x *Canal_Database) GetTableMap() map[string]*Canal_Addition
- func (*Canal_Database) ProtoMessage()
- func (x *Canal_Database) ProtoReflect() protoreflect.Message
- func (x *Canal_Database) Reset()
- func (x *Canal_Database) String() string
- func (m *Canal_Database) Validate() error
- type Canal_DatabaseValidationError
- func (e Canal_DatabaseValidationError) Cause() error
- func (e Canal_DatabaseValidationError) Error() string
- func (e Canal_DatabaseValidationError) ErrorName() string
- func (e Canal_DatabaseValidationError) Field() string
- func (e Canal_DatabaseValidationError) Key() bool
- func (e Canal_DatabaseValidationError) Reason() string
- type Canal_Database_Infoc
- func (*Canal_Database_Infoc) Descriptor() ([]byte, []int)deprecated
- func (x *Canal_Database_Infoc) GetAddr() string
- func (x *Canal_Database_Infoc) GetProto() string
- func (x *Canal_Database_Infoc) GetReporterAddr() string
- func (x *Canal_Database_Infoc) GetTaskID() string
- func (*Canal_Database_Infoc) ProtoMessage()
- func (x *Canal_Database_Infoc) ProtoReflect() protoreflect.Message
- func (x *Canal_Database_Infoc) Reset()
- func (x *Canal_Database_Infoc) String() string
- func (m *Canal_Database_Infoc) Validate() error
- type Canal_Database_InfocValidationError
- func (e Canal_Database_InfocValidationError) Cause() error
- func (e Canal_Database_InfocValidationError) Error() string
- func (e Canal_Database_InfocValidationError) ErrorName() string
- func (e Canal_Database_InfocValidationError) Field() string
- func (e Canal_Database_InfocValidationError) Key() bool
- func (e Canal_Database_InfocValidationError) Reason() string
- type Canal_HBaseIns
- func (*Canal_HBaseIns) Descriptor() ([]byte, []int)deprecated
- func (x *Canal_HBaseIns) GetAddrs() []string
- func (x *Canal_HBaseIns) GetCluster() string
- func (x *Canal_HBaseIns) GetMonitorPeriod() *durationpb.Duration
- func (x *Canal_HBaseIns) GetRoot() string
- func (*Canal_HBaseIns) ProtoMessage()
- func (x *Canal_HBaseIns) ProtoReflect() protoreflect.Message
- func (x *Canal_HBaseIns) Reset()
- func (x *Canal_HBaseIns) String() string
- func (m *Canal_HBaseIns) Validate() error
- type Canal_HBaseInsValidationError
- func (e Canal_HBaseInsValidationError) Cause() error
- func (e Canal_HBaseInsValidationError) Error() string
- func (e Canal_HBaseInsValidationError) ErrorName() string
- func (e Canal_HBaseInsValidationError) Field() string
- func (e Canal_HBaseInsValidationError) Key() bool
- func (e Canal_HBaseInsValidationError) Reason() string
- type Canal_Ins
- func (*Canal_Ins) Descriptor() ([]byte, []int)deprecated
- func (x *Canal_Ins) GetConfig() *Canal_Ins_CanalConfig
- func (x *Canal_Ins) GetDatabases() []*Canal_Database
- func (x *Canal_Ins) GetMasterInfo() *MasterInfo
- func (x *Canal_Ins) GetMonitorOff() bool
- func (x *Canal_Ins) GetMonitorPeriod() *durationpb.Duration
- func (*Canal_Ins) ProtoMessage()
- func (x *Canal_Ins) ProtoReflect() protoreflect.Message
- func (x *Canal_Ins) Reset()
- func (x *Canal_Ins) String() string
- func (m *Canal_Ins) Validate() error
- type Canal_InsValidationError
- type Canal_Ins_CanalConfig
- func (*Canal_Ins_CanalConfig) Descriptor() ([]byte, []int)deprecated
- func (x *Canal_Ins_CanalConfig) GetAddr() string
- func (x *Canal_Ins_CanalConfig) GetCharset() string
- func (x *Canal_Ins_CanalConfig) GetFlavor() string
- func (x *Canal_Ins_CanalConfig) GetHeartbeatPeriod() *durationpb.Duration
- func (x *Canal_Ins_CanalConfig) GetParseTime() bool
- func (x *Canal_Ins_CanalConfig) GetPassword() string
- func (x *Canal_Ins_CanalConfig) GetReadTimeout() *durationpb.Duration
- func (x *Canal_Ins_CanalConfig) GetServerID() uint32
- func (x *Canal_Ins_CanalConfig) GetUseDecimal() bool
- func (x *Canal_Ins_CanalConfig) GetUser() string
- func (*Canal_Ins_CanalConfig) ProtoMessage()
- func (x *Canal_Ins_CanalConfig) ProtoReflect() protoreflect.Message
- func (x *Canal_Ins_CanalConfig) Reset()
- func (x *Canal_Ins_CanalConfig) String() string
- func (m *Canal_Ins_CanalConfig) Validate() error
- type Canal_Ins_CanalConfigValidationError
- func (e Canal_Ins_CanalConfigValidationError) Cause() error
- func (e Canal_Ins_CanalConfigValidationError) Error() string
- func (e Canal_Ins_CanalConfigValidationError) ErrorName() string
- func (e Canal_Ins_CanalConfigValidationError) Field() string
- func (e Canal_Ins_CanalConfigValidationError) Key() bool
- func (e Canal_Ins_CanalConfigValidationError) Reason() string
- type Canal_TiDBIns
- func (*Canal_TiDBIns) Descriptor() ([]byte, []int)deprecated
- func (x *Canal_TiDBIns) GetAddrs() []string
- func (x *Canal_TiDBIns) GetClusterId() string
- func (x *Canal_TiDBIns) GetCommitTs() int64
- func (x *Canal_TiDBIns) GetDatabases() []*Canal_Database
- func (x *Canal_TiDBIns) GetMonitorPeriod() *durationpb.Duration
- func (x *Canal_TiDBIns) GetName() string
- func (x *Canal_TiDBIns) GetOffset() int64
- func (*Canal_TiDBIns) ProtoMessage()
- func (x *Canal_TiDBIns) ProtoReflect() protoreflect.Message
- func (x *Canal_TiDBIns) Reset()
- func (x *Canal_TiDBIns) String() string
- func (m *Canal_TiDBIns) Validate() error
- type Canal_TiDBInsValidationError
- func (e Canal_TiDBInsValidationError) Cause() error
- func (e Canal_TiDBInsValidationError) Error() string
- func (e Canal_TiDBInsValidationError) ErrorName() string
- func (e Canal_TiDBInsValidationError) Field() string
- func (e Canal_TiDBInsValidationError) Key() bool
- func (e Canal_TiDBInsValidationError) Reason() string
- type Data
- func (*Data) Descriptor() ([]byte, []int)deprecated
- func (x *Data) GetDatabase() *Data_Database
- func (x *Data) GetMigrate() *Data_Migrate
- func (x *Data) GetRedis() *Data_Redis
- func (*Data) ProtoMessage()
- func (x *Data) ProtoReflect() protoreflect.Message
- func (x *Data) Reset()
- func (x *Data) String() string
- func (m *Data) Validate() error
- type DataValidationError
- type Data_Database
- func (*Data_Database) Descriptor() ([]byte, []int)deprecated
- func (x *Data_Database) GetDriver() string
- func (x *Data_Database) GetLogLevel() int32
- func (x *Data_Database) GetSource() string
- func (*Data_Database) ProtoMessage()
- func (x *Data_Database) ProtoReflect() protoreflect.Message
- func (x *Data_Database) Reset()
- func (x *Data_Database) String() string
- func (m *Data_Database) Validate() error
- type Data_DatabaseValidationError
- func (e Data_DatabaseValidationError) Cause() error
- func (e Data_DatabaseValidationError) Error() string
- func (e Data_DatabaseValidationError) ErrorName() string
- func (e Data_DatabaseValidationError) Field() string
- func (e Data_DatabaseValidationError) Key() bool
- func (e Data_DatabaseValidationError) Reason() string
- type Data_Migrate
- func (*Data_Migrate) Descriptor() ([]byte, []int)deprecated
- func (x *Data_Migrate) GetPath() string
- func (*Data_Migrate) ProtoMessage()
- func (x *Data_Migrate) ProtoReflect() protoreflect.Message
- func (x *Data_Migrate) Reset()
- func (x *Data_Migrate) String() string
- func (m *Data_Migrate) Validate() error
- type Data_MigrateValidationError
- func (e Data_MigrateValidationError) Cause() error
- func (e Data_MigrateValidationError) Error() string
- func (e Data_MigrateValidationError) ErrorName() string
- func (e Data_MigrateValidationError) Field() string
- func (e Data_MigrateValidationError) Key() bool
- func (e Data_MigrateValidationError) Reason() string
- type Data_Redis
- func (*Data_Redis) Descriptor() ([]byte, []int)deprecated
- func (x *Data_Redis) GetAddr() string
- func (x *Data_Redis) GetDialTimeout() *durationpb.Duration
- func (x *Data_Redis) GetExpireTimeout() *durationpb.Duration
- func (x *Data_Redis) GetNetwork() string
- func (x *Data_Redis) GetReadTimeout() *durationpb.Duration
- func (x *Data_Redis) GetWriteTimeout() *durationpb.Duration
- func (*Data_Redis) ProtoMessage()
- func (x *Data_Redis) ProtoReflect() protoreflect.Message
- func (x *Data_Redis) Reset()
- func (x *Data_Redis) String() string
- func (m *Data_Redis) Validate() error
- type Data_RedisValidationError
- type Kafka
- func (*Kafka) Descriptor() ([]byte, []int)deprecated
- func (x *Kafka) GetBrokers() string
- func (x *Kafka) GetConsumer() *Kafka_Consumer
- func (x *Kafka) GetEnable() bool
- func (x *Kafka) GetNet() *Kafka_Net
- func (x *Kafka) GetProducer() *Kafka_Producer
- func (*Kafka) ProtoMessage()
- func (x *Kafka) ProtoReflect() protoreflect.Message
- func (x *Kafka) Reset()
- func (x *Kafka) String() string
- func (m *Kafka) Validate() error
- type KafkaValidationError
- type Kafka_Consumer
- func (*Kafka_Consumer) Descriptor() ([]byte, []int)deprecated
- func (x *Kafka_Consumer) GetAcks() int32
- func (x *Kafka_Consumer) GetGroup() string
- func (x *Kafka_Consumer) GetReadTimeout() *durationpb.Duration
- func (x *Kafka_Consumer) GetTopic() string
- func (x *Kafka_Consumer) GetWriteTimeout() *durationpb.Duration
- func (*Kafka_Consumer) ProtoMessage()
- func (x *Kafka_Consumer) ProtoReflect() protoreflect.Message
- func (x *Kafka_Consumer) Reset()
- func (x *Kafka_Consumer) String() string
- func (m *Kafka_Consumer) Validate() error
- type Kafka_ConsumerValidationError
- func (e Kafka_ConsumerValidationError) Cause() error
- func (e Kafka_ConsumerValidationError) Error() string
- func (e Kafka_ConsumerValidationError) ErrorName() string
- func (e Kafka_ConsumerValidationError) Field() string
- func (e Kafka_ConsumerValidationError) Key() bool
- func (e Kafka_ConsumerValidationError) Reason() string
- type Kafka_Net
- func (*Kafka_Net) Descriptor() ([]byte, []int)deprecated
- func (x *Kafka_Net) GetSasl() *Kafka_Net_SASL
- func (x *Kafka_Net) GetTls() *Kafka_Net_TLS
- func (*Kafka_Net) ProtoMessage()
- func (x *Kafka_Net) ProtoReflect() protoreflect.Message
- func (x *Kafka_Net) Reset()
- func (x *Kafka_Net) String() string
- func (m *Kafka_Net) Validate() error
- type Kafka_NetValidationError
- type Kafka_Net_SASL
- func (*Kafka_Net_SASL) Descriptor() ([]byte, []int)deprecated
- func (x *Kafka_Net_SASL) GetEnable() bool
- func (x *Kafka_Net_SASL) GetPassword() string
- func (x *Kafka_Net_SASL) GetUser() string
- func (*Kafka_Net_SASL) ProtoMessage()
- func (x *Kafka_Net_SASL) ProtoReflect() protoreflect.Message
- func (x *Kafka_Net_SASL) Reset()
- func (x *Kafka_Net_SASL) String() string
- func (m *Kafka_Net_SASL) Validate() error
- type Kafka_Net_SASLValidationError
- func (e Kafka_Net_SASLValidationError) Cause() error
- func (e Kafka_Net_SASLValidationError) Error() string
- func (e Kafka_Net_SASLValidationError) ErrorName() string
- func (e Kafka_Net_SASLValidationError) Field() string
- func (e Kafka_Net_SASLValidationError) Key() bool
- func (e Kafka_Net_SASLValidationError) Reason() string
- type Kafka_Net_TLS
- func (*Kafka_Net_TLS) Descriptor() ([]byte, []int)deprecated
- func (x *Kafka_Net_TLS) GetCert() string
- func (x *Kafka_Net_TLS) GetEnable() bool
- func (x *Kafka_Net_TLS) GetJks() string
- func (x *Kafka_Net_TLS) GetKey() string
- func (x *Kafka_Net_TLS) GetPassword() string
- func (x *Kafka_Net_TLS) GetRootCa() string
- func (*Kafka_Net_TLS) ProtoMessage()
- func (x *Kafka_Net_TLS) ProtoReflect() protoreflect.Message
- func (x *Kafka_Net_TLS) Reset()
- func (x *Kafka_Net_TLS) String() string
- func (m *Kafka_Net_TLS) Validate() error
- type Kafka_Net_TLSValidationError
- func (e Kafka_Net_TLSValidationError) Cause() error
- func (e Kafka_Net_TLSValidationError) Error() string
- func (e Kafka_Net_TLSValidationError) ErrorName() string
- func (e Kafka_Net_TLSValidationError) Field() string
- func (e Kafka_Net_TLSValidationError) Key() bool
- func (e Kafka_Net_TLSValidationError) Reason() string
- type Kafka_Producer
- func (*Kafka_Producer) Descriptor() ([]byte, []int)deprecated
- func (x *Kafka_Producer) GetAcks() int32
- func (x *Kafka_Producer) GetGroup() string
- func (x *Kafka_Producer) GetReadTimeout() *durationpb.Duration
- func (x *Kafka_Producer) GetTopic() string
- func (x *Kafka_Producer) GetWriteTimeout() *durationpb.Duration
- func (*Kafka_Producer) ProtoMessage()
- func (x *Kafka_Producer) ProtoReflect() protoreflect.Message
- func (x *Kafka_Producer) Reset()
- func (x *Kafka_Producer) String() string
- func (m *Kafka_Producer) Validate() error
- type Kafka_ProducerValidationError
- func (e Kafka_ProducerValidationError) Cause() error
- func (e Kafka_ProducerValidationError) Error() string
- func (e Kafka_ProducerValidationError) ErrorName() string
- func (e Kafka_ProducerValidationError) Field() string
- func (e Kafka_ProducerValidationError) Key() bool
- func (e Kafka_ProducerValidationError) Reason() string
- type MasterInfo
- func (*MasterInfo) Descriptor() ([]byte, []int)deprecated
- func (x *MasterInfo) GetAddr() string
- func (x *MasterInfo) GetDbName() string
- func (x *MasterInfo) GetPassword() string
- func (x *MasterInfo) GetTimeout() *durationpb.Duration
- func (x *MasterInfo) GetUser() string
- func (*MasterInfo) ProtoMessage()
- func (x *MasterInfo) ProtoReflect() protoreflect.Message
- func (x *MasterInfo) Reset()
- func (x *MasterInfo) String() string
- func (m *MasterInfo) Validate() error
- type MasterInfoValidationError
- type Monitor
- func (*Monitor) Descriptor() ([]byte, []int)deprecated
- func (x *Monitor) GetSecret() string
- func (x *Monitor) GetToken() string
- func (x *Monitor) GetUser() string
- func (*Monitor) ProtoMessage()
- func (x *Monitor) ProtoReflect() protoreflect.Message
- func (x *Monitor) Reset()
- func (x *Monitor) String() string
- func (m *Monitor) Validate() error
- type MonitorValidationError
- type Reg
- type RegValidationError
- type Reg_Consul
- func (*Reg_Consul) Descriptor() ([]byte, []int)deprecated
- func (x *Reg_Consul) GetAddress() string
- func (x *Reg_Consul) GetDialTimeout() *durationpb.Duration
- func (*Reg_Consul) ProtoMessage()
- func (x *Reg_Consul) ProtoReflect() protoreflect.Message
- func (x *Reg_Consul) Reset()
- func (x *Reg_Consul) String() string
- func (m *Reg_Consul) Validate() error
- type Reg_ConsulValidationError
- type Reg_Etcd
- func (*Reg_Etcd) Descriptor() ([]byte, []int)deprecated
- func (x *Reg_Etcd) GetDialTimeout() *durationpb.Duration
- func (x *Reg_Etcd) GetEndpoints() []string
- func (*Reg_Etcd) ProtoMessage()
- func (x *Reg_Etcd) ProtoReflect() protoreflect.Message
- func (x *Reg_Etcd) Reset()
- func (x *Reg_Etcd) String() string
- func (m *Reg_Etcd) Validate() error
- type Reg_EtcdValidationError
- type Server
- func (*Server) Descriptor() ([]byte, []int)deprecated
- func (x *Server) GetGrpc() *Server_GRPC
- func (x *Server) GetHttp() *Server_HTTP
- func (*Server) ProtoMessage()
- func (x *Server) ProtoReflect() protoreflect.Message
- func (x *Server) Reset()
- func (x *Server) String() string
- func (m *Server) Validate() error
- type ServerValidationError
- type Server_GRPC
- func (*Server_GRPC) Descriptor() ([]byte, []int)deprecated
- func (x *Server_GRPC) GetAddress() string
- func (x *Server_GRPC) GetNetwork() string
- func (x *Server_GRPC) GetTimeout() *durationpb.Duration
- func (*Server_GRPC) ProtoMessage()
- func (x *Server_GRPC) ProtoReflect() protoreflect.Message
- func (x *Server_GRPC) Reset()
- func (x *Server_GRPC) String() string
- func (m *Server_GRPC) Validate() error
- type Server_GRPCValidationError
- func (e Server_GRPCValidationError) Cause() error
- func (e Server_GRPCValidationError) Error() string
- func (e Server_GRPCValidationError) ErrorName() string
- func (e Server_GRPCValidationError) Field() string
- func (e Server_GRPCValidationError) Key() bool
- func (e Server_GRPCValidationError) Reason() string
- type Server_HTTP
- func (*Server_HTTP) Descriptor() ([]byte, []int)deprecated
- func (x *Server_HTTP) GetAddress() string
- func (x *Server_HTTP) GetNetwork() string
- func (x *Server_HTTP) GetTimeout() *durationpb.Duration
- func (*Server_HTTP) ProtoMessage()
- func (x *Server_HTTP) ProtoReflect() protoreflect.Message
- func (x *Server_HTTP) Reset()
- func (x *Server_HTTP) String() string
- func (m *Server_HTTP) Validate() error
- type Server_HTTPValidationError
- func (e Server_HTTPValidationError) Cause() error
- func (e Server_HTTPValidationError) Error() string
- func (e Server_HTTPValidationError) ErrorName() string
- func (e Server_HTTPValidationError) Field() string
- func (e Server_HTTPValidationError) Key() bool
- func (e Server_HTTPValidationError) Reason() string
- type Service
- func (*Service) Descriptor() ([]byte, []int)deprecated
- func (x *Service) GetName() string
- func (x *Service) GetVersion() string
- func (*Service) ProtoMessage()
- func (x *Service) ProtoReflect() protoreflect.Message
- func (x *Service) Reset()
- func (x *Service) String() string
- func (m *Service) Validate() error
- type ServiceValidationError
- type Trace
- type TraceValidationError
Constants ¶
This section is empty.
Variables ¶
var File_canal_internal_conf_conf_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Bootstrap ¶
type Bootstrap struct { Service *Service `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` Server *Server `protobuf:"bytes,2,opt,name=server,proto3" json:"server,omitempty"` Data *Data `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` Reg *registry.Conf `protobuf:"bytes,4,opt,name=reg,proto3" json:"reg,omitempty"` Trace *tracing.Conf `protobuf:"bytes,5,opt,name=trace,proto3" json:"trace,omitempty"` Logger *log.Conf `protobuf:"bytes,6,opt,name=logger,proto3" json:"logger,omitempty"` Monitor *Monitor `protobuf:"bytes,7,opt,name=monitor,proto3" json:"monitor,omitempty"` Canal *Canal `protobuf:"bytes,8,opt,name=canal,proto3" json:"canal,omitempty"` // contains filtered or unexported fields }
func (*Bootstrap) Descriptor
deprecated
func (*Bootstrap) GetMonitor ¶
func (*Bootstrap) GetService ¶
func (*Bootstrap) ProtoMessage ¶
func (*Bootstrap) ProtoMessage()
func (*Bootstrap) ProtoReflect ¶
func (x *Bootstrap) ProtoReflect() protoreflect.Message
type BootstrapValidationError ¶
type BootstrapValidationError struct {
// contains filtered or unexported fields
}
BootstrapValidationError is the validation error returned by Bootstrap.Validate if the designated constraints aren't met.
func (BootstrapValidationError) Cause ¶
func (e BootstrapValidationError) Cause() error
Cause function returns cause value.
func (BootstrapValidationError) Error ¶
func (e BootstrapValidationError) Error() string
Error satisfies the builtin error interface
func (BootstrapValidationError) ErrorName ¶
func (e BootstrapValidationError) ErrorName() string
ErrorName returns error name.
func (BootstrapValidationError) Field ¶
func (e BootstrapValidationError) Field() string
Field function returns field value.
func (BootstrapValidationError) Key ¶
func (e BootstrapValidationError) Key() bool
Key function returns key value.
func (BootstrapValidationError) Reason ¶
func (e BootstrapValidationError) Reason() string
Reason function returns reason value.
type Canal ¶
type Canal struct { Instances []*Canal_Ins `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"` HbaseInstances []*Canal_HBaseIns `protobuf:"bytes,2,rep,name=hbaseInstances,proto3" json:"hbaseInstances,omitempty"` TidbInstances []*Canal_TiDBIns `protobuf:"bytes,3,rep,name=tidbInstances,proto3" json:"tidbInstances,omitempty"` // contains filtered or unexported fields }
func (*Canal) Descriptor
deprecated
func (*Canal) GetHbaseInstances ¶
func (x *Canal) GetHbaseInstances() []*Canal_HBaseIns
func (*Canal) GetInstances ¶
func (*Canal) GetTidbInstances ¶
func (x *Canal) GetTidbInstances() []*Canal_TiDBIns
func (*Canal) ProtoMessage ¶
func (*Canal) ProtoMessage()
func (*Canal) ProtoReflect ¶
func (x *Canal) ProtoReflect() protoreflect.Message
type CanalValidationError ¶
type CanalValidationError struct {
// contains filtered or unexported fields
}
CanalValidationError is the validation error returned by Canal.Validate if the designated constraints aren't met.
func (CanalValidationError) Cause ¶
func (e CanalValidationError) Cause() error
Cause function returns cause value.
func (CanalValidationError) Error ¶
func (e CanalValidationError) Error() string
Error satisfies the builtin error interface
func (CanalValidationError) ErrorName ¶
func (e CanalValidationError) ErrorName() string
ErrorName returns error name.
func (CanalValidationError) Field ¶
func (e CanalValidationError) Field() string
Field function returns field value.
func (CanalValidationError) Key ¶
func (e CanalValidationError) Key() bool
Key function returns key value.
func (CanalValidationError) Reason ¶
func (e CanalValidationError) Reason() string
Reason function returns reason value.
type Canal_Addition ¶
type Canal_Addition struct { PrimaryKey []string `protobuf:"bytes,1,rep,name=primaryKey,proto3" json:"primaryKey,omitempty"` OmitField []string `protobuf:"bytes,2,rep,name=omitField,proto3" json:"omitField,omitempty"` // contains filtered or unexported fields }
func (*Canal_Addition) Descriptor
deprecated
func (*Canal_Addition) Descriptor() ([]byte, []int)
Deprecated: Use Canal_Addition.ProtoReflect.Descriptor instead.
func (*Canal_Addition) GetOmitField ¶
func (x *Canal_Addition) GetOmitField() []string
func (*Canal_Addition) GetPrimaryKey ¶
func (x *Canal_Addition) GetPrimaryKey() []string
func (*Canal_Addition) ProtoMessage ¶
func (*Canal_Addition) ProtoMessage()
func (*Canal_Addition) ProtoReflect ¶
func (x *Canal_Addition) ProtoReflect() protoreflect.Message
func (*Canal_Addition) Reset ¶
func (x *Canal_Addition) Reset()
func (*Canal_Addition) String ¶
func (x *Canal_Addition) String() string
func (*Canal_Addition) Validate ¶
func (m *Canal_Addition) Validate() error
Validate checks the field values on Canal_Addition with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type Canal_AdditionValidationError ¶
type Canal_AdditionValidationError struct {
// contains filtered or unexported fields
}
Canal_AdditionValidationError is the validation error returned by Canal_Addition.Validate if the designated constraints aren't met.
func (Canal_AdditionValidationError) Cause ¶
func (e Canal_AdditionValidationError) Cause() error
Cause function returns cause value.
func (Canal_AdditionValidationError) Error ¶
func (e Canal_AdditionValidationError) Error() string
Error satisfies the builtin error interface
func (Canal_AdditionValidationError) ErrorName ¶
func (e Canal_AdditionValidationError) ErrorName() string
ErrorName returns error name.
func (Canal_AdditionValidationError) Field ¶
func (e Canal_AdditionValidationError) Field() string
Field function returns field value.
func (Canal_AdditionValidationError) Key ¶
func (e Canal_AdditionValidationError) Key() bool
Key function returns key value.
func (Canal_AdditionValidationError) Reason ¶
func (e Canal_AdditionValidationError) Reason() string
Reason function returns reason value.
type Canal_CTable ¶
type Canal_CTable struct { PrimaryKey []string `protobuf:"bytes,1,rep,name=primaryKey,proto3" json:"primaryKey,omitempty"` OmitField []string `protobuf:"bytes,2,rep,name=omitField,proto3" json:"omitField,omitempty"` OmitAction []string `protobuf:"bytes,3,rep,name=omitAction,proto3" json:"omitAction,omitempty"` Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` Tables []string `protobuf:"bytes,5,rep,name=tables,proto3" json:"tables,omitempty"` // contains filtered or unexported fields }
func (*Canal_CTable) Descriptor
deprecated
func (*Canal_CTable) Descriptor() ([]byte, []int)
Deprecated: Use Canal_CTable.ProtoReflect.Descriptor instead.
func (*Canal_CTable) GetName ¶
func (x *Canal_CTable) GetName() string
func (*Canal_CTable) GetOmitAction ¶
func (x *Canal_CTable) GetOmitAction() []string
func (*Canal_CTable) GetOmitField ¶
func (x *Canal_CTable) GetOmitField() []string
func (*Canal_CTable) GetPrimaryKey ¶
func (x *Canal_CTable) GetPrimaryKey() []string
func (*Canal_CTable) GetTables ¶
func (x *Canal_CTable) GetTables() []string
func (*Canal_CTable) ProtoMessage ¶
func (*Canal_CTable) ProtoMessage()
func (*Canal_CTable) ProtoReflect ¶
func (x *Canal_CTable) ProtoReflect() protoreflect.Message
func (*Canal_CTable) Reset ¶
func (x *Canal_CTable) Reset()
func (*Canal_CTable) String ¶
func (x *Canal_CTable) String() string
func (*Canal_CTable) Validate ¶
func (m *Canal_CTable) Validate() error
Validate checks the field values on Canal_CTable with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type Canal_CTableValidationError ¶
type Canal_CTableValidationError struct {
// contains filtered or unexported fields
}
Canal_CTableValidationError is the validation error returned by Canal_CTable.Validate if the designated constraints aren't met.
func (Canal_CTableValidationError) Cause ¶
func (e Canal_CTableValidationError) Cause() error
Cause function returns cause value.
func (Canal_CTableValidationError) Error ¶
func (e Canal_CTableValidationError) Error() string
Error satisfies the builtin error interface
func (Canal_CTableValidationError) ErrorName ¶
func (e Canal_CTableValidationError) ErrorName() string
ErrorName returns error name.
func (Canal_CTableValidationError) Field ¶
func (e Canal_CTableValidationError) Field() string
Field function returns field value.
func (Canal_CTableValidationError) Key ¶
func (e Canal_CTableValidationError) Key() bool
Key function returns key value.
func (Canal_CTableValidationError) Reason ¶
func (e Canal_CTableValidationError) Reason() string
Reason function returns reason value.
type Canal_Database ¶
type Canal_Database struct { Schema string `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"` Databus *Kafka `protobuf:"bytes,2,opt,name=databus,proto3" json:"databus,omitempty"` Infoc *Canal_Database_Infoc `protobuf:"bytes,3,opt,name=infoc,proto3" json:"infoc,omitempty"` Ctables []*Canal_CTable `protobuf:"bytes,4,rep,name=ctables,proto3" json:"ctables,omitempty"` TableMap map[string]*Canal_Addition `` /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Canal_Database) CheckTable ¶
func (db *Canal_Database) CheckTable(addr, user, passwd string) (err error)
CheckTable check database tables.
func (*Canal_Database) Descriptor
deprecated
func (*Canal_Database) Descriptor() ([]byte, []int)
Deprecated: Use Canal_Database.ProtoReflect.Descriptor instead.
func (*Canal_Database) GetCtables ¶
func (x *Canal_Database) GetCtables() []*Canal_CTable
func (*Canal_Database) GetDatabus ¶
func (x *Canal_Database) GetDatabus() *Kafka
func (*Canal_Database) GetInfoc ¶
func (x *Canal_Database) GetInfoc() *Canal_Database_Infoc
func (*Canal_Database) GetSchema ¶
func (x *Canal_Database) GetSchema() string
func (*Canal_Database) GetTableMap ¶
func (x *Canal_Database) GetTableMap() map[string]*Canal_Addition
func (*Canal_Database) ProtoMessage ¶
func (*Canal_Database) ProtoMessage()
func (*Canal_Database) ProtoReflect ¶
func (x *Canal_Database) ProtoReflect() protoreflect.Message
func (*Canal_Database) Reset ¶
func (x *Canal_Database) Reset()
func (*Canal_Database) String ¶
func (x *Canal_Database) String() string
func (*Canal_Database) Validate ¶
func (m *Canal_Database) Validate() error
Validate checks the field values on Canal_Database with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type Canal_DatabaseValidationError ¶
type Canal_DatabaseValidationError struct {
// contains filtered or unexported fields
}
Canal_DatabaseValidationError is the validation error returned by Canal_Database.Validate if the designated constraints aren't met.
func (Canal_DatabaseValidationError) Cause ¶
func (e Canal_DatabaseValidationError) Cause() error
Cause function returns cause value.
func (Canal_DatabaseValidationError) Error ¶
func (e Canal_DatabaseValidationError) Error() string
Error satisfies the builtin error interface
func (Canal_DatabaseValidationError) ErrorName ¶
func (e Canal_DatabaseValidationError) ErrorName() string
ErrorName returns error name.
func (Canal_DatabaseValidationError) Field ¶
func (e Canal_DatabaseValidationError) Field() string
Field function returns field value.
func (Canal_DatabaseValidationError) Key ¶
func (e Canal_DatabaseValidationError) Key() bool
Key function returns key value.
func (Canal_DatabaseValidationError) Reason ¶
func (e Canal_DatabaseValidationError) Reason() string
Reason function returns reason value.
type Canal_Database_Infoc ¶
type Canal_Database_Infoc struct { TaskID string `protobuf:"bytes,1,opt,name=taskID,proto3" json:"taskID,omitempty"` // udp or tcp Proto string `protobuf:"bytes,2,opt,name=proto,proto3" json:"proto,omitempty"` Addr string `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"` // reporter ReporterAddr string `protobuf:"bytes,4,opt,name=reporterAddr,proto3" json:"reporterAddr,omitempty"` // contains filtered or unexported fields }
func (*Canal_Database_Infoc) Descriptor
deprecated
func (*Canal_Database_Infoc) Descriptor() ([]byte, []int)
Deprecated: Use Canal_Database_Infoc.ProtoReflect.Descriptor instead.
func (*Canal_Database_Infoc) GetAddr ¶
func (x *Canal_Database_Infoc) GetAddr() string
func (*Canal_Database_Infoc) GetProto ¶
func (x *Canal_Database_Infoc) GetProto() string
func (*Canal_Database_Infoc) GetReporterAddr ¶
func (x *Canal_Database_Infoc) GetReporterAddr() string
func (*Canal_Database_Infoc) GetTaskID ¶
func (x *Canal_Database_Infoc) GetTaskID() string
func (*Canal_Database_Infoc) ProtoMessage ¶
func (*Canal_Database_Infoc) ProtoMessage()
func (*Canal_Database_Infoc) ProtoReflect ¶
func (x *Canal_Database_Infoc) ProtoReflect() protoreflect.Message
func (*Canal_Database_Infoc) Reset ¶
func (x *Canal_Database_Infoc) Reset()
func (*Canal_Database_Infoc) String ¶
func (x *Canal_Database_Infoc) String() string
func (*Canal_Database_Infoc) Validate ¶
func (m *Canal_Database_Infoc) Validate() error
Validate checks the field values on Canal_Database_Infoc with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type Canal_Database_InfocValidationError ¶
type Canal_Database_InfocValidationError struct {
// contains filtered or unexported fields
}
Canal_Database_InfocValidationError is the validation error returned by Canal_Database_Infoc.Validate if the designated constraints aren't met.
func (Canal_Database_InfocValidationError) Cause ¶
func (e Canal_Database_InfocValidationError) Cause() error
Cause function returns cause value.
func (Canal_Database_InfocValidationError) Error ¶
func (e Canal_Database_InfocValidationError) Error() string
Error satisfies the builtin error interface
func (Canal_Database_InfocValidationError) ErrorName ¶
func (e Canal_Database_InfocValidationError) ErrorName() string
ErrorName returns error name.
func (Canal_Database_InfocValidationError) Field ¶
func (e Canal_Database_InfocValidationError) Field() string
Field function returns field value.
func (Canal_Database_InfocValidationError) Key ¶
func (e Canal_Database_InfocValidationError) Key() bool
Key function returns key value.
func (Canal_Database_InfocValidationError) Reason ¶
func (e Canal_Database_InfocValidationError) Reason() string
Reason function returns reason value.
type Canal_HBaseIns ¶
type Canal_HBaseIns struct { Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"` Root string `protobuf:"bytes,2,opt,name=root,proto3" json:"root,omitempty"` Addrs []string `protobuf:"bytes,3,rep,name=addrs,proto3" json:"addrs,omitempty"` MonitorPeriod *durationpb.Duration `protobuf:"bytes,4,opt,name=monitor_period,json=monitorPeriod,proto3" json:"monitor_period,omitempty"` // contains filtered or unexported fields }
func (*Canal_HBaseIns) Descriptor
deprecated
func (*Canal_HBaseIns) Descriptor() ([]byte, []int)
Deprecated: Use Canal_HBaseIns.ProtoReflect.Descriptor instead.
func (*Canal_HBaseIns) GetAddrs ¶
func (x *Canal_HBaseIns) GetAddrs() []string
func (*Canal_HBaseIns) GetCluster ¶
func (x *Canal_HBaseIns) GetCluster() string
func (*Canal_HBaseIns) GetMonitorPeriod ¶
func (x *Canal_HBaseIns) GetMonitorPeriod() *durationpb.Duration
func (*Canal_HBaseIns) GetRoot ¶
func (x *Canal_HBaseIns) GetRoot() string
func (*Canal_HBaseIns) ProtoMessage ¶
func (*Canal_HBaseIns) ProtoMessage()
func (*Canal_HBaseIns) ProtoReflect ¶
func (x *Canal_HBaseIns) ProtoReflect() protoreflect.Message
func (*Canal_HBaseIns) Reset ¶
func (x *Canal_HBaseIns) Reset()
func (*Canal_HBaseIns) String ¶
func (x *Canal_HBaseIns) String() string
func (*Canal_HBaseIns) Validate ¶
func (m *Canal_HBaseIns) Validate() error
Validate checks the field values on Canal_HBaseIns with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type Canal_HBaseInsValidationError ¶
type Canal_HBaseInsValidationError struct {
// contains filtered or unexported fields
}
Canal_HBaseInsValidationError is the validation error returned by Canal_HBaseIns.Validate if the designated constraints aren't met.
func (Canal_HBaseInsValidationError) Cause ¶
func (e Canal_HBaseInsValidationError) Cause() error
Cause function returns cause value.
func (Canal_HBaseInsValidationError) Error ¶
func (e Canal_HBaseInsValidationError) Error() string
Error satisfies the builtin error interface
func (Canal_HBaseInsValidationError) ErrorName ¶
func (e Canal_HBaseInsValidationError) ErrorName() string
ErrorName returns error name.
func (Canal_HBaseInsValidationError) Field ¶
func (e Canal_HBaseInsValidationError) Field() string
Field function returns field value.
func (Canal_HBaseInsValidationError) Key ¶
func (e Canal_HBaseInsValidationError) Key() bool
Key function returns key value.
func (Canal_HBaseInsValidationError) Reason ¶
func (e Canal_HBaseInsValidationError) Reason() string
Reason function returns reason value.
type Canal_Ins ¶
type Canal_Ins struct { Config *Canal_Ins_CanalConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` MonitorPeriod *durationpb.Duration `protobuf:"bytes,2,opt,name=monitor_period,json=monitorPeriod,proto3" json:"monitor_period,omitempty"` MonitorOff bool `protobuf:"varint,3,opt,name=monitor_off,json=monitorOff,proto3" json:"monitor_off,omitempty"` Databases []*Canal_Database `protobuf:"bytes,4,rep,name=databases,proto3" json:"databases,omitempty"` MasterInfo *MasterInfo `protobuf:"bytes,5,opt,name=masterInfo,proto3" json:"masterInfo,omitempty"` // contains filtered or unexported fields }
func (*Canal_Ins) Descriptor
deprecated
func (*Canal_Ins) GetConfig ¶
func (x *Canal_Ins) GetConfig() *Canal_Ins_CanalConfig
func (*Canal_Ins) GetDatabases ¶
func (x *Canal_Ins) GetDatabases() []*Canal_Database
func (*Canal_Ins) GetMasterInfo ¶
func (x *Canal_Ins) GetMasterInfo() *MasterInfo
func (*Canal_Ins) GetMonitorOff ¶
func (*Canal_Ins) GetMonitorPeriod ¶
func (x *Canal_Ins) GetMonitorPeriod() *durationpb.Duration
func (*Canal_Ins) ProtoMessage ¶
func (*Canal_Ins) ProtoMessage()
func (*Canal_Ins) ProtoReflect ¶
func (x *Canal_Ins) ProtoReflect() protoreflect.Message
type Canal_InsValidationError ¶
type Canal_InsValidationError struct {
// contains filtered or unexported fields
}
Canal_InsValidationError is the validation error returned by Canal_Ins.Validate if the designated constraints aren't met.
func (Canal_InsValidationError) Cause ¶
func (e Canal_InsValidationError) Cause() error
Cause function returns cause value.
func (Canal_InsValidationError) Error ¶
func (e Canal_InsValidationError) Error() string
Error satisfies the builtin error interface
func (Canal_InsValidationError) ErrorName ¶
func (e Canal_InsValidationError) ErrorName() string
ErrorName returns error name.
func (Canal_InsValidationError) Field ¶
func (e Canal_InsValidationError) Field() string
Field function returns field value.
func (Canal_InsValidationError) Key ¶
func (e Canal_InsValidationError) Key() bool
Key function returns key value.
func (Canal_InsValidationError) Reason ¶
func (e Canal_InsValidationError) Reason() string
Reason function returns reason value.
type Canal_Ins_CanalConfig ¶
type Canal_Ins_CanalConfig struct { Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"` User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"` Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"` Charset string `protobuf:"bytes,4,opt,name=charset,proto3" json:"charset,omitempty"` ServerID uint32 `protobuf:"varint,5,opt,name=serverID,proto3" json:"serverID,omitempty"` Flavor string `protobuf:"bytes,6,opt,name=flavor,proto3" json:"flavor,omitempty"` HeartbeatPeriod *durationpb.Duration `protobuf:"bytes,7,opt,name=heartbeatPeriod,proto3" json:"heartbeatPeriod,omitempty"` ReadTimeout *durationpb.Duration `protobuf:"bytes,8,opt,name=readTimeout,proto3" json:"readTimeout,omitempty"` UseDecimal bool `protobuf:"varint,9,opt,name=useDecimal,proto3" json:"useDecimal,omitempty"` ParseTime bool `protobuf:"varint,10,opt,name=parseTime,proto3" json:"parseTime,omitempty"` // contains filtered or unexported fields }
func (*Canal_Ins_CanalConfig) Descriptor
deprecated
func (*Canal_Ins_CanalConfig) Descriptor() ([]byte, []int)
Deprecated: Use Canal_Ins_CanalConfig.ProtoReflect.Descriptor instead.
func (*Canal_Ins_CanalConfig) GetAddr ¶
func (x *Canal_Ins_CanalConfig) GetAddr() string
func (*Canal_Ins_CanalConfig) GetCharset ¶
func (x *Canal_Ins_CanalConfig) GetCharset() string
func (*Canal_Ins_CanalConfig) GetFlavor ¶
func (x *Canal_Ins_CanalConfig) GetFlavor() string
func (*Canal_Ins_CanalConfig) GetHeartbeatPeriod ¶
func (x *Canal_Ins_CanalConfig) GetHeartbeatPeriod() *durationpb.Duration
func (*Canal_Ins_CanalConfig) GetParseTime ¶
func (x *Canal_Ins_CanalConfig) GetParseTime() bool
func (*Canal_Ins_CanalConfig) GetPassword ¶
func (x *Canal_Ins_CanalConfig) GetPassword() string
func (*Canal_Ins_CanalConfig) GetReadTimeout ¶
func (x *Canal_Ins_CanalConfig) GetReadTimeout() *durationpb.Duration
func (*Canal_Ins_CanalConfig) GetServerID ¶
func (x *Canal_Ins_CanalConfig) GetServerID() uint32
func (*Canal_Ins_CanalConfig) GetUseDecimal ¶
func (x *Canal_Ins_CanalConfig) GetUseDecimal() bool
func (*Canal_Ins_CanalConfig) GetUser ¶
func (x *Canal_Ins_CanalConfig) GetUser() string
func (*Canal_Ins_CanalConfig) ProtoMessage ¶
func (*Canal_Ins_CanalConfig) ProtoMessage()
func (*Canal_Ins_CanalConfig) ProtoReflect ¶
func (x *Canal_Ins_CanalConfig) ProtoReflect() protoreflect.Message
func (*Canal_Ins_CanalConfig) Reset ¶
func (x *Canal_Ins_CanalConfig) Reset()
func (*Canal_Ins_CanalConfig) String ¶
func (x *Canal_Ins_CanalConfig) String() string
func (*Canal_Ins_CanalConfig) Validate ¶
func (m *Canal_Ins_CanalConfig) Validate() error
Validate checks the field values on Canal_Ins_CanalConfig with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type Canal_Ins_CanalConfigValidationError ¶
type Canal_Ins_CanalConfigValidationError struct {
// contains filtered or unexported fields
}
Canal_Ins_CanalConfigValidationError is the validation error returned by Canal_Ins_CanalConfig.Validate if the designated constraints aren't met.
func (Canal_Ins_CanalConfigValidationError) Cause ¶
func (e Canal_Ins_CanalConfigValidationError) Cause() error
Cause function returns cause value.
func (Canal_Ins_CanalConfigValidationError) Error ¶
func (e Canal_Ins_CanalConfigValidationError) Error() string
Error satisfies the builtin error interface
func (Canal_Ins_CanalConfigValidationError) ErrorName ¶
func (e Canal_Ins_CanalConfigValidationError) ErrorName() string
ErrorName returns error name.
func (Canal_Ins_CanalConfigValidationError) Field ¶
func (e Canal_Ins_CanalConfigValidationError) Field() string
Field function returns field value.
func (Canal_Ins_CanalConfigValidationError) Key ¶
func (e Canal_Ins_CanalConfigValidationError) Key() bool
Key function returns key value.
func (Canal_Ins_CanalConfigValidationError) Reason ¶
func (e Canal_Ins_CanalConfigValidationError) Reason() string
Reason function returns reason value.
type Canal_TiDBIns ¶
type Canal_TiDBIns struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` ClusterId string `protobuf:"bytes,2,opt,name=clusterId,proto3" json:"clusterId,omitempty"` Addrs []string `protobuf:"bytes,3,rep,name=addrs,proto3" json:"addrs,omitempty"` Offset int64 `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"` CommitTs int64 `protobuf:"varint,5,opt,name=commitTs,proto3" json:"commitTs,omitempty"` MonitorPeriod *durationpb.Duration `protobuf:"bytes,6,opt,name=monitor_period,json=monitorPeriod,proto3" json:"monitor_period,omitempty"` Databases []*Canal_Database `protobuf:"bytes,7,rep,name=databases,proto3" json:"databases,omitempty"` // contains filtered or unexported fields }
func (*Canal_TiDBIns) Descriptor
deprecated
func (*Canal_TiDBIns) Descriptor() ([]byte, []int)
Deprecated: Use Canal_TiDBIns.ProtoReflect.Descriptor instead.
func (*Canal_TiDBIns) GetAddrs ¶
func (x *Canal_TiDBIns) GetAddrs() []string
func (*Canal_TiDBIns) GetClusterId ¶
func (x *Canal_TiDBIns) GetClusterId() string
func (*Canal_TiDBIns) GetCommitTs ¶
func (x *Canal_TiDBIns) GetCommitTs() int64
func (*Canal_TiDBIns) GetDatabases ¶
func (x *Canal_TiDBIns) GetDatabases() []*Canal_Database
func (*Canal_TiDBIns) GetMonitorPeriod ¶
func (x *Canal_TiDBIns) GetMonitorPeriod() *durationpb.Duration
func (*Canal_TiDBIns) GetName ¶
func (x *Canal_TiDBIns) GetName() string
func (*Canal_TiDBIns) GetOffset ¶
func (x *Canal_TiDBIns) GetOffset() int64
func (*Canal_TiDBIns) ProtoMessage ¶
func (*Canal_TiDBIns) ProtoMessage()
func (*Canal_TiDBIns) ProtoReflect ¶
func (x *Canal_TiDBIns) ProtoReflect() protoreflect.Message
func (*Canal_TiDBIns) Reset ¶
func (x *Canal_TiDBIns) Reset()
func (*Canal_TiDBIns) String ¶
func (x *Canal_TiDBIns) String() string
func (*Canal_TiDBIns) Validate ¶
func (m *Canal_TiDBIns) Validate() error
Validate checks the field values on Canal_TiDBIns with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type Canal_TiDBInsValidationError ¶
type Canal_TiDBInsValidationError struct {
// contains filtered or unexported fields
}
Canal_TiDBInsValidationError is the validation error returned by Canal_TiDBIns.Validate if the designated constraints aren't met.
func (Canal_TiDBInsValidationError) Cause ¶
func (e Canal_TiDBInsValidationError) Cause() error
Cause function returns cause value.
func (Canal_TiDBInsValidationError) Error ¶
func (e Canal_TiDBInsValidationError) Error() string
Error satisfies the builtin error interface
func (Canal_TiDBInsValidationError) ErrorName ¶
func (e Canal_TiDBInsValidationError) ErrorName() string
ErrorName returns error name.
func (Canal_TiDBInsValidationError) Field ¶
func (e Canal_TiDBInsValidationError) Field() string
Field function returns field value.
func (Canal_TiDBInsValidationError) Key ¶
func (e Canal_TiDBInsValidationError) Key() bool
Key function returns key value.
func (Canal_TiDBInsValidationError) Reason ¶
func (e Canal_TiDBInsValidationError) Reason() string
Reason function returns reason value.
type Data ¶
type Data struct { Database *Data_Database `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` Redis *Data_Redis `protobuf:"bytes,2,opt,name=redis,proto3" json:"redis,omitempty"` Migrate *Data_Migrate `protobuf:"bytes,3,opt,name=migrate,proto3" json:"migrate,omitempty"` // contains filtered or unexported fields }
func (*Data) Descriptor
deprecated
func (*Data) GetDatabase ¶
func (x *Data) GetDatabase() *Data_Database
func (*Data) GetMigrate ¶
func (x *Data) GetMigrate() *Data_Migrate
func (*Data) GetRedis ¶
func (x *Data) GetRedis() *Data_Redis
func (*Data) ProtoMessage ¶
func (*Data) ProtoMessage()
func (*Data) ProtoReflect ¶
func (x *Data) ProtoReflect() protoreflect.Message
type DataValidationError ¶
type DataValidationError struct {
// contains filtered or unexported fields
}
DataValidationError is the validation error returned by Data.Validate if the designated constraints aren't met.
func (DataValidationError) Cause ¶
func (e DataValidationError) Cause() error
Cause function returns cause value.
func (DataValidationError) Error ¶
func (e DataValidationError) Error() string
Error satisfies the builtin error interface
func (DataValidationError) ErrorName ¶
func (e DataValidationError) ErrorName() string
ErrorName returns error name.
func (DataValidationError) Field ¶
func (e DataValidationError) Field() string
Field function returns field value.
func (DataValidationError) Key ¶
func (e DataValidationError) Key() bool
Key function returns key value.
func (DataValidationError) Reason ¶
func (e DataValidationError) Reason() string
Reason function returns reason value.
type Data_Database ¶
type Data_Database struct { Driver string `protobuf:"bytes,1,opt,name=driver,proto3" json:"driver,omitempty"` Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` LogLevel int32 `protobuf:"varint,3,opt,name=logLevel,proto3" json:"logLevel,omitempty"` // contains filtered or unexported fields }
func (*Data_Database) Descriptor
deprecated
func (*Data_Database) Descriptor() ([]byte, []int)
Deprecated: Use Data_Database.ProtoReflect.Descriptor instead.
func (*Data_Database) GetDriver ¶
func (x *Data_Database) GetDriver() string
func (*Data_Database) GetLogLevel ¶
func (x *Data_Database) GetLogLevel() int32
func (*Data_Database) GetSource ¶
func (x *Data_Database) GetSource() string
func (*Data_Database) ProtoMessage ¶
func (*Data_Database) ProtoMessage()
func (*Data_Database) ProtoReflect ¶
func (x *Data_Database) ProtoReflect() protoreflect.Message
func (*Data_Database) Reset ¶
func (x *Data_Database) Reset()
func (*Data_Database) String ¶
func (x *Data_Database) String() string
func (*Data_Database) Validate ¶
func (m *Data_Database) Validate() error
Validate checks the field values on Data_Database with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type Data_DatabaseValidationError ¶
type Data_DatabaseValidationError struct {
// contains filtered or unexported fields
}
Data_DatabaseValidationError is the validation error returned by Data_Database.Validate if the designated constraints aren't met.
func (Data_DatabaseValidationError) Cause ¶
func (e Data_DatabaseValidationError) Cause() error
Cause function returns cause value.
func (Data_DatabaseValidationError) Error ¶
func (e Data_DatabaseValidationError) Error() string
Error satisfies the builtin error interface
func (Data_DatabaseValidationError) ErrorName ¶
func (e Data_DatabaseValidationError) ErrorName() string
ErrorName returns error name.
func (Data_DatabaseValidationError) Field ¶
func (e Data_DatabaseValidationError) Field() string
Field function returns field value.
func (Data_DatabaseValidationError) Key ¶
func (e Data_DatabaseValidationError) Key() bool
Key function returns key value.
func (Data_DatabaseValidationError) Reason ¶
func (e Data_DatabaseValidationError) Reason() string
Reason function returns reason value.
type Data_Migrate ¶
type Data_Migrate struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
func (*Data_Migrate) Descriptor
deprecated
func (*Data_Migrate) Descriptor() ([]byte, []int)
Deprecated: Use Data_Migrate.ProtoReflect.Descriptor instead.
func (*Data_Migrate) GetPath ¶
func (x *Data_Migrate) GetPath() string
func (*Data_Migrate) ProtoMessage ¶
func (*Data_Migrate) ProtoMessage()
func (*Data_Migrate) ProtoReflect ¶
func (x *Data_Migrate) ProtoReflect() protoreflect.Message
func (*Data_Migrate) Reset ¶
func (x *Data_Migrate) Reset()
func (*Data_Migrate) String ¶
func (x *Data_Migrate) String() string
func (*Data_Migrate) Validate ¶
func (m *Data_Migrate) Validate() error
Validate checks the field values on Data_Migrate with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type Data_MigrateValidationError ¶
type Data_MigrateValidationError struct {
// contains filtered or unexported fields
}
Data_MigrateValidationError is the validation error returned by Data_Migrate.Validate if the designated constraints aren't met.
func (Data_MigrateValidationError) Cause ¶
func (e Data_MigrateValidationError) Cause() error
Cause function returns cause value.
func (Data_MigrateValidationError) Error ¶
func (e Data_MigrateValidationError) Error() string
Error satisfies the builtin error interface
func (Data_MigrateValidationError) ErrorName ¶
func (e Data_MigrateValidationError) ErrorName() string
ErrorName returns error name.
func (Data_MigrateValidationError) Field ¶
func (e Data_MigrateValidationError) Field() string
Field function returns field value.
func (Data_MigrateValidationError) Key ¶
func (e Data_MigrateValidationError) Key() bool
Key function returns key value.
func (Data_MigrateValidationError) Reason ¶
func (e Data_MigrateValidationError) Reason() string
Reason function returns reason value.
type Data_Redis ¶
type Data_Redis struct { Network string `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"` Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"` ReadTimeout *durationpb.Duration `protobuf:"bytes,3,opt,name=read_timeout,json=readTimeout,proto3" json:"read_timeout,omitempty"` WriteTimeout *durationpb.Duration `protobuf:"bytes,4,opt,name=write_timeout,json=writeTimeout,proto3" json:"write_timeout,omitempty"` DialTimeout *durationpb.Duration `protobuf:"bytes,5,opt,name=dial_timeout,json=dialTimeout,proto3" json:"dial_timeout,omitempty"` ExpireTimeout *durationpb.Duration `protobuf:"bytes,6,opt,name=expire_timeout,json=expireTimeout,proto3" json:"expire_timeout,omitempty"` // contains filtered or unexported fields }
func (*Data_Redis) Descriptor
deprecated
func (*Data_Redis) Descriptor() ([]byte, []int)
Deprecated: Use Data_Redis.ProtoReflect.Descriptor instead.
func (*Data_Redis) GetAddr ¶
func (x *Data_Redis) GetAddr() string
func (*Data_Redis) GetDialTimeout ¶
func (x *Data_Redis) GetDialTimeout() *durationpb.Duration
func (*Data_Redis) GetExpireTimeout ¶
func (x *Data_Redis) GetExpireTimeout() *durationpb.Duration
func (*Data_Redis) GetNetwork ¶
func (x *Data_Redis) GetNetwork() string
func (*Data_Redis) GetReadTimeout ¶
func (x *Data_Redis) GetReadTimeout() *durationpb.Duration
func (*Data_Redis) GetWriteTimeout ¶
func (x *Data_Redis) GetWriteTimeout() *durationpb.Duration
func (*Data_Redis) ProtoMessage ¶
func (*Data_Redis) ProtoMessage()
func (*Data_Redis) ProtoReflect ¶
func (x *Data_Redis) ProtoReflect() protoreflect.Message
func (*Data_Redis) Reset ¶
func (x *Data_Redis) Reset()
func (*Data_Redis) String ¶
func (x *Data_Redis) String() string
func (*Data_Redis) Validate ¶
func (m *Data_Redis) Validate() error
Validate checks the field values on Data_Redis with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type Data_RedisValidationError ¶
type Data_RedisValidationError struct {
// contains filtered or unexported fields
}
Data_RedisValidationError is the validation error returned by Data_Redis.Validate if the designated constraints aren't met.
func (Data_RedisValidationError) Cause ¶
func (e Data_RedisValidationError) Cause() error
Cause function returns cause value.
func (Data_RedisValidationError) Error ¶
func (e Data_RedisValidationError) Error() string
Error satisfies the builtin error interface
func (Data_RedisValidationError) ErrorName ¶
func (e Data_RedisValidationError) ErrorName() string
ErrorName returns error name.
func (Data_RedisValidationError) Field ¶
func (e Data_RedisValidationError) Field() string
Field function returns field value.
func (Data_RedisValidationError) Key ¶
func (e Data_RedisValidationError) Key() bool
Key function returns key value.
func (Data_RedisValidationError) Reason ¶
func (e Data_RedisValidationError) Reason() string
Reason function returns reason value.
type Kafka ¶
type Kafka struct { Enable bool `protobuf:"varint,1,opt,name=enable,proto3" json:"enable,omitempty"` Brokers string `protobuf:"bytes,2,opt,name=brokers,proto3" json:"brokers,omitempty"` Net *Kafka_Net `protobuf:"bytes,3,opt,name=net,proto3" json:"net,omitempty"` Consumer *Kafka_Consumer `protobuf:"bytes,4,opt,name=consumer,proto3" json:"consumer,omitempty"` Producer *Kafka_Producer `protobuf:"bytes,5,opt,name=producer,proto3" json:"producer,omitempty"` // contains filtered or unexported fields }
func (*Kafka) Descriptor
deprecated
func (*Kafka) GetBrokers ¶
func (*Kafka) GetConsumer ¶
func (x *Kafka) GetConsumer() *Kafka_Consumer
func (*Kafka) GetProducer ¶
func (x *Kafka) GetProducer() *Kafka_Producer
func (*Kafka) ProtoMessage ¶
func (*Kafka) ProtoMessage()
func (*Kafka) ProtoReflect ¶
func (x *Kafka) ProtoReflect() protoreflect.Message
type KafkaValidationError ¶
type KafkaValidationError struct {
// contains filtered or unexported fields
}
KafkaValidationError is the validation error returned by Kafka.Validate if the designated constraints aren't met.
func (KafkaValidationError) Cause ¶
func (e KafkaValidationError) Cause() error
Cause function returns cause value.
func (KafkaValidationError) Error ¶
func (e KafkaValidationError) Error() string
Error satisfies the builtin error interface
func (KafkaValidationError) ErrorName ¶
func (e KafkaValidationError) ErrorName() string
ErrorName returns error name.
func (KafkaValidationError) Field ¶
func (e KafkaValidationError) Field() string
Field function returns field value.
func (KafkaValidationError) Key ¶
func (e KafkaValidationError) Key() bool
Key function returns key value.
func (KafkaValidationError) Reason ¶
func (e KafkaValidationError) Reason() string
Reason function returns reason value.
type Kafka_Consumer ¶
type Kafka_Consumer struct { Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` Group string `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"` ReadTimeout *durationpb.Duration `protobuf:"bytes,4,opt,name=read_timeout,json=readTimeout,proto3" json:"read_timeout,omitempty"` WriteTimeout *durationpb.Duration `protobuf:"bytes,5,opt,name=write_timeout,json=writeTimeout,proto3" json:"write_timeout,omitempty"` Acks int32 `protobuf:"varint,6,opt,name=acks,proto3" json:"acks,omitempty"` // contains filtered or unexported fields }
func (*Kafka_Consumer) Descriptor
deprecated
func (*Kafka_Consumer) Descriptor() ([]byte, []int)
Deprecated: Use Kafka_Consumer.ProtoReflect.Descriptor instead.
func (*Kafka_Consumer) GetAcks ¶
func (x *Kafka_Consumer) GetAcks() int32
func (*Kafka_Consumer) GetGroup ¶
func (x *Kafka_Consumer) GetGroup() string
func (*Kafka_Consumer) GetReadTimeout ¶
func (x *Kafka_Consumer) GetReadTimeout() *durationpb.Duration
func (*Kafka_Consumer) GetTopic ¶
func (x *Kafka_Consumer) GetTopic() string
func (*Kafka_Consumer) GetWriteTimeout ¶
func (x *Kafka_Consumer) GetWriteTimeout() *durationpb.Duration
func (*Kafka_Consumer) ProtoMessage ¶
func (*Kafka_Consumer) ProtoMessage()
func (*Kafka_Consumer) ProtoReflect ¶
func (x *Kafka_Consumer) ProtoReflect() protoreflect.Message
func (*Kafka_Consumer) Reset ¶
func (x *Kafka_Consumer) Reset()
func (*Kafka_Consumer) String ¶
func (x *Kafka_Consumer) String() string
func (*Kafka_Consumer) Validate ¶
func (m *Kafka_Consumer) Validate() error
Validate checks the field values on Kafka_Consumer with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type Kafka_ConsumerValidationError ¶
type Kafka_ConsumerValidationError struct {
// contains filtered or unexported fields
}
Kafka_ConsumerValidationError is the validation error returned by Kafka_Consumer.Validate if the designated constraints aren't met.
func (Kafka_ConsumerValidationError) Cause ¶
func (e Kafka_ConsumerValidationError) Cause() error
Cause function returns cause value.
func (Kafka_ConsumerValidationError) Error ¶
func (e Kafka_ConsumerValidationError) Error() string
Error satisfies the builtin error interface
func (Kafka_ConsumerValidationError) ErrorName ¶
func (e Kafka_ConsumerValidationError) ErrorName() string
ErrorName returns error name.
func (Kafka_ConsumerValidationError) Field ¶
func (e Kafka_ConsumerValidationError) Field() string
Field function returns field value.
func (Kafka_ConsumerValidationError) Key ¶
func (e Kafka_ConsumerValidationError) Key() bool
Key function returns key value.
func (Kafka_ConsumerValidationError) Reason ¶
func (e Kafka_ConsumerValidationError) Reason() string
Reason function returns reason value.
type Kafka_Net ¶
type Kafka_Net struct { Sasl *Kafka_Net_SASL `protobuf:"bytes,1,opt,name=sasl,proto3" json:"sasl,omitempty"` Tls *Kafka_Net_TLS `protobuf:"bytes,2,opt,name=tls,proto3" json:"tls,omitempty"` // contains filtered or unexported fields }
func (*Kafka_Net) Descriptor
deprecated
func (*Kafka_Net) GetSasl ¶
func (x *Kafka_Net) GetSasl() *Kafka_Net_SASL
func (*Kafka_Net) GetTls ¶
func (x *Kafka_Net) GetTls() *Kafka_Net_TLS
func (*Kafka_Net) ProtoMessage ¶
func (*Kafka_Net) ProtoMessage()
func (*Kafka_Net) ProtoReflect ¶
func (x *Kafka_Net) ProtoReflect() protoreflect.Message
type Kafka_NetValidationError ¶
type Kafka_NetValidationError struct {
// contains filtered or unexported fields
}
Kafka_NetValidationError is the validation error returned by Kafka_Net.Validate if the designated constraints aren't met.
func (Kafka_NetValidationError) Cause ¶
func (e Kafka_NetValidationError) Cause() error
Cause function returns cause value.
func (Kafka_NetValidationError) Error ¶
func (e Kafka_NetValidationError) Error() string
Error satisfies the builtin error interface
func (Kafka_NetValidationError) ErrorName ¶
func (e Kafka_NetValidationError) ErrorName() string
ErrorName returns error name.
func (Kafka_NetValidationError) Field ¶
func (e Kafka_NetValidationError) Field() string
Field function returns field value.
func (Kafka_NetValidationError) Key ¶
func (e Kafka_NetValidationError) Key() bool
Key function returns key value.
func (Kafka_NetValidationError) Reason ¶
func (e Kafka_NetValidationError) Reason() string
Reason function returns reason value.
type Kafka_Net_SASL ¶
type Kafka_Net_SASL struct { Enable bool `protobuf:"varint,1,opt,name=enable,proto3" json:"enable,omitempty"` User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"` Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"` // contains filtered or unexported fields }
func (*Kafka_Net_SASL) Descriptor
deprecated
func (*Kafka_Net_SASL) Descriptor() ([]byte, []int)
Deprecated: Use Kafka_Net_SASL.ProtoReflect.Descriptor instead.
func (*Kafka_Net_SASL) GetEnable ¶
func (x *Kafka_Net_SASL) GetEnable() bool
func (*Kafka_Net_SASL) GetPassword ¶
func (x *Kafka_Net_SASL) GetPassword() string
func (*Kafka_Net_SASL) GetUser ¶
func (x *Kafka_Net_SASL) GetUser() string
func (*Kafka_Net_SASL) ProtoMessage ¶
func (*Kafka_Net_SASL) ProtoMessage()
func (*Kafka_Net_SASL) ProtoReflect ¶
func (x *Kafka_Net_SASL) ProtoReflect() protoreflect.Message
func (*Kafka_Net_SASL) Reset ¶
func (x *Kafka_Net_SASL) Reset()
func (*Kafka_Net_SASL) String ¶
func (x *Kafka_Net_SASL) String() string
func (*Kafka_Net_SASL) Validate ¶
func (m *Kafka_Net_SASL) Validate() error
Validate checks the field values on Kafka_Net_SASL with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type Kafka_Net_SASLValidationError ¶
type Kafka_Net_SASLValidationError struct {
// contains filtered or unexported fields
}
Kafka_Net_SASLValidationError is the validation error returned by Kafka_Net_SASL.Validate if the designated constraints aren't met.
func (Kafka_Net_SASLValidationError) Cause ¶
func (e Kafka_Net_SASLValidationError) Cause() error
Cause function returns cause value.
func (Kafka_Net_SASLValidationError) Error ¶
func (e Kafka_Net_SASLValidationError) Error() string
Error satisfies the builtin error interface
func (Kafka_Net_SASLValidationError) ErrorName ¶
func (e Kafka_Net_SASLValidationError) ErrorName() string
ErrorName returns error name.
func (Kafka_Net_SASLValidationError) Field ¶
func (e Kafka_Net_SASLValidationError) Field() string
Field function returns field value.
func (Kafka_Net_SASLValidationError) Key ¶
func (e Kafka_Net_SASLValidationError) Key() bool
Key function returns key value.
func (Kafka_Net_SASLValidationError) Reason ¶
func (e Kafka_Net_SASLValidationError) Reason() string
Reason function returns reason value.
type Kafka_Net_TLS ¶
type Kafka_Net_TLS struct { Enable bool `protobuf:"varint,1,opt,name=enable,proto3" json:"enable,omitempty"` RootCa string `protobuf:"bytes,2,opt,name=rootCa,proto3" json:"rootCa,omitempty"` Jks string `protobuf:"bytes,3,opt,name=jks,proto3" json:"jks,omitempty"` Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"` Cert string `protobuf:"bytes,5,opt,name=cert,proto3" json:"cert,omitempty"` Key string `protobuf:"bytes,6,opt,name=key,proto3" json:"key,omitempty"` // contains filtered or unexported fields }
func (*Kafka_Net_TLS) Descriptor
deprecated
func (*Kafka_Net_TLS) Descriptor() ([]byte, []int)
Deprecated: Use Kafka_Net_TLS.ProtoReflect.Descriptor instead.
func (*Kafka_Net_TLS) GetCert ¶
func (x *Kafka_Net_TLS) GetCert() string
func (*Kafka_Net_TLS) GetEnable ¶
func (x *Kafka_Net_TLS) GetEnable() bool
func (*Kafka_Net_TLS) GetJks ¶
func (x *Kafka_Net_TLS) GetJks() string
func (*Kafka_Net_TLS) GetKey ¶
func (x *Kafka_Net_TLS) GetKey() string
func (*Kafka_Net_TLS) GetPassword ¶
func (x *Kafka_Net_TLS) GetPassword() string
func (*Kafka_Net_TLS) GetRootCa ¶
func (x *Kafka_Net_TLS) GetRootCa() string
func (*Kafka_Net_TLS) ProtoMessage ¶
func (*Kafka_Net_TLS) ProtoMessage()
func (*Kafka_Net_TLS) ProtoReflect ¶
func (x *Kafka_Net_TLS) ProtoReflect() protoreflect.Message
func (*Kafka_Net_TLS) Reset ¶
func (x *Kafka_Net_TLS) Reset()
func (*Kafka_Net_TLS) String ¶
func (x *Kafka_Net_TLS) String() string
func (*Kafka_Net_TLS) Validate ¶
func (m *Kafka_Net_TLS) Validate() error
Validate checks the field values on Kafka_Net_TLS with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type Kafka_Net_TLSValidationError ¶
type Kafka_Net_TLSValidationError struct {
// contains filtered or unexported fields
}
Kafka_Net_TLSValidationError is the validation error returned by Kafka_Net_TLS.Validate if the designated constraints aren't met.
func (Kafka_Net_TLSValidationError) Cause ¶
func (e Kafka_Net_TLSValidationError) Cause() error
Cause function returns cause value.
func (Kafka_Net_TLSValidationError) Error ¶
func (e Kafka_Net_TLSValidationError) Error() string
Error satisfies the builtin error interface
func (Kafka_Net_TLSValidationError) ErrorName ¶
func (e Kafka_Net_TLSValidationError) ErrorName() string
ErrorName returns error name.
func (Kafka_Net_TLSValidationError) Field ¶
func (e Kafka_Net_TLSValidationError) Field() string
Field function returns field value.
func (Kafka_Net_TLSValidationError) Key ¶
func (e Kafka_Net_TLSValidationError) Key() bool
Key function returns key value.
func (Kafka_Net_TLSValidationError) Reason ¶
func (e Kafka_Net_TLSValidationError) Reason() string
Reason function returns reason value.
type Kafka_Producer ¶
type Kafka_Producer struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` Group string `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"` ReadTimeout *durationpb.Duration `protobuf:"bytes,4,opt,name=read_timeout,json=readTimeout,proto3" json:"read_timeout,omitempty"` WriteTimeout *durationpb.Duration `protobuf:"bytes,5,opt,name=write_timeout,json=writeTimeout,proto3" json:"write_timeout,omitempty"` Acks int32 `protobuf:"varint,6,opt,name=acks,proto3" json:"acks,omitempty"` // contains filtered or unexported fields }
func (*Kafka_Producer) Descriptor
deprecated
func (*Kafka_Producer) Descriptor() ([]byte, []int)
Deprecated: Use Kafka_Producer.ProtoReflect.Descriptor instead.
func (*Kafka_Producer) GetAcks ¶
func (x *Kafka_Producer) GetAcks() int32
func (*Kafka_Producer) GetGroup ¶
func (x *Kafka_Producer) GetGroup() string
func (*Kafka_Producer) GetReadTimeout ¶
func (x *Kafka_Producer) GetReadTimeout() *durationpb.Duration
func (*Kafka_Producer) GetTopic ¶
func (x *Kafka_Producer) GetTopic() string
func (*Kafka_Producer) GetWriteTimeout ¶
func (x *Kafka_Producer) GetWriteTimeout() *durationpb.Duration
func (*Kafka_Producer) ProtoMessage ¶
func (*Kafka_Producer) ProtoMessage()
func (*Kafka_Producer) ProtoReflect ¶
func (x *Kafka_Producer) ProtoReflect() protoreflect.Message
func (*Kafka_Producer) Reset ¶
func (x *Kafka_Producer) Reset()
func (*Kafka_Producer) String ¶
func (x *Kafka_Producer) String() string
func (*Kafka_Producer) Validate ¶
func (m *Kafka_Producer) Validate() error
Validate checks the field values on Kafka_Producer with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type Kafka_ProducerValidationError ¶
type Kafka_ProducerValidationError struct {
// contains filtered or unexported fields
}
Kafka_ProducerValidationError is the validation error returned by Kafka_Producer.Validate if the designated constraints aren't met.
func (Kafka_ProducerValidationError) Cause ¶
func (e Kafka_ProducerValidationError) Cause() error
Cause function returns cause value.
func (Kafka_ProducerValidationError) Error ¶
func (e Kafka_ProducerValidationError) Error() string
Error satisfies the builtin error interface
func (Kafka_ProducerValidationError) ErrorName ¶
func (e Kafka_ProducerValidationError) ErrorName() string
ErrorName returns error name.
func (Kafka_ProducerValidationError) Field ¶
func (e Kafka_ProducerValidationError) Field() string
Field function returns field value.
func (Kafka_ProducerValidationError) Key ¶
func (e Kafka_ProducerValidationError) Key() bool
Key function returns key value.
func (Kafka_ProducerValidationError) Reason ¶
func (e Kafka_ProducerValidationError) Reason() string
Reason function returns reason value.
type MasterInfo ¶
type MasterInfo struct { Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"` DbName string `protobuf:"bytes,2,opt,name=dbName,proto3" json:"dbName,omitempty"` User string `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"` Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"` Timeout *durationpb.Duration `protobuf:"bytes,5,opt,name=timeout,proto3" json:"timeout,omitempty"` // contains filtered or unexported fields }
func (*MasterInfo) Descriptor
deprecated
func (*MasterInfo) Descriptor() ([]byte, []int)
Deprecated: Use MasterInfo.ProtoReflect.Descriptor instead.
func (*MasterInfo) GetAddr ¶
func (x *MasterInfo) GetAddr() string
func (*MasterInfo) GetDbName ¶
func (x *MasterInfo) GetDbName() string
func (*MasterInfo) GetPassword ¶
func (x *MasterInfo) GetPassword() string
func (*MasterInfo) GetTimeout ¶
func (x *MasterInfo) GetTimeout() *durationpb.Duration
func (*MasterInfo) GetUser ¶
func (x *MasterInfo) GetUser() string
func (*MasterInfo) ProtoMessage ¶
func (*MasterInfo) ProtoMessage()
func (*MasterInfo) ProtoReflect ¶
func (x *MasterInfo) ProtoReflect() protoreflect.Message
func (*MasterInfo) Reset ¶
func (x *MasterInfo) Reset()
func (*MasterInfo) String ¶
func (x *MasterInfo) String() string
func (*MasterInfo) Validate ¶
func (m *MasterInfo) Validate() error
Validate checks the field values on MasterInfo with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type MasterInfoValidationError ¶
type MasterInfoValidationError struct {
// contains filtered or unexported fields
}
MasterInfoValidationError is the validation error returned by MasterInfo.Validate if the designated constraints aren't met.
func (MasterInfoValidationError) Cause ¶
func (e MasterInfoValidationError) Cause() error
Cause function returns cause value.
func (MasterInfoValidationError) Error ¶
func (e MasterInfoValidationError) Error() string
Error satisfies the builtin error interface
func (MasterInfoValidationError) ErrorName ¶
func (e MasterInfoValidationError) ErrorName() string
ErrorName returns error name.
func (MasterInfoValidationError) Field ¶
func (e MasterInfoValidationError) Field() string
Field function returns field value.
func (MasterInfoValidationError) Key ¶
func (e MasterInfoValidationError) Key() bool
Key function returns key value.
func (MasterInfoValidationError) Reason ¶
func (e MasterInfoValidationError) Reason() string
Reason function returns reason value.
type Monitor ¶
type Monitor struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"` Secret string `protobuf:"bytes,3,opt,name=secret,proto3" json:"secret,omitempty"` // contains filtered or unexported fields }
func (*Monitor) Descriptor
deprecated
func (*Monitor) ProtoMessage ¶
func (*Monitor) ProtoMessage()
func (*Monitor) ProtoReflect ¶
func (x *Monitor) ProtoReflect() protoreflect.Message
type MonitorValidationError ¶
type MonitorValidationError struct {
// contains filtered or unexported fields
}
MonitorValidationError is the validation error returned by Monitor.Validate if the designated constraints aren't met.
func (MonitorValidationError) Cause ¶
func (e MonitorValidationError) Cause() error
Cause function returns cause value.
func (MonitorValidationError) Error ¶
func (e MonitorValidationError) Error() string
Error satisfies the builtin error interface
func (MonitorValidationError) ErrorName ¶
func (e MonitorValidationError) ErrorName() string
ErrorName returns error name.
func (MonitorValidationError) Field ¶
func (e MonitorValidationError) Field() string
Field function returns field value.
func (MonitorValidationError) Key ¶
func (e MonitorValidationError) Key() bool
Key function returns key value.
func (MonitorValidationError) Reason ¶
func (e MonitorValidationError) Reason() string
Reason function returns reason value.
type Reg ¶
type Reg struct { Etcd *Reg_Etcd `protobuf:"bytes,1,opt,name=etcd,proto3" json:"etcd,omitempty"` Consul *Reg_Consul `protobuf:"bytes,2,opt,name=consul,proto3" json:"consul,omitempty"` // contains filtered or unexported fields }
func (*Reg) Descriptor
deprecated
func (*Reg) GetConsul ¶
func (x *Reg) GetConsul() *Reg_Consul
func (*Reg) ProtoMessage ¶
func (*Reg) ProtoMessage()
func (*Reg) ProtoReflect ¶
func (x *Reg) ProtoReflect() protoreflect.Message
type RegValidationError ¶
type RegValidationError struct {
// contains filtered or unexported fields
}
RegValidationError is the validation error returned by Reg.Validate if the designated constraints aren't met.
func (RegValidationError) Cause ¶
func (e RegValidationError) Cause() error
Cause function returns cause value.
func (RegValidationError) Error ¶
func (e RegValidationError) Error() string
Error satisfies the builtin error interface
func (RegValidationError) ErrorName ¶
func (e RegValidationError) ErrorName() string
ErrorName returns error name.
func (RegValidationError) Field ¶
func (e RegValidationError) Field() string
Field function returns field value.
func (RegValidationError) Key ¶
func (e RegValidationError) Key() bool
Key function returns key value.
func (RegValidationError) Reason ¶
func (e RegValidationError) Reason() string
Reason function returns reason value.
type Reg_Consul ¶
type Reg_Consul struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` DialTimeout *durationpb.Duration `protobuf:"bytes,2,opt,name=dialTimeout,proto3" json:"dialTimeout,omitempty"` // contains filtered or unexported fields }
func (*Reg_Consul) Descriptor
deprecated
func (*Reg_Consul) Descriptor() ([]byte, []int)
Deprecated: Use Reg_Consul.ProtoReflect.Descriptor instead.
func (*Reg_Consul) GetAddress ¶
func (x *Reg_Consul) GetAddress() string
func (*Reg_Consul) GetDialTimeout ¶
func (x *Reg_Consul) GetDialTimeout() *durationpb.Duration
func (*Reg_Consul) ProtoMessage ¶
func (*Reg_Consul) ProtoMessage()
func (*Reg_Consul) ProtoReflect ¶
func (x *Reg_Consul) ProtoReflect() protoreflect.Message
func (*Reg_Consul) Reset ¶
func (x *Reg_Consul) Reset()
func (*Reg_Consul) String ¶
func (x *Reg_Consul) String() string
func (*Reg_Consul) Validate ¶
func (m *Reg_Consul) Validate() error
Validate checks the field values on Reg_Consul with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type Reg_ConsulValidationError ¶
type Reg_ConsulValidationError struct {
// contains filtered or unexported fields
}
Reg_ConsulValidationError is the validation error returned by Reg_Consul.Validate if the designated constraints aren't met.
func (Reg_ConsulValidationError) Cause ¶
func (e Reg_ConsulValidationError) Cause() error
Cause function returns cause value.
func (Reg_ConsulValidationError) Error ¶
func (e Reg_ConsulValidationError) Error() string
Error satisfies the builtin error interface
func (Reg_ConsulValidationError) ErrorName ¶
func (e Reg_ConsulValidationError) ErrorName() string
ErrorName returns error name.
func (Reg_ConsulValidationError) Field ¶
func (e Reg_ConsulValidationError) Field() string
Field function returns field value.
func (Reg_ConsulValidationError) Key ¶
func (e Reg_ConsulValidationError) Key() bool
Key function returns key value.
func (Reg_ConsulValidationError) Reason ¶
func (e Reg_ConsulValidationError) Reason() string
Reason function returns reason value.
type Reg_Etcd ¶
type Reg_Etcd struct { Endpoints []string `protobuf:"bytes,1,rep,name=endpoints,proto3" json:"endpoints,omitempty"` DialTimeout *durationpb.Duration `protobuf:"bytes,2,opt,name=dialTimeout,proto3" json:"dialTimeout,omitempty"` // contains filtered or unexported fields }
func (*Reg_Etcd) Descriptor
deprecated
func (*Reg_Etcd) GetDialTimeout ¶
func (x *Reg_Etcd) GetDialTimeout() *durationpb.Duration
func (*Reg_Etcd) GetEndpoints ¶
func (*Reg_Etcd) ProtoMessage ¶
func (*Reg_Etcd) ProtoMessage()
func (*Reg_Etcd) ProtoReflect ¶
func (x *Reg_Etcd) ProtoReflect() protoreflect.Message
type Reg_EtcdValidationError ¶
type Reg_EtcdValidationError struct {
// contains filtered or unexported fields
}
Reg_EtcdValidationError is the validation error returned by Reg_Etcd.Validate if the designated constraints aren't met.
func (Reg_EtcdValidationError) Cause ¶
func (e Reg_EtcdValidationError) Cause() error
Cause function returns cause value.
func (Reg_EtcdValidationError) Error ¶
func (e Reg_EtcdValidationError) Error() string
Error satisfies the builtin error interface
func (Reg_EtcdValidationError) ErrorName ¶
func (e Reg_EtcdValidationError) ErrorName() string
ErrorName returns error name.
func (Reg_EtcdValidationError) Field ¶
func (e Reg_EtcdValidationError) Field() string
Field function returns field value.
func (Reg_EtcdValidationError) Key ¶
func (e Reg_EtcdValidationError) Key() bool
Key function returns key value.
func (Reg_EtcdValidationError) Reason ¶
func (e Reg_EtcdValidationError) Reason() string
Reason function returns reason value.
type Server ¶
type Server struct { Http *Server_HTTP `protobuf:"bytes,1,opt,name=http,proto3" json:"http,omitempty"` Grpc *Server_GRPC `protobuf:"bytes,2,opt,name=grpc,proto3" json:"grpc,omitempty"` // contains filtered or unexported fields }
func (*Server) Descriptor
deprecated
func (*Server) GetGrpc ¶
func (x *Server) GetGrpc() *Server_GRPC
func (*Server) GetHttp ¶
func (x *Server) GetHttp() *Server_HTTP
func (*Server) ProtoMessage ¶
func (*Server) ProtoMessage()
func (*Server) ProtoReflect ¶
func (x *Server) ProtoReflect() protoreflect.Message
type ServerValidationError ¶
type ServerValidationError struct {
// contains filtered or unexported fields
}
ServerValidationError is the validation error returned by Server.Validate if the designated constraints aren't met.
func (ServerValidationError) Cause ¶
func (e ServerValidationError) Cause() error
Cause function returns cause value.
func (ServerValidationError) Error ¶
func (e ServerValidationError) Error() string
Error satisfies the builtin error interface
func (ServerValidationError) ErrorName ¶
func (e ServerValidationError) ErrorName() string
ErrorName returns error name.
func (ServerValidationError) Field ¶
func (e ServerValidationError) Field() string
Field function returns field value.
func (ServerValidationError) Key ¶
func (e ServerValidationError) Key() bool
Key function returns key value.
func (ServerValidationError) Reason ¶
func (e ServerValidationError) Reason() string
Reason function returns reason value.
type Server_GRPC ¶
type Server_GRPC struct { Network string `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` Timeout *durationpb.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"` // contains filtered or unexported fields }
func (*Server_GRPC) Descriptor
deprecated
func (*Server_GRPC) Descriptor() ([]byte, []int)
Deprecated: Use Server_GRPC.ProtoReflect.Descriptor instead.
func (*Server_GRPC) GetAddress ¶
func (x *Server_GRPC) GetAddress() string
func (*Server_GRPC) GetNetwork ¶
func (x *Server_GRPC) GetNetwork() string
func (*Server_GRPC) GetTimeout ¶
func (x *Server_GRPC) GetTimeout() *durationpb.Duration
func (*Server_GRPC) ProtoMessage ¶
func (*Server_GRPC) ProtoMessage()
func (*Server_GRPC) ProtoReflect ¶
func (x *Server_GRPC) ProtoReflect() protoreflect.Message
func (*Server_GRPC) Reset ¶
func (x *Server_GRPC) Reset()
func (*Server_GRPC) String ¶
func (x *Server_GRPC) String() string
func (*Server_GRPC) Validate ¶
func (m *Server_GRPC) Validate() error
Validate checks the field values on Server_GRPC with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type Server_GRPCValidationError ¶
type Server_GRPCValidationError struct {
// contains filtered or unexported fields
}
Server_GRPCValidationError is the validation error returned by Server_GRPC.Validate if the designated constraints aren't met.
func (Server_GRPCValidationError) Cause ¶
func (e Server_GRPCValidationError) Cause() error
Cause function returns cause value.
func (Server_GRPCValidationError) Error ¶
func (e Server_GRPCValidationError) Error() string
Error satisfies the builtin error interface
func (Server_GRPCValidationError) ErrorName ¶
func (e Server_GRPCValidationError) ErrorName() string
ErrorName returns error name.
func (Server_GRPCValidationError) Field ¶
func (e Server_GRPCValidationError) Field() string
Field function returns field value.
func (Server_GRPCValidationError) Key ¶
func (e Server_GRPCValidationError) Key() bool
Key function returns key value.
func (Server_GRPCValidationError) Reason ¶
func (e Server_GRPCValidationError) Reason() string
Reason function returns reason value.
type Server_HTTP ¶
type Server_HTTP struct { Network string `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` Timeout *durationpb.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"` // contains filtered or unexported fields }
func (*Server_HTTP) Descriptor
deprecated
func (*Server_HTTP) Descriptor() ([]byte, []int)
Deprecated: Use Server_HTTP.ProtoReflect.Descriptor instead.
func (*Server_HTTP) GetAddress ¶
func (x *Server_HTTP) GetAddress() string
func (*Server_HTTP) GetNetwork ¶
func (x *Server_HTTP) GetNetwork() string
func (*Server_HTTP) GetTimeout ¶
func (x *Server_HTTP) GetTimeout() *durationpb.Duration
func (*Server_HTTP) ProtoMessage ¶
func (*Server_HTTP) ProtoMessage()
func (*Server_HTTP) ProtoReflect ¶
func (x *Server_HTTP) ProtoReflect() protoreflect.Message
func (*Server_HTTP) Reset ¶
func (x *Server_HTTP) Reset()
func (*Server_HTTP) String ¶
func (x *Server_HTTP) String() string
func (*Server_HTTP) Validate ¶
func (m *Server_HTTP) Validate() error
Validate checks the field values on Server_HTTP with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type Server_HTTPValidationError ¶
type Server_HTTPValidationError struct {
// contains filtered or unexported fields
}
Server_HTTPValidationError is the validation error returned by Server_HTTP.Validate if the designated constraints aren't met.
func (Server_HTTPValidationError) Cause ¶
func (e Server_HTTPValidationError) Cause() error
Cause function returns cause value.
func (Server_HTTPValidationError) Error ¶
func (e Server_HTTPValidationError) Error() string
Error satisfies the builtin error interface
func (Server_HTTPValidationError) ErrorName ¶
func (e Server_HTTPValidationError) ErrorName() string
ErrorName returns error name.
func (Server_HTTPValidationError) Field ¶
func (e Server_HTTPValidationError) Field() string
Field function returns field value.
func (Server_HTTPValidationError) Key ¶
func (e Server_HTTPValidationError) Key() bool
Key function returns key value.
func (Server_HTTPValidationError) Reason ¶
func (e Server_HTTPValidationError) Reason() string
Reason function returns reason value.
type Service ¶
type Service struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*Service) Descriptor
deprecated
func (*Service) GetVersion ¶
func (*Service) ProtoMessage ¶
func (*Service) ProtoMessage()
func (*Service) ProtoReflect ¶
func (x *Service) ProtoReflect() protoreflect.Message
type ServiceValidationError ¶
type ServiceValidationError struct {
// contains filtered or unexported fields
}
ServiceValidationError is the validation error returned by Service.Validate if the designated constraints aren't met.
func (ServiceValidationError) Cause ¶
func (e ServiceValidationError) Cause() error
Cause function returns cause value.
func (ServiceValidationError) Error ¶
func (e ServiceValidationError) Error() string
Error satisfies the builtin error interface
func (ServiceValidationError) ErrorName ¶
func (e ServiceValidationError) ErrorName() string
ErrorName returns error name.
func (ServiceValidationError) Field ¶
func (e ServiceValidationError) Field() string
Field function returns field value.
func (ServiceValidationError) Key ¶
func (e ServiceValidationError) Key() bool
Key function returns key value.
func (ServiceValidationError) Reason ¶
func (e ServiceValidationError) Reason() string
Reason function returns reason value.
type Trace ¶
type Trace struct { Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` // contains filtered or unexported fields }
func (*Trace) Descriptor
deprecated
func (*Trace) GetEndpoint ¶
func (*Trace) ProtoMessage ¶
func (*Trace) ProtoMessage()
func (*Trace) ProtoReflect ¶
func (x *Trace) ProtoReflect() protoreflect.Message
type TraceValidationError ¶
type TraceValidationError struct {
// contains filtered or unexported fields
}
TraceValidationError is the validation error returned by Trace.Validate if the designated constraints aren't met.
func (TraceValidationError) Cause ¶
func (e TraceValidationError) Cause() error
Cause function returns cause value.
func (TraceValidationError) Error ¶
func (e TraceValidationError) Error() string
Error satisfies the builtin error interface
func (TraceValidationError) ErrorName ¶
func (e TraceValidationError) ErrorName() string
ErrorName returns error name.
func (TraceValidationError) Field ¶
func (e TraceValidationError) Field() string
Field function returns field value.
func (TraceValidationError) Key ¶
func (e TraceValidationError) Key() bool
Key function returns key value.
func (TraceValidationError) Reason ¶
func (e TraceValidationError) Reason() string
Reason function returns reason value.