conf

package
v0.0.0-...-c9f961e Latest Latest
Warning

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

 Go to latest Published: Oct 16, 2022 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use Bootstrap.ProtoReflect.Descriptor instead.

func (*Bootstrap) GetCanal 

func (x *Bootstrap) GetCanal() *Canal

func (*Bootstrap) GetData 

func (x *Bootstrap) GetData() *Data

func (*Bootstrap) GetLogger 

func (x *Bootstrap) GetLogger() *log.Conf

func (*Bootstrap) GetMonitor 

func (x *Bootstrap) GetMonitor() *Monitor

func (*Bootstrap) GetReg 

func (x *Bootstrap) GetReg() *registry.Conf

func (*Bootstrap) GetServer 

func (x *Bootstrap) GetServer() *Server

func (*Bootstrap) GetService 

func (x *Bootstrap) GetService() *Service

func (*Bootstrap) GetTrace 

func (x *Bootstrap) GetTrace() *tracing.Conf

func (*Bootstrap) ProtoMessage 

func (*Bootstrap) ProtoMessage()

func (*Bootstrap) ProtoReflect 

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

func (*Bootstrap) Reset 

func (x *Bootstrap) Reset()

func (*Bootstrap) String 

func (x *Bootstrap) String() string

func (*Bootstrap) Validate 

func (m *Bootstrap) Validate() error

Validate checks the field values on Bootstrap with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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) Descriptor() ([]byte, []int)

Deprecated: Use Canal.ProtoReflect.Descriptor instead.

func (*Canal) GetHbaseInstances 

func (x *Canal) GetHbaseInstances() []*Canal_HBaseIns

func (*Canal) GetInstances 

func (x *Canal) GetInstances() []*Canal_Ins

func (*Canal) GetTidbInstances 

func (x *Canal) GetTidbInstances() []*Canal_TiDBIns

func (*Canal) ProtoMessage 

func (*Canal) ProtoMessage()

func (*Canal) ProtoReflect 

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

func (*Canal) Reset 

func (x *Canal) Reset()

func (*Canal) String 

func (x *Canal) String() string

func (*Canal) Validate 

func (m *Canal) Validate() error

Validate checks the field values on Canal with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type CanalEv 

type CanalEv struct {
	InsCh <-chan *Canal_Ins
}

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) Descriptor() ([]byte, []int)

Deprecated: Use Canal_Ins.ProtoReflect.Descriptor instead.

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 (x *Canal_Ins) GetMonitorOff() bool

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

func (*Canal_Ins) Reset 

func (x *Canal_Ins) Reset()

func (*Canal_Ins) String 

func (x *Canal_Ins) String() string

func (*Canal_Ins) Validate 

func (m *Canal_Ins) Validate() error

Validate checks the field values on Canal_Ins with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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) Descriptor() ([]byte, []int)

Deprecated: Use Data.ProtoReflect.Descriptor instead.

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

func (*Data) Reset 

func (x *Data) Reset()

func (*Data) String 

func (x *Data) String() string

func (*Data) Validate 

func (m *Data) Validate() error

Validate checks the field values on Data with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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) Descriptor() ([]byte, []int)

Deprecated: Use Kafka.ProtoReflect.Descriptor instead.

func (*Kafka) GetBrokers 

func (x *Kafka) GetBrokers() string

func (*Kafka) GetConsumer 

func (x *Kafka) GetConsumer() *Kafka_Consumer

func (*Kafka) GetEnable 

func (x *Kafka) GetEnable() bool

func (*Kafka) GetNet 

func (x *Kafka) GetNet() *Kafka_Net

func (*Kafka) GetProducer 

func (x *Kafka) GetProducer() *Kafka_Producer

func (*Kafka) ProtoMessage 

func (*Kafka) ProtoMessage()

func (*Kafka) ProtoReflect 

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

func (*Kafka) Reset 

func (x *Kafka) Reset()

func (*Kafka) String 

func (x *Kafka) String() string

func (*Kafka) Validate 

func (m *Kafka) Validate() error

Validate checks the field values on Kafka with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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) Descriptor() ([]byte, []int)

Deprecated: Use Kafka_Net.ProtoReflect.Descriptor instead.

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

func (*Kafka_Net) Reset 

func (x *Kafka_Net) Reset()

func (*Kafka_Net) String 

func (x *Kafka_Net) String() string

func (*Kafka_Net) Validate 

func (m *Kafka_Net) Validate() error

Validate checks the field values on Kafka_Net with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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) Descriptor() ([]byte, []int)

Deprecated: Use Monitor.ProtoReflect.Descriptor instead.

func (*Monitor) GetSecret 

func (x *Monitor) GetSecret() string

func (*Monitor) GetToken 

func (x *Monitor) GetToken() string

func (*Monitor) GetUser 

func (x *Monitor) GetUser() string

func (*Monitor) ProtoMessage 

func (*Monitor) ProtoMessage()

func (*Monitor) ProtoReflect 

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

func (*Monitor) Reset 

func (x *Monitor) Reset()

func (*Monitor) String 

func (x *Monitor) String() string

func (*Monitor) Validate 

func (m *Monitor) Validate() error

Validate checks the field values on Monitor with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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) Descriptor() ([]byte, []int)

Deprecated: Use Reg.ProtoReflect.Descriptor instead.

func (*Reg) GetConsul 

func (x *Reg) GetConsul() *Reg_Consul

func (*Reg) GetEtcd 

func (x *Reg) GetEtcd() *Reg_Etcd

func (*Reg) ProtoMessage 

func (*Reg) ProtoMessage()

func (*Reg) ProtoReflect 

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

func (*Reg) Reset 

func (x *Reg) Reset()

func (*Reg) String 

func (x *Reg) String() string

func (*Reg) Validate 

func (m *Reg) Validate() error

Validate checks the field values on Reg with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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) Descriptor() ([]byte, []int)

Deprecated: Use Reg_Etcd.ProtoReflect.Descriptor instead.

func (*Reg_Etcd) GetDialTimeout 

func (x *Reg_Etcd) GetDialTimeout() *durationpb.Duration

func (*Reg_Etcd) GetEndpoints 

func (x *Reg_Etcd) GetEndpoints() []string

func (*Reg_Etcd) ProtoMessage 

func (*Reg_Etcd) ProtoMessage()

func (*Reg_Etcd) ProtoReflect 

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

func (*Reg_Etcd) Reset 

func (x *Reg_Etcd) Reset()

func (*Reg_Etcd) String 

func (x *Reg_Etcd) String() string

func (*Reg_Etcd) Validate 

func (m *Reg_Etcd) Validate() error

Validate checks the field values on Reg_Etcd with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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) Descriptor() ([]byte, []int)

Deprecated: Use Server.ProtoReflect.Descriptor instead.

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

func (*Server) Reset 

func (x *Server) Reset()

func (*Server) String 

func (x *Server) String() string

func (*Server) Validate 

func (m *Server) Validate() error

Validate checks the field values on Server with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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) Descriptor() ([]byte, []int)

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetName 

func (x *Service) GetName() string

func (*Service) GetVersion 

func (x *Service) GetVersion() string

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) ProtoReflect 

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

func (*Service) Reset 

func (x *Service) Reset()

func (*Service) String 

func (x *Service) String() string

func (*Service) Validate 

func (m *Service) Validate() error

Validate checks the field values on Service with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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) Descriptor() ([]byte, []int)

Deprecated: Use Trace.ProtoReflect.Descriptor instead.

func (*Trace) GetEndpoint 

func (x *Trace) GetEndpoint() string

func (*Trace) ProtoMessage 

func (*Trace) ProtoMessage()

func (*Trace) ProtoReflect 

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

func (*Trace) Reset 

func (x *Trace) Reset()

func (*Trace) String 

func (x *Trace) String() string

func (*Trace) Validate 

func (m *Trace) Validate() error

Validate checks the field values on Trace with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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.

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.