protocol

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: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthProtocol = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowProtocol   = fmt.Errorf("proto: integer overflow")
)
View Source 
var MySQLOptionJSONMarshaler = new(jsonpb.Marshaler)

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

View Source 
var MySQLOptionJSONUnmarshaler = new(jsonpb.Unmarshaler)

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

View Source 
var Protocol_name = map[int32]string{
	0: "UNKNOWN",
	1: "TCP",
	2: "MySQL",
	3: "Redis",
}
View Source 
var Protocol_value = map[string]int32{
	"UNKNOWN": 0,
	"TCP":     1,
	"MySQL":   2,
	"Redis":   3,
}
View Source 
var RedisOptionJSONMarshaler = new(jsonpb.Marshaler)

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

View Source 
var RedisOptionJSONUnmarshaler = new(jsonpb.Unmarshaler)

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

View Source 
var TCPOptionJSONMarshaler = new(jsonpb.Marshaler)

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

View Source 
var TCPOptionJSONUnmarshaler = new(jsonpb.Unmarshaler)

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

Functions

This section is empty.

Types

type MySQLOption 

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

MySQL protocol option.

func (*MySQLOption) Descriptor 

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

func (*MySQLOption) Equal 

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

func (*MySQLOption) GoString 

func (this *MySQLOption) GoString() string

func (*MySQLOption) Marshal 

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

func (*MySQLOption) MarshalJSON 

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

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

func (*MySQLOption) MarshalTo 

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

func (*MySQLOption) MarshalToSizedBuffer 

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

func (*MySQLOption) ProtoMessage 

func (*MySQLOption) ProtoMessage()

func (*MySQLOption) Reset 

func (m *MySQLOption) Reset()

func (*MySQLOption) Size 

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

func (*MySQLOption) String 

func (m *MySQLOption) String() string

func (*MySQLOption) Unmarshal 

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

func (*MySQLOption) UnmarshalJSON 

func (m *MySQLOption) 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 (*MySQLOption) Validate 

func (m *MySQLOption) Validate() error

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

func (*MySQLOption) VerboseEqual 

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

func (*MySQLOption) XXX_DiscardUnknown 

func (m *MySQLOption) XXX_DiscardUnknown()

func (*MySQLOption) XXX_Marshal 

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

func (*MySQLOption) XXX_Merge 

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

func (*MySQLOption) XXX_Size 

func (m *MySQLOption) XXX_Size() int

func (*MySQLOption) XXX_Unmarshal 

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

type MySQLOptionValidationError 

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

MySQLOptionValidationError is the validation error returned by MySQLOption.Validate if the designated constraints aren't met.

func (MySQLOptionValidationError) Cause 

func (e MySQLOptionValidationError) Cause() error

Cause function returns cause value.

func (MySQLOptionValidationError) Error 

func (e MySQLOptionValidationError) Error() string

Error satisfies the builtin error interface

func (MySQLOptionValidationError) ErrorName 

func (e MySQLOptionValidationError) ErrorName() string

ErrorName returns error name.

func (MySQLOptionValidationError) Field 

func (e MySQLOptionValidationError) Field() string

Field function returns field value.

func (MySQLOptionValidationError) Key 

func (e MySQLOptionValidationError) Key() bool

Key function returns key value.

func (MySQLOptionValidationError) Reason 

func (e MySQLOptionValidationError) Reason() string

Reason function returns reason value.

type Protocol 

type Protocol int32

Protocol enum. 

const (
	UNKNOWN Protocol = 0
	// TCP
	TCP Protocol = 1
	// MySQL
	MySQL Protocol = 2
	// Redis
	Redis Protocol = 3
)

func (Protocol) EnumDescriptor 

func (Protocol) EnumDescriptor() ([]byte, []int)

func (Protocol) String 

func (x Protocol) String() string

type RedisOption 

type RedisOption struct {
	// Strategy of a read only command.
	ReadStrategy redis.ReadStrategy `protobuf:"varint,1,opt,name=read_strategy,json=readStrategy,proto3,enum=redis.ReadStrategy" json:"read_strategy,omitempty"`
	// Configuration of compression.
	Compression          *redis.Compression `protobuf:"bytes,2,opt,name=compression,proto3" json:"compression,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Redis protocol option.

func (*RedisOption) Descriptor 

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

func (*RedisOption) Equal 

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

func (*RedisOption) GetCompression 

func (m *RedisOption) GetCompression() *redis.Compression

func (*RedisOption) GetReadStrategy 

func (m *RedisOption) GetReadStrategy() redis.ReadStrategy

func (*RedisOption) GoString 

func (this *RedisOption) GoString() string

func (*RedisOption) Marshal 

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

func (*RedisOption) MarshalJSON 

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

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

func (*RedisOption) MarshalTo 

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

func (*RedisOption) MarshalToSizedBuffer 

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

func (*RedisOption) ProtoMessage 

func (*RedisOption) ProtoMessage()

func (*RedisOption) Reset 

func (m *RedisOption) Reset()

func (*RedisOption) Size 

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

func (*RedisOption) String 

func (m *RedisOption) String() string

func (*RedisOption) Unmarshal 

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

func (*RedisOption) UnmarshalJSON 

func (m *RedisOption) 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 (*RedisOption) Validate 

func (m *RedisOption) Validate() error

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

func (*RedisOption) VerboseEqual 

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

func (*RedisOption) XXX_DiscardUnknown 

func (m *RedisOption) XXX_DiscardUnknown()

func (*RedisOption) XXX_Marshal 

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

func (*RedisOption) XXX_Merge 

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

func (*RedisOption) XXX_Size 

func (m *RedisOption) XXX_Size() int

func (*RedisOption) XXX_Unmarshal 

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

type RedisOptionValidationError 

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

RedisOptionValidationError is the validation error returned by RedisOption.Validate if the designated constraints aren't met.

func (RedisOptionValidationError) Cause 

func (e RedisOptionValidationError) Cause() error

Cause function returns cause value.

func (RedisOptionValidationError) Error 

func (e RedisOptionValidationError) Error() string

Error satisfies the builtin error interface

func (RedisOptionValidationError) ErrorName 

func (e RedisOptionValidationError) ErrorName() string

ErrorName returns error name.

func (RedisOptionValidationError) Field 

func (e RedisOptionValidationError) Field() string

Field function returns field value.

func (RedisOptionValidationError) Key 

func (e RedisOptionValidationError) Key() bool

Key function returns key value.

func (RedisOptionValidationError) Reason 

func (e RedisOptionValidationError) Reason() string

Reason function returns reason value.

type TCPOption 

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

TCP protocol option.

func (*TCPOption) Descriptor 

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

func (*TCPOption) Equal 

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

func (*TCPOption) GoString 

func (this *TCPOption) GoString() string

func (*TCPOption) Marshal 

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

func (*TCPOption) MarshalJSON 

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

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

func (*TCPOption) MarshalTo 

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

func (*TCPOption) MarshalToSizedBuffer 

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

func (*TCPOption) ProtoMessage 

func (*TCPOption) ProtoMessage()

func (*TCPOption) Reset 

func (m *TCPOption) Reset()

func (*TCPOption) Size 

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

func (*TCPOption) String 

func (m *TCPOption) String() string

func (*TCPOption) Unmarshal 

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

func (*TCPOption) UnmarshalJSON 

func (m *TCPOption) 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 (*TCPOption) Validate 

func (m *TCPOption) Validate() error

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

func (*TCPOption) VerboseEqual 

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

func (*TCPOption) XXX_DiscardUnknown 

func (m *TCPOption) XXX_DiscardUnknown()

func (*TCPOption) XXX_Marshal 

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

func (*TCPOption) XXX_Merge 

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

func (*TCPOption) XXX_Size 

func (m *TCPOption) XXX_Size() int

func (*TCPOption) XXX_Unmarshal 

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

type TCPOptionValidationError 

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

TCPOptionValidationError is the validation error returned by TCPOption.Validate if the designated constraints aren't met.

func (TCPOptionValidationError) Cause 

func (e TCPOptionValidationError) Cause() error

Cause function returns cause value.

func (TCPOptionValidationError) Error 

func (e TCPOptionValidationError) Error() string

Error satisfies the builtin error interface

func (TCPOptionValidationError) ErrorName 

func (e TCPOptionValidationError) ErrorName() string

ErrorName returns error name.

func (TCPOptionValidationError) Field 

func (e TCPOptionValidationError) Field() string

Field function returns field value.

func (TCPOptionValidationError) Key 

func (e TCPOptionValidationError) Key() bool

Key function returns key value.

func (TCPOptionValidationError) Reason 

func (e TCPOptionValidationError) Reason() string

Reason function returns reason value.

Source Files

View all Source files

Directories

Path Synopsis

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.