hc

package
v0.0.0-...-09abd0a Latest Latest
Warning

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

 Go to latest Published: Jan 3, 2020 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthHc = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowHc   = fmt.Errorf("proto: integer overflow")
)
View Source 
var ATCPCheckerJSONMarshaler = new(jsonpb.Marshaler)

ATCPCheckerJSONMarshaler describes the default jsonpb.Marshaler used by all instances of ATCPChecker. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var ATCPCheckerJSONUnmarshaler = new(jsonpb.Unmarshaler)

ATCPCheckerJSONUnmarshaler describes the default jsonpb.Unmarshaler used by all instances of ATCPChecker. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var ATCPChecker_ActionJSONMarshaler = new(jsonpb.Marshaler)

ATCPChecker_ActionJSONMarshaler describes the default jsonpb.Marshaler used by all instances of ATCPChecker_Action. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var ATCPChecker_ActionJSONUnmarshaler = new(jsonpb.Unmarshaler)

ATCPChecker_ActionJSONUnmarshaler describes the default jsonpb.Unmarshaler used by all instances of ATCPChecker_Action. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var HealthCheckJSONMarshaler = new(jsonpb.Marshaler)

HealthCheckJSONMarshaler describes the default jsonpb.Marshaler used by all instances of HealthCheck. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var HealthCheckJSONUnmarshaler = new(jsonpb.Unmarshaler)

HealthCheckJSONUnmarshaler describes the default jsonpb.Unmarshaler used by all instances of HealthCheck. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var MySQLCheckerJSONMarshaler = new(jsonpb.Marshaler)

MySQLCheckerJSONMarshaler describes the default jsonpb.Marshaler used by all instances of MySQLChecker. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var MySQLCheckerJSONUnmarshaler = new(jsonpb.Unmarshaler)

MySQLCheckerJSONUnmarshaler describes the default jsonpb.Unmarshaler used by all instances of MySQLChecker. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var RedisCheckerJSONMarshaler = new(jsonpb.Marshaler)

RedisCheckerJSONMarshaler describes the default jsonpb.Marshaler used by all instances of RedisChecker. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var RedisCheckerJSONUnmarshaler = new(jsonpb.Unmarshaler)

RedisCheckerJSONUnmarshaler describes the default jsonpb.Unmarshaler used by all instances of RedisChecker. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var TCPCheckerJSONMarshaler = new(jsonpb.Marshaler)

TCPCheckerJSONMarshaler describes the default jsonpb.Marshaler used by all instances of TCPChecker. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var TCPCheckerJSONUnmarshaler = new(jsonpb.Unmarshaler)

TCPCheckerJSONUnmarshaler describes the default jsonpb.Unmarshaler used by all instances of TCPChecker. This struct is safe to replace or modify but should not be done so concurrently.

Functions

This section is empty.

Types

type ATCPChecker 

type ATCPChecker struct {
	// List of actions.
	// All actions will execute during the health check,
	// if one of the actions fails, this health check will be considered as failed.
	// Need at least one action.
	Action               []*ATCPChecker_Action `protobuf:"bytes,1,rep,name=action,proto3" json:"action,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

ATCP checker config.

func (*ATCPChecker) Descriptor 

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

func (*ATCPChecker) Equal 

func (this *ATCPChecker) Equal(that interface{}) bool

func (*ATCPChecker) GetAction 

func (m *ATCPChecker) GetAction() []*ATCPChecker_Action

func (*ATCPChecker) GoString 

func (this *ATCPChecker) GoString() string

func (*ATCPChecker) Marshal 

func (m *ATCPChecker) Marshal() (dAtA []byte, err error)

func (*ATCPChecker) MarshalJSON 

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

MarshalJSON satisfies the encoding/json Marshaler interface. This method uses the more correct jsonpb package to correctly marshal the message.

func (*ATCPChecker) MarshalTo 

func (m *ATCPChecker) MarshalTo(dAtA []byte) (int, error)

func (*ATCPChecker) MarshalToSizedBuffer 

func (m *ATCPChecker) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ATCPChecker) ProtoMessage 

func (*ATCPChecker) ProtoMessage()

func (*ATCPChecker) Reset 

func (m *ATCPChecker) Reset()

func (*ATCPChecker) Size 

func (m *ATCPChecker) Size() (n int)

func (*ATCPChecker) String 

func (m *ATCPChecker) String() string

func (*ATCPChecker) Unmarshal 

func (m *ATCPChecker) Unmarshal(dAtA []byte) error

func (*ATCPChecker) UnmarshalJSON 

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

UnmarshalJSON satisfies the encoding/json Unmarshaler interface. This method uses the more correct jsonpb package to correctly unmarshal the message.

func (*ATCPChecker) Validate 

func (m *ATCPChecker) Validate() error

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

func (*ATCPChecker) VerboseEqual 

func (this *ATCPChecker) VerboseEqual(that interface{}) error

func (*ATCPChecker) XXX_DiscardUnknown 

func (m *ATCPChecker) XXX_DiscardUnknown()

func (*ATCPChecker) XXX_Marshal 

func (m *ATCPChecker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ATCPChecker) XXX_Merge 

func (m *ATCPChecker) XXX_Merge(src proto.Message)

func (*ATCPChecker) XXX_Size 

func (m *ATCPChecker) XXX_Size() int

func (*ATCPChecker) XXX_Unmarshal 

func (m *ATCPChecker) XXX_Unmarshal(b []byte) error

type ATCPCheckerValidationError 

type ATCPCheckerValidationError struct {
	// contains filtered or unexported fields
}

ATCPCheckerValidationError is the validation error returned by ATCPChecker.Validate if the designated constraints aren't met.

func (ATCPCheckerValidationError) Cause 

func (e ATCPCheckerValidationError) Cause() error

Cause function returns cause value.

func (ATCPCheckerValidationError) Error 

func (e ATCPCheckerValidationError) Error() string

Error satisfies the builtin error interface

func (ATCPCheckerValidationError) ErrorName 

func (e ATCPCheckerValidationError) ErrorName() string

ErrorName returns error name.

func (ATCPCheckerValidationError) Field 

func (e ATCPCheckerValidationError) Field() string

Field function returns field value.

func (ATCPCheckerValidationError) Key 

func (e ATCPCheckerValidationError) Key() bool

Key function returns key value.

func (ATCPCheckerValidationError) Reason 

func (e ATCPCheckerValidationError) Reason() string

Reason function returns reason value.

type ATCPChecker_Action 

type ATCPChecker_Action struct {
	// This is used to send a data along with a connection opening.
	Send []byte `protobuf:"bytes,1,opt,name=send,proto3" json:"send,omitempty"`
	// Expecting content returned from the server.
	Expect               []byte   `protobuf:"bytes,2,opt,name=expect,proto3" json:"expect,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Action represents a set of requests from Samaritan to the server and what the expected server returns.

func (*ATCPChecker_Action) Descriptor 

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

func (*ATCPChecker_Action) Equal 

func (this *ATCPChecker_Action) Equal(that interface{}) bool

func (*ATCPChecker_Action) GetExpect 

func (m *ATCPChecker_Action) GetExpect() []byte

func (*ATCPChecker_Action) GetSend 

func (m *ATCPChecker_Action) GetSend() []byte

func (*ATCPChecker_Action) GoString 

func (this *ATCPChecker_Action) GoString() string

func (*ATCPChecker_Action) Marshal 

func (m *ATCPChecker_Action) Marshal() (dAtA []byte, err error)

func (*ATCPChecker_Action) MarshalJSON 

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

MarshalJSON satisfies the encoding/json Marshaler interface. This method uses the more correct jsonpb package to correctly marshal the message.

func (*ATCPChecker_Action) MarshalTo 

func (m *ATCPChecker_Action) MarshalTo(dAtA []byte) (int, error)

func (*ATCPChecker_Action) MarshalToSizedBuffer 

func (m *ATCPChecker_Action) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ATCPChecker_Action) ProtoMessage 

func (*ATCPChecker_Action) ProtoMessage()

func (*ATCPChecker_Action) Reset 

func (m *ATCPChecker_Action) Reset()

func (*ATCPChecker_Action) Size 

func (m *ATCPChecker_Action) Size() (n int)

func (*ATCPChecker_Action) String 

func (m *ATCPChecker_Action) String() string

func (*ATCPChecker_Action) Unmarshal 

func (m *ATCPChecker_Action) Unmarshal(dAtA []byte) error

func (*ATCPChecker_Action) UnmarshalJSON 

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

UnmarshalJSON satisfies the encoding/json Unmarshaler interface. This method uses the more correct jsonpb package to correctly unmarshal the message.

func (*ATCPChecker_Action) Validate 

func (m *ATCPChecker_Action) Validate() error

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

func (*ATCPChecker_Action) VerboseEqual 

func (this *ATCPChecker_Action) VerboseEqual(that interface{}) error

func (*ATCPChecker_Action) XXX_DiscardUnknown 

func (m *ATCPChecker_Action) XXX_DiscardUnknown()

func (*ATCPChecker_Action) XXX_Marshal 

func (m *ATCPChecker_Action) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ATCPChecker_Action) XXX_Merge 

func (m *ATCPChecker_Action) XXX_Merge(src proto.Message)

func (*ATCPChecker_Action) XXX_Size 

func (m *ATCPChecker_Action) XXX_Size() int

func (*ATCPChecker_Action) XXX_Unmarshal 

func (m *ATCPChecker_Action) XXX_Unmarshal(b []byte) error

type ATCPChecker_ActionValidationError 

type ATCPChecker_ActionValidationError struct {
	// contains filtered or unexported fields
}

ATCPChecker_ActionValidationError is the validation error returned by ATCPChecker_Action.Validate if the designated constraints aren't met.

func (ATCPChecker_ActionValidationError) Cause 

func (e ATCPChecker_ActionValidationError) Cause() error

Cause function returns cause value.

func (ATCPChecker_ActionValidationError) Error 

func (e ATCPChecker_ActionValidationError) Error() string

Error satisfies the builtin error interface

func (ATCPChecker_ActionValidationError) ErrorName 

func (e ATCPChecker_ActionValidationError) ErrorName() string

ErrorName returns error name.

func (ATCPChecker_ActionValidationError) Field 

func (e ATCPChecker_ActionValidationError) Field() string

Field function returns field value.

func (ATCPChecker_ActionValidationError) Key 

func (e ATCPChecker_ActionValidationError) Key() bool

Key function returns key value.

func (ATCPChecker_ActionValidationError) Reason 

func (e ATCPChecker_ActionValidationError) Reason() string

Reason function returns reason value.

type HealthCheck 

type HealthCheck struct {
	// The interval between two consecutive health checks.
	// Must be greater than 0s.
	Interval time.Duration `protobuf:"bytes,1,opt,name=interval,proto3,stdduration" json:"interval"`
	// The timeout when doing a health check.
	// Must be greater than 0s.
	Timeout time.Duration `protobuf:"bytes,2,opt,name=timeout,proto3,stdduration" json:"timeout"`
	// A server will be considered as dead after # consecutive unsuccessful health checks.
	// Must be greater than 0.
	FallThreshold uint32 `protobuf:"varint,3,opt,name=fall_threshold,json=fallThreshold,proto3" json:"fall_threshold,omitempty"`
	// A server will be considered as operational after # consecutive successful health checks.
	// Must be greater than 0.
	RiseThreshold uint32 `protobuf:"varint,4,opt,name=rise_threshold,json=riseThreshold,proto3" json:"rise_threshold,omitempty"`
	// Implement of checker, if the checker is null, then TCP checker will be selected.
	//
	// Types that are valid to be assigned to Checker:
	//	*HealthCheck_TcpChecker
	//	*HealthCheck_AtcpChecker
	//	*HealthCheck_MysqlChecker
	//	*HealthCheck_RedisChecker
	Checker              isHealthCheck_Checker `protobuf_oneof:"checker"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

Configuration of health check.

func (*HealthCheck) Descriptor 

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

func (*HealthCheck) Equal 

func (this *HealthCheck) Equal(that interface{}) bool

func (*HealthCheck) GetAtcpChecker 

func (m *HealthCheck) GetAtcpChecker() *ATCPChecker

func (*HealthCheck) GetChecker 

func (m *HealthCheck) GetChecker() isHealthCheck_Checker

func (*HealthCheck) GetFallThreshold 

func (m *HealthCheck) GetFallThreshold() uint32

func (*HealthCheck) GetInterval 

func (m *HealthCheck) GetInterval() time.Duration

func (*HealthCheck) GetMysqlChecker 

func (m *HealthCheck) GetMysqlChecker() *MySQLChecker

func (*HealthCheck) GetRedisChecker 

func (m *HealthCheck) GetRedisChecker() *RedisChecker

func (*HealthCheck) GetRiseThreshold 

func (m *HealthCheck) GetRiseThreshold() uint32

func (*HealthCheck) GetTcpChecker 

func (m *HealthCheck) GetTcpChecker() *TCPChecker

func (*HealthCheck) GetTimeout 

func (m *HealthCheck) GetTimeout() time.Duration

func (*HealthCheck) GoString 

func (this *HealthCheck) GoString() string

func (*HealthCheck) Marshal 

func (m *HealthCheck) Marshal() (dAtA []byte, err error)

func (*HealthCheck) MarshalJSON 

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

MarshalJSON satisfies the encoding/json Marshaler interface. This method uses the more correct jsonpb package to correctly marshal the message.

func (*HealthCheck) MarshalTo 

func (m *HealthCheck) MarshalTo(dAtA []byte) (int, error)

func (*HealthCheck) MarshalToSizedBuffer 

func (m *HealthCheck) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HealthCheck) ProtoMessage 

func (*HealthCheck) ProtoMessage()

func (*HealthCheck) Reset 

func (m *HealthCheck) Reset()

func (*HealthCheck) Size 

func (m *HealthCheck) Size() (n int)

func (*HealthCheck) String 

func (m *HealthCheck) String() string

func (*HealthCheck) Unmarshal 

func (m *HealthCheck) Unmarshal(dAtA []byte) error

func (*HealthCheck) UnmarshalJSON 

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

UnmarshalJSON satisfies the encoding/json Unmarshaler interface. This method uses the more correct jsonpb package to correctly unmarshal the message.

func (*HealthCheck) Validate 

func (m *HealthCheck) Validate() error

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

func (*HealthCheck) VerboseEqual 

func (this *HealthCheck) VerboseEqual(that interface{}) error

func (*HealthCheck) XXX_DiscardUnknown 

func (m *HealthCheck) XXX_DiscardUnknown()

func (*HealthCheck) XXX_Marshal 

func (m *HealthCheck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthCheck) XXX_Merge 

func (m *HealthCheck) XXX_Merge(src proto.Message)

func (*HealthCheck) XXX_OneofWrappers 

func (*HealthCheck) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*HealthCheck) XXX_Size 

func (m *HealthCheck) XXX_Size() int

func (*HealthCheck) XXX_Unmarshal 

func (m *HealthCheck) XXX_Unmarshal(b []byte) error

type HealthCheckValidationError 

type HealthCheckValidationError struct {
	// contains filtered or unexported fields
}

HealthCheckValidationError is the validation error returned by HealthCheck.Validate if the designated constraints aren't met.

func (HealthCheckValidationError) Cause 

func (e HealthCheckValidationError) Cause() error

Cause function returns cause value.

func (HealthCheckValidationError) Error 

func (e HealthCheckValidationError) Error() string

Error satisfies the builtin error interface

func (HealthCheckValidationError) ErrorName 

func (e HealthCheckValidationError) ErrorName() string

ErrorName returns error name.

func (HealthCheckValidationError) Field 

func (e HealthCheckValidationError) Field() string

Field function returns field value.

func (HealthCheckValidationError) Key 

func (e HealthCheckValidationError) Key() bool

Key function returns key value.

func (HealthCheckValidationError) Reason 

func (e HealthCheckValidationError) Reason() string

Reason function returns reason value.

type HealthCheck_AtcpChecker 

type HealthCheck_AtcpChecker struct {
	AtcpChecker *ATCPChecker `protobuf:"bytes,6,opt,name=atcp_checker,json=atcpChecker,proto3,oneof"`
}

func (*HealthCheck_AtcpChecker) Equal 

func (this *HealthCheck_AtcpChecker) Equal(that interface{}) bool

func (*HealthCheck_AtcpChecker) GoString 

func (this *HealthCheck_AtcpChecker) GoString() string

func (*HealthCheck_AtcpChecker) MarshalTo 

func (m *HealthCheck_AtcpChecker) MarshalTo(dAtA []byte) (int, error)

func (*HealthCheck_AtcpChecker) MarshalToSizedBuffer 

func (m *HealthCheck_AtcpChecker) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HealthCheck_AtcpChecker) Size 

func (m *HealthCheck_AtcpChecker) Size() (n int)

func (*HealthCheck_AtcpChecker) VerboseEqual 

func (this *HealthCheck_AtcpChecker) VerboseEqual(that interface{}) error

type HealthCheck_MysqlChecker 

type HealthCheck_MysqlChecker struct {
	MysqlChecker *MySQLChecker `protobuf:"bytes,7,opt,name=mysql_checker,json=mysqlChecker,proto3,oneof"`
}

func (*HealthCheck_MysqlChecker) Equal 

func (this *HealthCheck_MysqlChecker) Equal(that interface{}) bool

func (*HealthCheck_MysqlChecker) GoString 

func (this *HealthCheck_MysqlChecker) GoString() string

func (*HealthCheck_MysqlChecker) MarshalTo 

func (m *HealthCheck_MysqlChecker) MarshalTo(dAtA []byte) (int, error)

func (*HealthCheck_MysqlChecker) MarshalToSizedBuffer 

func (m *HealthCheck_MysqlChecker) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HealthCheck_MysqlChecker) Size 

func (m *HealthCheck_MysqlChecker) Size() (n int)

func (*HealthCheck_MysqlChecker) VerboseEqual 

func (this *HealthCheck_MysqlChecker) VerboseEqual(that interface{}) error

type HealthCheck_RedisChecker 

type HealthCheck_RedisChecker struct {
	RedisChecker *RedisChecker `protobuf:"bytes,8,opt,name=redis_checker,json=redisChecker,proto3,oneof"`
}

func (*HealthCheck_RedisChecker) Equal 

func (this *HealthCheck_RedisChecker) Equal(that interface{}) bool

func (*HealthCheck_RedisChecker) GoString 

func (this *HealthCheck_RedisChecker) GoString() string

func (*HealthCheck_RedisChecker) MarshalTo 

func (m *HealthCheck_RedisChecker) MarshalTo(dAtA []byte) (int, error)

func (*HealthCheck_RedisChecker) MarshalToSizedBuffer 

func (m *HealthCheck_RedisChecker) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HealthCheck_RedisChecker) Size 

func (m *HealthCheck_RedisChecker) Size() (n int)

func (*HealthCheck_RedisChecker) VerboseEqual 

func (this *HealthCheck_RedisChecker) VerboseEqual(that interface{}) error

type HealthCheck_TcpChecker 

type HealthCheck_TcpChecker struct {
	TcpChecker *TCPChecker `protobuf:"bytes,5,opt,name=tcp_checker,json=tcpChecker,proto3,oneof"`
}

func (*HealthCheck_TcpChecker) Equal 

func (this *HealthCheck_TcpChecker) Equal(that interface{}) bool

func (*HealthCheck_TcpChecker) GoString 

func (this *HealthCheck_TcpChecker) GoString() string

func (*HealthCheck_TcpChecker) MarshalTo 

func (m *HealthCheck_TcpChecker) MarshalTo(dAtA []byte) (int, error)

func (*HealthCheck_TcpChecker) MarshalToSizedBuffer 

func (m *HealthCheck_TcpChecker) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HealthCheck_TcpChecker) Size 

func (m *HealthCheck_TcpChecker) Size() (n int)

func (*HealthCheck_TcpChecker) VerboseEqual 

func (this *HealthCheck_TcpChecker) VerboseEqual(that interface{}) error

type MySQLChecker 

type MySQLChecker struct {
	// MySQL server username, not null.
	Username             string   `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

MySQL checker config.

func (*MySQLChecker) Descriptor 

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

func (*MySQLChecker) Equal 

func (this *MySQLChecker) Equal(that interface{}) bool

func (*MySQLChecker) GetUsername 

func (m *MySQLChecker) GetUsername() string

func (*MySQLChecker) GoString 

func (this *MySQLChecker) GoString() string

func (*MySQLChecker) Marshal 

func (m *MySQLChecker) Marshal() (dAtA []byte, err error)

func (*MySQLChecker) MarshalJSON 

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

MarshalJSON satisfies the encoding/json Marshaler interface. This method uses the more correct jsonpb package to correctly marshal the message.

func (*MySQLChecker) MarshalTo 

func (m *MySQLChecker) MarshalTo(dAtA []byte) (int, error)

func (*MySQLChecker) MarshalToSizedBuffer 

func (m *MySQLChecker) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MySQLChecker) ProtoMessage 

func (*MySQLChecker) ProtoMessage()

func (*MySQLChecker) Reset 

func (m *MySQLChecker) Reset()

func (*MySQLChecker) Size 

func (m *MySQLChecker) Size() (n int)

func (*MySQLChecker) String 

func (m *MySQLChecker) String() string

func (*MySQLChecker) Unmarshal 

func (m *MySQLChecker) Unmarshal(dAtA []byte) error

func (*MySQLChecker) UnmarshalJSON 

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

UnmarshalJSON satisfies the encoding/json Unmarshaler interface. This method uses the more correct jsonpb package to correctly unmarshal the message.

func (*MySQLChecker) Validate 

func (m *MySQLChecker) Validate() error

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

func (*MySQLChecker) VerboseEqual 

func (this *MySQLChecker) VerboseEqual(that interface{}) error

func (*MySQLChecker) XXX_DiscardUnknown 

func (m *MySQLChecker) XXX_DiscardUnknown()

func (*MySQLChecker) XXX_Marshal 

func (m *MySQLChecker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MySQLChecker) XXX_Merge 

func (m *MySQLChecker) XXX_Merge(src proto.Message)

func (*MySQLChecker) XXX_Size 

func (m *MySQLChecker) XXX_Size() int

func (*MySQLChecker) XXX_Unmarshal 

func (m *MySQLChecker) XXX_Unmarshal(b []byte) error

type MySQLCheckerValidationError 

type MySQLCheckerValidationError struct {
	// contains filtered or unexported fields
}

MySQLCheckerValidationError is the validation error returned by MySQLChecker.Validate if the designated constraints aren't met.

func (MySQLCheckerValidationError) Cause 

func (e MySQLCheckerValidationError) Cause() error

Cause function returns cause value.

func (MySQLCheckerValidationError) Error 

func (e MySQLCheckerValidationError) Error() string

Error satisfies the builtin error interface

func (MySQLCheckerValidationError) ErrorName 

func (e MySQLCheckerValidationError) ErrorName() string

ErrorName returns error name.

func (MySQLCheckerValidationError) Field 

func (e MySQLCheckerValidationError) Field() string

Field function returns field value.

func (MySQLCheckerValidationError) Key 

func (e MySQLCheckerValidationError) Key() bool

Key function returns key value.

func (MySQLCheckerValidationError) Reason 

func (e MySQLCheckerValidationError) Reason() string

Reason function returns reason value.

type RedisChecker 

type RedisChecker struct {
	// Redis server password, if the password is not empty,
	// the AUTH command will be sent before the PING command.
	Password             string   `protobuf:"bytes,1,opt,name=password,proto3" json:"password,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Redis checker config.

func (*RedisChecker) Descriptor 

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

func (*RedisChecker) Equal 

func (this *RedisChecker) Equal(that interface{}) bool

func (*RedisChecker) GetPassword 

func (m *RedisChecker) GetPassword() string

func (*RedisChecker) GoString 

func (this *RedisChecker) GoString() string

func (*RedisChecker) Marshal 

func (m *RedisChecker) Marshal() (dAtA []byte, err error)

func (*RedisChecker) MarshalJSON 

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

MarshalJSON satisfies the encoding/json Marshaler interface. This method uses the more correct jsonpb package to correctly marshal the message.

func (*RedisChecker) MarshalTo 

func (m *RedisChecker) MarshalTo(dAtA []byte) (int, error)

func (*RedisChecker) MarshalToSizedBuffer 

func (m *RedisChecker) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RedisChecker) ProtoMessage 

func (*RedisChecker) ProtoMessage()

func (*RedisChecker) Reset 

func (m *RedisChecker) Reset()

func (*RedisChecker) Size 

func (m *RedisChecker) Size() (n int)

func (*RedisChecker) String 

func (m *RedisChecker) String() string

func (*RedisChecker) Unmarshal 

func (m *RedisChecker) Unmarshal(dAtA []byte) error

func (*RedisChecker) UnmarshalJSON 

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

UnmarshalJSON satisfies the encoding/json Unmarshaler interface. This method uses the more correct jsonpb package to correctly unmarshal the message.

func (*RedisChecker) Validate 

func (m *RedisChecker) Validate() error

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

func (*RedisChecker) VerboseEqual 

func (this *RedisChecker) VerboseEqual(that interface{}) error

func (*RedisChecker) XXX_DiscardUnknown 

func (m *RedisChecker) XXX_DiscardUnknown()

func (*RedisChecker) XXX_Marshal 

func (m *RedisChecker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RedisChecker) XXX_Merge 

func (m *RedisChecker) XXX_Merge(src proto.Message)

func (*RedisChecker) XXX_Size 

func (m *RedisChecker) XXX_Size() int

func (*RedisChecker) XXX_Unmarshal 

func (m *RedisChecker) XXX_Unmarshal(b []byte) error

type RedisCheckerValidationError 

type RedisCheckerValidationError struct {
	// contains filtered or unexported fields
}

RedisCheckerValidationError is the validation error returned by RedisChecker.Validate if the designated constraints aren't met.

func (RedisCheckerValidationError) Cause 

func (e RedisCheckerValidationError) Cause() error

Cause function returns cause value.

func (RedisCheckerValidationError) Error 

func (e RedisCheckerValidationError) Error() string

Error satisfies the builtin error interface

func (RedisCheckerValidationError) ErrorName 

func (e RedisCheckerValidationError) ErrorName() string

ErrorName returns error name.

func (RedisCheckerValidationError) Field 

func (e RedisCheckerValidationError) Field() string

Field function returns field value.

func (RedisCheckerValidationError) Key 

func (e RedisCheckerValidationError) Key() bool

Key function returns key value.

func (RedisCheckerValidationError) Reason 

func (e RedisCheckerValidationError) Reason() string

Reason function returns reason value.

type TCPChecker 

type TCPChecker struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TCP checker config.

func (*TCPChecker) Descriptor 

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

func (*TCPChecker) Equal 

func (this *TCPChecker) Equal(that interface{}) bool

func (*TCPChecker) GoString 

func (this *TCPChecker) GoString() string

func (*TCPChecker) Marshal 

func (m *TCPChecker) Marshal() (dAtA []byte, err error)

func (*TCPChecker) MarshalJSON 

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

MarshalJSON satisfies the encoding/json Marshaler interface. This method uses the more correct jsonpb package to correctly marshal the message.

func (*TCPChecker) MarshalTo 

func (m *TCPChecker) MarshalTo(dAtA []byte) (int, error)

func (*TCPChecker) MarshalToSizedBuffer 

func (m *TCPChecker) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TCPChecker) ProtoMessage 

func (*TCPChecker) ProtoMessage()

func (*TCPChecker) Reset 

func (m *TCPChecker) Reset()

func (*TCPChecker) Size 

func (m *TCPChecker) Size() (n int)

func (*TCPChecker) String 

func (m *TCPChecker) String() string

func (*TCPChecker) Unmarshal 

func (m *TCPChecker) Unmarshal(dAtA []byte) error

func (*TCPChecker) UnmarshalJSON 

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

UnmarshalJSON satisfies the encoding/json Unmarshaler interface. This method uses the more correct jsonpb package to correctly unmarshal the message.

func (*TCPChecker) Validate 

func (m *TCPChecker) Validate() error

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

func (*TCPChecker) VerboseEqual 

func (this *TCPChecker) VerboseEqual(that interface{}) error

func (*TCPChecker) XXX_DiscardUnknown 

func (m *TCPChecker) XXX_DiscardUnknown()

func (*TCPChecker) XXX_Marshal 

func (m *TCPChecker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TCPChecker) XXX_Merge 

func (m *TCPChecker) XXX_Merge(src proto.Message)

func (*TCPChecker) XXX_Size 

func (m *TCPChecker) XXX_Size() int

func (*TCPChecker) XXX_Unmarshal 

func (m *TCPChecker) XXX_Unmarshal(b []byte) error

type TCPCheckerValidationError 

type TCPCheckerValidationError struct {
	// contains filtered or unexported fields
}

TCPCheckerValidationError is the validation error returned by TCPChecker.Validate if the designated constraints aren't met.

func (TCPCheckerValidationError) Cause 

func (e TCPCheckerValidationError) Cause() error

Cause function returns cause value.

func (TCPCheckerValidationError) Error 

func (e TCPCheckerValidationError) Error() string

Error satisfies the builtin error interface

func (TCPCheckerValidationError) ErrorName 

func (e TCPCheckerValidationError) ErrorName() string

ErrorName returns error name.

func (TCPCheckerValidationError) Field 

func (e TCPCheckerValidationError) Field() string

Field function returns field value.

func (TCPCheckerValidationError) Key 

func (e TCPCheckerValidationError) Key() bool

Key function returns key value.

func (TCPCheckerValidationError) Reason 

func (e TCPCheckerValidationError) 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.