Documentation ¶
Index ¶
- Variables
- func RegisterLambdaServer(s grpc.ServiceRegistrar, srv LambdaServer)
- type IntRow
- type IntRows
- type LambdaClient
- type LambdaServer
- type Response
- type RoleParams
- type SchemaParams
- func (*SchemaParams) Descriptor() ([]byte, []int)deprecated
- func (x *SchemaParams) GetId() int32
- func (x *SchemaParams) GetSchema() string
- func (x *SchemaParams) GetType() string
- func (*SchemaParams) ProtoMessage()
- func (x *SchemaParams) ProtoReflect() protoreflect.Message
- func (x *SchemaParams) Reset()
- func (x *SchemaParams) String() string
- type StringRow
- type StringRows
- type TableOption
- func (*TableOption) Descriptor() ([]byte, []int)deprecated
- func (x *TableOption) GetField() string
- func (x *TableOption) GetKey() string
- func (x *TableOption) GetTable() string
- func (x *TableOption) GetValues() []string
- func (*TableOption) ProtoMessage()
- func (x *TableOption) ProtoReflect() protoreflect.Message
- func (x *TableOption) Reset()
- func (x *TableOption) String() string
- type UnimplementedLambdaServer
- func (UnimplementedLambdaServer) GetIntData(context.Context, *TableOption) (*IntRows, error)
- func (UnimplementedLambdaServer) GetRoleData(context.Context, *RoleParams) (*Response, error)
- func (UnimplementedLambdaServer) GetSchemaData(context.Context, *SchemaParams) (*Response, error)
- func (UnimplementedLambdaServer) GetStringData(context.Context, *TableOption) (*StringRows, error)
- func (UnimplementedLambdaServer) UploadMySCHEMA(context.Context, *RoleParams) (*Response, error)
- type UnsafeLambdaServer
Constants ¶
This section is empty.
Variables ¶
var File_lambda_proto protoreflect.FileDescriptor
var Lambda_ServiceDesc = grpc.ServiceDesc{ ServiceName: "lambda.Lambda", HandlerType: (*LambdaServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetIntData", Handler: _Lambda_GetIntData_Handler, }, { MethodName: "GetStringData", Handler: _Lambda_GetStringData_Handler, }, { MethodName: "GetSchemaData", Handler: _Lambda_GetSchemaData_Handler, }, { MethodName: "GetRoleData", Handler: _Lambda_GetRoleData_Handler, }, { MethodName: "UploadMySCHEMA", Handler: _Lambda_UploadMySCHEMA_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "lambda.proto", }
Lambda_ServiceDesc is the grpc.ServiceDesc for Lambda service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterLambdaServer ¶
func RegisterLambdaServer(s grpc.ServiceRegistrar, srv LambdaServer)
Types ¶
type IntRow ¶
type IntRow struct { Key int32 `protobuf:"varint,1,opt,name=key,proto3" json:"key,omitempty"` Value int32 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*IntRow) Descriptor
deprecated
func (*IntRow) ProtoMessage ¶
func (*IntRow) ProtoMessage()
func (*IntRow) ProtoReflect ¶
func (x *IntRow) ProtoReflect() protoreflect.Message
type IntRows ¶
type IntRows struct { Rows []*IntRow `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"` // contains filtered or unexported fields }
func (*IntRows) Descriptor
deprecated
func (*IntRows) ProtoMessage ¶
func (*IntRows) ProtoMessage()
func (*IntRows) ProtoReflect ¶
func (x *IntRows) ProtoReflect() protoreflect.Message
type LambdaClient ¶
type LambdaClient interface { GetIntData(ctx context.Context, in *TableOption, opts ...grpc.CallOption) (*IntRows, error) GetStringData(ctx context.Context, in *TableOption, opts ...grpc.CallOption) (*StringRows, error) GetSchemaData(ctx context.Context, in *SchemaParams, opts ...grpc.CallOption) (*Response, error) GetRoleData(ctx context.Context, in *RoleParams, opts ...grpc.CallOption) (*Response, error) UploadMySCHEMA(ctx context.Context, in *RoleParams, opts ...grpc.CallOption) (*Response, error) }
LambdaClient is the client API for Lambda 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 NewLambdaClient ¶
func NewLambdaClient(cc grpc.ClientConnInterface) LambdaClient
type LambdaServer ¶
type LambdaServer interface { GetIntData(context.Context, *TableOption) (*IntRows, error) GetStringData(context.Context, *TableOption) (*StringRows, error) GetSchemaData(context.Context, *SchemaParams) (*Response, error) GetRoleData(context.Context, *RoleParams) (*Response, error) UploadMySCHEMA(context.Context, *RoleParams) (*Response, error) }
LambdaServer is the server API for Lambda service. All implementations should embed UnimplementedLambdaServer for forward compatibility
type Response ¶
type Response struct { Status bool `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*Response) Descriptor
deprecated
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶
func (x *Response) ProtoReflect() protoreflect.Message
type RoleParams ¶
type RoleParams struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*RoleParams) Descriptor
deprecated
func (*RoleParams) Descriptor() ([]byte, []int)
Deprecated: Use RoleParams.ProtoReflect.Descriptor instead.
func (*RoleParams) GetId ¶
func (x *RoleParams) GetId() string
func (*RoleParams) ProtoMessage ¶
func (*RoleParams) ProtoMessage()
func (*RoleParams) ProtoReflect ¶
func (x *RoleParams) ProtoReflect() protoreflect.Message
func (*RoleParams) Reset ¶
func (x *RoleParams) Reset()
func (*RoleParams) String ¶
func (x *RoleParams) String() string
type SchemaParams ¶
type SchemaParams struct { Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Schema string `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"` Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
func (*SchemaParams) Descriptor
deprecated
func (*SchemaParams) Descriptor() ([]byte, []int)
Deprecated: Use SchemaParams.ProtoReflect.Descriptor instead.
func (*SchemaParams) GetId ¶
func (x *SchemaParams) GetId() int32
func (*SchemaParams) GetSchema ¶
func (x *SchemaParams) GetSchema() string
func (*SchemaParams) GetType ¶
func (x *SchemaParams) GetType() string
func (*SchemaParams) ProtoMessage ¶
func (*SchemaParams) ProtoMessage()
func (*SchemaParams) ProtoReflect ¶
func (x *SchemaParams) ProtoReflect() protoreflect.Message
func (*SchemaParams) Reset ¶
func (x *SchemaParams) Reset()
func (*SchemaParams) String ¶
func (x *SchemaParams) String() string
type StringRow ¶
type StringRow struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*StringRow) Descriptor
deprecated
func (*StringRow) ProtoMessage ¶
func (*StringRow) ProtoMessage()
func (*StringRow) ProtoReflect ¶
func (x *StringRow) ProtoReflect() protoreflect.Message
type StringRows ¶
type StringRows struct { Rows []*StringRow `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"` // contains filtered or unexported fields }
func (*StringRows) Descriptor
deprecated
func (*StringRows) Descriptor() ([]byte, []int)
Deprecated: Use StringRows.ProtoReflect.Descriptor instead.
func (*StringRows) GetRows ¶
func (x *StringRows) GetRows() []*StringRow
func (*StringRows) ProtoMessage ¶
func (*StringRows) ProtoMessage()
func (*StringRows) ProtoReflect ¶
func (x *StringRows) ProtoReflect() protoreflect.Message
func (*StringRows) Reset ¶
func (x *StringRows) Reset()
func (*StringRows) String ¶
func (x *StringRows) String() string
type TableOption ¶
type TableOption struct { Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Field string `protobuf:"bytes,3,opt,name=field,proto3" json:"field,omitempty"` Values []string `protobuf:"bytes,4,rep,name=values,proto3" json:"values,omitempty"` // contains filtered or unexported fields }
func (*TableOption) Descriptor
deprecated
func (*TableOption) Descriptor() ([]byte, []int)
Deprecated: Use TableOption.ProtoReflect.Descriptor instead.
func (*TableOption) GetField ¶
func (x *TableOption) GetField() string
func (*TableOption) GetKey ¶
func (x *TableOption) GetKey() string
func (*TableOption) GetTable ¶
func (x *TableOption) GetTable() string
func (*TableOption) GetValues ¶
func (x *TableOption) GetValues() []string
func (*TableOption) ProtoMessage ¶
func (*TableOption) ProtoMessage()
func (*TableOption) ProtoReflect ¶
func (x *TableOption) ProtoReflect() protoreflect.Message
func (*TableOption) Reset ¶
func (x *TableOption) Reset()
func (*TableOption) String ¶
func (x *TableOption) String() string
type UnimplementedLambdaServer ¶
type UnimplementedLambdaServer struct { }
UnimplementedLambdaServer should be embedded to have forward compatible implementations.
func (UnimplementedLambdaServer) GetIntData ¶
func (UnimplementedLambdaServer) GetIntData(context.Context, *TableOption) (*IntRows, error)
func (UnimplementedLambdaServer) GetRoleData ¶
func (UnimplementedLambdaServer) GetRoleData(context.Context, *RoleParams) (*Response, error)
func (UnimplementedLambdaServer) GetSchemaData ¶
func (UnimplementedLambdaServer) GetSchemaData(context.Context, *SchemaParams) (*Response, error)
func (UnimplementedLambdaServer) GetStringData ¶
func (UnimplementedLambdaServer) GetStringData(context.Context, *TableOption) (*StringRows, error)
func (UnimplementedLambdaServer) UploadMySCHEMA ¶
func (UnimplementedLambdaServer) UploadMySCHEMA(context.Context, *RoleParams) (*Response, error)
type UnsafeLambdaServer ¶
type UnsafeLambdaServer interface {
// contains filtered or unexported methods
}
UnsafeLambdaServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LambdaServer will result in compilation errors.