polardb

package
v0.0.0-...-3f388d4 Latest Latest
Warning

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

 Go to latest Published: Jun 8, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ControlService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "polardb.ControlService",
	HandlerType: (*ControlServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SyncInstance",
			Handler:    _ControlService_SyncInstance_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "control_service.proto",
}

ControlService_ServiceDesc is the grpc.ServiceDesc for ControlService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_control_service_proto protoreflect.FileDescriptor

Functions

func RegisterControlServiceServer 

func RegisterControlServiceServer(s grpc.ServiceRegistrar, srv ControlServiceServer)

Types

type ControlServiceClient 

type ControlServiceClient interface {
	// 下发实例元信息(有密码敏感信息，UE不存储实例元信息，UE进程重启后丢失实例信息，需要CM一直下发实例元信息，类型心跳机制)
	SyncInstance(ctx context.Context, in *SyncInstanceRequest, opts ...grpc.CallOption) (*SyncInstanceResponse, error)
}

ControlServiceClient is the client API for ControlService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewControlServiceClient 

func NewControlServiceClient(cc grpc.ClientConnInterface) ControlServiceClient

type ControlServiceServer 

type ControlServiceServer interface {
	// 下发实例元信息(有密码敏感信息，UE不存储实例元信息，UE进程重启后丢失实例信息，需要CM一直下发实例元信息，类型心跳机制)
	SyncInstance(context.Context, *SyncInstanceRequest) (*SyncInstanceResponse, error)
	// contains filtered or unexported methods
}

ControlServiceServer is the server API for ControlService service. All implementations must embed UnimplementedControlServiceServer for forward compatibility

type InsSpec 

type InsSpec struct {
	Host     string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port     int32  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	Database string `protobuf:"bytes,5,opt,name=database,proto3" json:"database,omitempty"`
	Instype  string `protobuf:"bytes,6,opt,name=instype,proto3" json:"instype,omitempty"` // "db", "maxscale", "cm"
	// contains filtered or unexported fields
}

func (*InsSpec) Descriptor deprecated 

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

Deprecated: Use InsSpec.ProtoReflect.Descriptor instead.

func (*InsSpec) GetDatabase 

func (x *InsSpec) GetDatabase() string

func (*InsSpec) GetHost 

func (x *InsSpec) GetHost() string

func (*InsSpec) GetInstype 

func (x *InsSpec) GetInstype() string

func (*InsSpec) GetPassword 

func (x *InsSpec) GetPassword() string

func (*InsSpec) GetPort 

func (x *InsSpec) GetPort() int32

func (*InsSpec) GetUsername 

func (x *InsSpec) GetUsername() string

func (*InsSpec) ProtoMessage 

func (*InsSpec) ProtoMessage()

func (*InsSpec) ProtoReflect 

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

func (*InsSpec) Reset 

func (x *InsSpec) Reset()

func (*InsSpec) String 

func (x *InsSpec) String() string

type SyncInstanceRequest 

type SyncInstanceRequest struct {
	SystemIdentify string   `protobuf:"bytes,1,opt,name=system_identify,json=systemIdentify,proto3" json:"system_identify,omitempty"`
	LogicalInsname string   `protobuf:"bytes,4,opt,name=logical_insname,json=logicalInsname,proto3" json:"logical_insname,omitempty"`
	Ins            *InsSpec `protobuf:"bytes,2,opt,name=ins,proto3" json:"ins,omitempty"`
	Rw             *InsSpec `protobuf:"bytes,3,opt,name=rw,proto3" json:"rw,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncInstanceRequest) Descriptor deprecated 

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

Deprecated: Use SyncInstanceRequest.ProtoReflect.Descriptor instead.

func (*SyncInstanceRequest) GetIns 

func (x *SyncInstanceRequest) GetIns() *InsSpec

func (*SyncInstanceRequest) GetLogicalInsname 

func (x *SyncInstanceRequest) GetLogicalInsname() string

func (*SyncInstanceRequest) GetRw 

func (x *SyncInstanceRequest) GetRw() *InsSpec

func (*SyncInstanceRequest) GetSystemIdentify 

func (x *SyncInstanceRequest) GetSystemIdentify() string

func (*SyncInstanceRequest) ProtoMessage 

func (*SyncInstanceRequest) ProtoMessage()

func (*SyncInstanceRequest) ProtoReflect 

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

func (*SyncInstanceRequest) Reset 

func (x *SyncInstanceRequest) Reset()

func (*SyncInstanceRequest) String 

func (x *SyncInstanceRequest) String() string

type SyncInstanceResponse 

type SyncInstanceResponse struct {

	// 返回码
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg     string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncInstanceResponse) Descriptor deprecated 

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

Deprecated: Use SyncInstanceResponse.ProtoReflect.Descriptor instead.

func (*SyncInstanceResponse) GetCode 

func (x *SyncInstanceResponse) GetCode() int32

func (*SyncInstanceResponse) GetMsg 

func (x *SyncInstanceResponse) GetMsg() string

func (*SyncInstanceResponse) GetVersion 

func (x *SyncInstanceResponse) GetVersion() string

func (*SyncInstanceResponse) ProtoMessage 

func (*SyncInstanceResponse) ProtoMessage()

func (*SyncInstanceResponse) ProtoReflect 

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

func (*SyncInstanceResponse) Reset 

func (x *SyncInstanceResponse) Reset()

func (*SyncInstanceResponse) String 

func (x *SyncInstanceResponse) String() string

type UnimplementedControlServiceServer 

type UnimplementedControlServiceServer struct {
}

UnimplementedControlServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedControlServiceServer) SyncInstance 

func (UnimplementedControlServiceServer) SyncInstance(context.Context, *SyncInstanceRequest) (*SyncInstanceResponse, error)

type UnsafeControlServiceServer 

type UnsafeControlServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeControlServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ControlServiceServer will result in compilation errors.

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.