protobuf

Documentation

Index

• Variables
• func RegisterOpenGaussControllerServer(s grpc.ServiceRegistrar, srv OpenGaussControllerServer)
• type GetRequest
  • func (*GetRequest) Descriptor() ([]byte, []int)
  • func (x *GetRequest) GetOpenGaussObjectKey() string
  • func (*GetRequest) ProtoMessage()
  • func (x *GetRequest) ProtoReflect() protoreflect.Message
  • func (x *GetRequest) Reset()
  • func (x *GetRequest) String() string
• type GetResponse
  • func (*GetResponse) Descriptor() ([]byte, []int)
  • func (x *GetResponse) GetMasterReplication() int32
  • func (x *GetResponse) GetSuccess() bool
  • func (x *GetResponse) GetWorkerReplication() int32
  • func (*GetResponse) ProtoMessage()
  • func (x *GetResponse) ProtoReflect() protoreflect.Message
  • func (x *GetResponse) Reset()
  • func (x *GetResponse) String() string
• type OpenGaussControllerClient
  • func NewOpenGaussControllerClient(cc grpc.ClientConnInterface) OpenGaussControllerClient
• type OpenGaussControllerServer
• type ScaleRequest
  • func (*ScaleRequest) Descriptor() ([]byte, []int)
  • func (x *ScaleRequest) GetMasterReplication() int32
  • func (x *ScaleRequest) GetOpenGaussObjectKey() string
  • func (x *ScaleRequest) GetWorkerReplication() int32
  • func (*ScaleRequest) ProtoMessage()
  • func (x *ScaleRequest) ProtoReflect() protoreflect.Message
  • func (x *ScaleRequest) Reset()
  • func (x *ScaleRequest) String() string
• type ScaleResponse
  • func (*ScaleResponse) Descriptor() ([]byte, []int)
  • func (x *ScaleResponse) GetSuccess() bool
  • func (*ScaleResponse) ProtoMessage()
  • func (x *ScaleResponse) ProtoReflect() protoreflect.Message
  • func (x *ScaleResponse) Reset()
  • func (x *ScaleResponse) String() string
• type UnimplementedOpenGaussControllerServer
  • func (UnimplementedOpenGaussControllerServer) Get(context.Context, *GetRequest) (*GetResponse, error)
  • func (UnimplementedOpenGaussControllerServer) Scale(context.Context, *ScaleRequest) (*ScaleResponse, error)
• type UnsafeOpenGaussControllerServer

Variables

var File_protobuf_clients_proto protoreflect.FileDescriptor

var OpenGaussController_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "controllerClient.OpenGaussController",
	HandlerType: (*OpenGaussControllerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Scale",
			Handler:    _OpenGaussController_Scale_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _OpenGaussController_Get_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protobuf/clients.proto",
}

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

Functions

func RegisterOpenGaussControllerServer

func RegisterOpenGaussControllerServer(s grpc.ServiceRegistrar, srv OpenGaussControllerServer)

Types

type GetRequest

type GetRequest struct {
	OpenGaussObjectKey string `protobuf:"bytes,1,opt,name=openGaussObjectKey,proto3" json:"openGaussObjectKey,omitempty"` // namespace/name, e.g.: "default/test-openGauss"
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetOpenGaussObjectKey

func (x *GetRequest) GetOpenGaussObjectKey() string

func (*GetRequest) ProtoMessage

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect

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

func (*GetRequest) Reset

func (x *GetRequest) Reset()

func (*GetRequest) String

func (x *GetRequest) String() string

type GetResponse

type GetResponse struct {
	Success           bool  `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	MasterReplication int32 `protobuf:"varint,2,opt,name=masterReplication,proto3" json:"masterReplication,omitempty"`
	WorkerReplication int32 `protobuf:"varint,3,opt,name=workerReplication,proto3" json:"workerReplication,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetMasterReplication

func (x *GetResponse) GetMasterReplication() int32

func (*GetResponse) GetSuccess

func (x *GetResponse) GetSuccess() bool

func (*GetResponse) GetWorkerReplication

func (x *GetResponse) GetWorkerReplication() int32

func (*GetResponse) ProtoMessage

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect

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

func (*GetResponse) Reset

func (x *GetResponse) Reset()

func (*GetResponse) String

func (x *GetResponse) String() string

type OpenGaussControllerClient

type OpenGaussControllerClient interface {
	Scale(ctx context.Context, in *ScaleRequest, opts ...grpc.CallOption) (*ScaleResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
}

OpenGaussControllerClient is the client API for OpenGaussController 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 NewOpenGaussControllerClient

func NewOpenGaussControllerClient(cc grpc.ClientConnInterface) OpenGaussControllerClient

type OpenGaussControllerServer

type OpenGaussControllerServer interface {
	Scale(context.Context, *ScaleRequest) (*ScaleResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// contains filtered or unexported methods
}

OpenGaussControllerServer is the server API for OpenGaussController service. All implementations must embed UnimplementedOpenGaussControllerServer for forward compatibility

type ScaleRequest

type ScaleRequest struct {
	OpenGaussObjectKey string `protobuf:"bytes,1,opt,name=openGaussObjectKey,proto3" json:"openGaussObjectKey,omitempty"` // namespace/name, e.g.: "default/test-openGauss"
	MasterReplication  int32  `protobuf:"varint,2,opt,name=masterReplication,proto3" json:"masterReplication,omitempty"`
	WorkerReplication  int32  `protobuf:"varint,3,opt,name=workerReplication,proto3" json:"workerReplication,omitempty"`
	// contains filtered or unexported fields
}

func (*ScaleRequest) Descriptor

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

Deprecated: Use ScaleRequest.ProtoReflect.Descriptor instead.

func (*ScaleRequest) GetMasterReplication

func (x *ScaleRequest) GetMasterReplication() int32

func (*ScaleRequest) GetOpenGaussObjectKey

func (x *ScaleRequest) GetOpenGaussObjectKey() string

func (*ScaleRequest) GetWorkerReplication

func (x *ScaleRequest) GetWorkerReplication() int32

func (*ScaleRequest) ProtoMessage

func (*ScaleRequest) ProtoMessage()

func (*ScaleRequest) ProtoReflect

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

func (*ScaleRequest) Reset

func (x *ScaleRequest) Reset()

func (*ScaleRequest) String

func (x *ScaleRequest) String() string

type ScaleResponse

type ScaleResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*ScaleResponse) Descriptor

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

Deprecated: Use ScaleResponse.ProtoReflect.Descriptor instead.

func (*ScaleResponse) GetSuccess

func (x *ScaleResponse) GetSuccess() bool

func (*ScaleResponse) ProtoMessage

func (*ScaleResponse) ProtoMessage()

func (*ScaleResponse) ProtoReflect

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

func (*ScaleResponse) Reset

func (x *ScaleResponse) Reset()

func (*ScaleResponse) String

func (x *ScaleResponse) String() string

type UnimplementedOpenGaussControllerServer

type UnimplementedOpenGaussControllerServer struct {
}

UnimplementedOpenGaussControllerServer must be embedded to have forward compatible implementations.

func (UnimplementedOpenGaussControllerServer) Get

func (UnimplementedOpenGaussControllerServer) Get(context.Context, *GetRequest) (*GetResponse, error)

func (UnimplementedOpenGaussControllerServer) Scale

func (UnimplementedOpenGaussControllerServer) Scale(context.Context, *ScaleRequest) (*ScaleResponse, error)

type UnsafeOpenGaussControllerServer

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

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