command

package
v0.0.1-alpha Latest Latest
Warning

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

 Go to latest Published: May 31, 2021 License: GPL-3.0 Imports: 16 Imported by: 0

Documentation

Overview

Package command is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var DatabaseController_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "DatabaseController",
	HandlerType: (*DatabaseControllerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SelectDatabase",
			Handler:    _DatabaseController_SelectDatabase_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _DatabaseController_Get_Handler,
		},
		{
			MethodName: "Set",
			Handler:    _DatabaseController_Set_Handler,
		},
		{
			MethodName: "GetKeys",
			Handler:    _DatabaseController_GetKeys_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/proto/command/command.proto",
}

DatabaseController_ServiceDesc is the grpc.ServiceDesc for DatabaseController 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_api_proto_command_command_proto protoreflect.FileDescriptor

Functions

func RegisterDatabaseControllerHandler 

func RegisterDatabaseControllerHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterDatabaseControllerHandler registers the http handlers for service DatabaseController to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterDatabaseControllerHandlerClient 

func RegisterDatabaseControllerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DatabaseControllerClient) error

RegisterDatabaseControllerHandlerClient registers the http handlers for service DatabaseController to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "DatabaseControllerClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "DatabaseControllerClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "DatabaseControllerClient" to call the correct interceptors.

func RegisterDatabaseControllerHandlerFromEndpoint 

func RegisterDatabaseControllerHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterDatabaseControllerHandlerFromEndpoint is same as RegisterDatabaseControllerHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterDatabaseControllerHandlerServer 

func RegisterDatabaseControllerHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DatabaseControllerServer) error

RegisterDatabaseControllerHandlerServer registers the http handlers for service DatabaseController to "mux". UnaryRPC :call DatabaseControllerServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterDatabaseControllerHandlerFromEndpoint instead.

func RegisterDatabaseControllerServer 

func RegisterDatabaseControllerServer(s grpc.ServiceRegistrar, srv DatabaseControllerServer)

Types

type DatabaseControllerClient 

type DatabaseControllerClient interface {
	SelectDatabase(ctx context.Context, in *SelectDatabaseRequest, opts ...grpc.CallOption) (*SelectDatabaseResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error)
	GetKeys(ctx context.Context, in *GetKeysRequest, opts ...grpc.CallOption) (*GetKeysResponse, error)
}

DatabaseControllerClient is the client API for DatabaseController 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 NewDatabaseControllerClient 

func NewDatabaseControllerClient(cc grpc.ClientConnInterface) DatabaseControllerClient

type DatabaseControllerServer 

type DatabaseControllerServer interface {
	SelectDatabase(context.Context, *SelectDatabaseRequest) (*SelectDatabaseResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Set(context.Context, *SetRequest) (*SetResponse, error)
	GetKeys(context.Context, *GetKeysRequest) (*GetKeysResponse, error)
	// contains filtered or unexported methods
}

DatabaseControllerServer is the server API for DatabaseController service. All implementations must embed UnimplementedDatabaseControllerServer for forward compatibility

type GetKeysRequest 

type GetKeysRequest struct {
	DatabaseName string `protobuf:"bytes,1,opt,name=database_name,json=databaseName,proto3" json:"database_name,omitempty"`
	KeyPattern   string `protobuf:"bytes,2,opt,name=key_pattern,json=keyPattern,proto3" json:"key_pattern,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKeysRequest) Descriptor deprecated 

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

Deprecated: Use GetKeysRequest.ProtoReflect.Descriptor instead.

func (*GetKeysRequest) GetDatabaseName 

func (x *GetKeysRequest) GetDatabaseName() string

func (*GetKeysRequest) GetKeyPattern 

func (x *GetKeysRequest) GetKeyPattern() string

func (*GetKeysRequest) ProtoMessage 

func (*GetKeysRequest) ProtoMessage()

func (*GetKeysRequest) ProtoReflect 

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

func (*GetKeysRequest) Reset 

func (x *GetKeysRequest) Reset()

func (*GetKeysRequest) String 

func (x *GetKeysRequest) String() string

type GetKeysResponse 

type GetKeysResponse struct {
	Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKeysResponse) Descriptor deprecated 

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

Deprecated: Use GetKeysResponse.ProtoReflect.Descriptor instead.

func (*GetKeysResponse) GetKeys 

func (x *GetKeysResponse) GetKeys() []string

func (*GetKeysResponse) ProtoMessage 

func (*GetKeysResponse) ProtoMessage()

func (*GetKeysResponse) ProtoReflect 

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

func (*GetKeysResponse) Reset 

func (x *GetKeysResponse) Reset()

func (*GetKeysResponse) String 

func (x *GetKeysResponse) String() string

type GetRequest 

type GetRequest struct {
	DatabaseName string `protobuf:"bytes,1,opt,name=database_name,json=databaseName,proto3" json:"database_name,omitempty"`
	Key          string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetDatabaseName 

func (x *GetRequest) GetDatabaseName() string

func (*GetRequest) GetKey 

func (x *GetRequest) GetKey() 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 {
	Key   string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetKey 

func (x *GetResponse) GetKey() string

func (*GetResponse) GetValue 

func (x *GetResponse) GetValue() []byte

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 SelectDatabaseRequest 

type SelectDatabaseRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*SelectDatabaseRequest) Descriptor deprecated 

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

Deprecated: Use SelectDatabaseRequest.ProtoReflect.Descriptor instead.

func (*SelectDatabaseRequest) GetName 

func (x *SelectDatabaseRequest) GetName() string

func (*SelectDatabaseRequest) ProtoMessage 

func (*SelectDatabaseRequest) ProtoMessage()

func (*SelectDatabaseRequest) ProtoReflect 

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

func (*SelectDatabaseRequest) Reset 

func (x *SelectDatabaseRequest) Reset()

func (*SelectDatabaseRequest) String 

func (x *SelectDatabaseRequest) String() string

type SelectDatabaseResponse 

type SelectDatabaseResponse struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*SelectDatabaseResponse) Descriptor deprecated 

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

Deprecated: Use SelectDatabaseResponse.ProtoReflect.Descriptor instead.

func (*SelectDatabaseResponse) GetName 

func (x *SelectDatabaseResponse) GetName() string

func (*SelectDatabaseResponse) ProtoMessage 

func (*SelectDatabaseResponse) ProtoMessage()

func (*SelectDatabaseResponse) ProtoReflect 

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

func (*SelectDatabaseResponse) Reset 

func (x *SelectDatabaseResponse) Reset()

func (*SelectDatabaseResponse) String 

func (x *SelectDatabaseResponse) String() string

type SetRequest 

type SetRequest struct {
	DatabaseName string `protobuf:"bytes,1,opt,name=database_name,json=databaseName,proto3" json:"database_name,omitempty"`
	Key          string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value        string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SetRequest) Descriptor deprecated 

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

Deprecated: Use SetRequest.ProtoReflect.Descriptor instead.

func (*SetRequest) GetDatabaseName 

func (x *SetRequest) GetDatabaseName() string

func (*SetRequest) GetKey 

func (x *SetRequest) GetKey() string

func (*SetRequest) GetValue 

func (x *SetRequest) GetValue() string

func (*SetRequest) ProtoMessage 

func (*SetRequest) ProtoMessage()

func (*SetRequest) ProtoReflect 

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

func (*SetRequest) Reset 

func (x *SetRequest) Reset()

func (*SetRequest) String 

func (x *SetRequest) String() string

type SetResponse 

type SetResponse struct {
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*SetResponse) Descriptor deprecated 

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

Deprecated: Use SetResponse.ProtoReflect.Descriptor instead.

func (*SetResponse) GetStatus 

func (x *SetResponse) GetStatus() string

func (*SetResponse) ProtoMessage 

func (*SetResponse) ProtoMessage()

func (*SetResponse) ProtoReflect 

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

func (*SetResponse) Reset 

func (x *SetResponse) Reset()

func (*SetResponse) String 

func (x *SetResponse) String() string

type UnimplementedDatabaseControllerServer 

type UnimplementedDatabaseControllerServer struct {
}

UnimplementedDatabaseControllerServer must be embedded to have forward compatible implementations.

func (UnimplementedDatabaseControllerServer) Get 

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

func (UnimplementedDatabaseControllerServer) GetKeys 

func (UnimplementedDatabaseControllerServer) GetKeys(context.Context, *GetKeysRequest) (*GetKeysResponse, error)

func (UnimplementedDatabaseControllerServer) SelectDatabase 

func (UnimplementedDatabaseControllerServer) SelectDatabase(context.Context, *SelectDatabaseRequest) (*SelectDatabaseResponse, error)

func (UnimplementedDatabaseControllerServer) Set 

func (UnimplementedDatabaseControllerServer) Set(context.Context, *SetRequest) (*SetResponse, error)

type UnsafeDatabaseControllerServer 

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

UnsafeDatabaseControllerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DatabaseControllerServer 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.