Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterBluePandaServer(s grpc.ServiceRegistrar, srv BluePandaServer)
- type BluePandaClient
- type BluePandaServer
- type BluePanda_FetchClient
- type BluePanda_FetchServer
- type Data
- type FetchRequest
- func (*FetchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FetchRequest) GetColumns() []string
- func (x *FetchRequest) GetType() string
- func (x *FetchRequest) GetUuid() string
- func (*FetchRequest) ProtoMessage()
- func (x *FetchRequest) ProtoReflect() protoreflect.Message
- func (x *FetchRequest) Reset()
- func (x *FetchRequest) String() string
- type FetchResult
- type UnimplementedBluePandaServer
- type UnsafeBluePandaServer
Constants ¶
View Source
const (
BluePanda_Fetch_FullMethodName = "/bluepanda.BluePanda/Fetch"
)
Variables ¶
View Source
var BluePanda_ServiceDesc = grpc.ServiceDesc{ ServiceName: "bluepanda.BluePanda", HandlerType: (*BluePandaServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Fetch", Handler: _BluePanda_Fetch_Handler, ServerStreams: true, }, }, Metadata: "service.proto", }
BluePanda_ServiceDesc is the grpc.ServiceDesc for BluePanda 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_service_proto protoreflect.FileDescriptor
Functions ¶
func RegisterBluePandaServer ¶
func RegisterBluePandaServer(s grpc.ServiceRegistrar, srv BluePandaServer)
Types ¶
type BluePandaClient ¶
type BluePandaClient interface {
Fetch(ctx context.Context, in *FetchRequest, opts ...grpc.CallOption) (BluePanda_FetchClient, error)
}
BluePandaClient is the client API for BluePanda 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 NewBluePandaClient ¶
func NewBluePandaClient(cc grpc.ClientConnInterface) BluePandaClient
type BluePandaServer ¶
type BluePandaServer interface {
Fetch(*FetchRequest, BluePanda_FetchServer) error
// contains filtered or unexported methods
}
BluePandaServer is the server API for BluePanda service. All implementations must embed UnimplementedBluePandaServer for forward compatibility
type BluePanda_FetchClient ¶
type BluePanda_FetchClient interface {
Recv() (*FetchResult, error)
grpc.ClientStream
}
type BluePanda_FetchServer ¶
type BluePanda_FetchServer interface {
Send(*FetchResult) error
grpc.ServerStream
}
type Data ¶
type Data struct {
Column string `protobuf:"bytes,1,opt,name=column,proto3" json:"column,omitempty"`
Type uint32 `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"`
Value *any1.Any `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
func (*Data) Descriptor
deprecated
func (*Data) ProtoMessage ¶
func (*Data) ProtoMessage()
func (*Data) ProtoReflect ¶
func (x *Data) ProtoReflect() protoreflect.Message
type FetchRequest ¶
type FetchRequest struct {
Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
Columns []string `protobuf:"bytes,3,rep,name=columns,proto3" json:"columns,omitempty"`
// contains filtered or unexported fields
}
func (*FetchRequest) Descriptor
deprecated
func (*FetchRequest) Descriptor() ([]byte, []int)
Deprecated: Use FetchRequest.ProtoReflect.Descriptor instead.
func (*FetchRequest) GetColumns ¶
func (x *FetchRequest) GetColumns() []string
func (*FetchRequest) GetType ¶
func (x *FetchRequest) GetType() string
func (*FetchRequest) GetUuid ¶
func (x *FetchRequest) GetUuid() string
func (*FetchRequest) ProtoMessage ¶
func (*FetchRequest) ProtoMessage()
func (*FetchRequest) ProtoReflect ¶
func (x *FetchRequest) ProtoReflect() protoreflect.Message
func (*FetchRequest) Reset ¶
func (x *FetchRequest) Reset()
func (*FetchRequest) String ¶
func (x *FetchRequest) String() string
type FetchResult ¶
type FetchResult struct {
Json []byte `protobuf:"bytes,1,opt,name=json,proto3" json:"json,omitempty"`
// contains filtered or unexported fields
}
func (*FetchResult) Descriptor
deprecated
func (*FetchResult) Descriptor() ([]byte, []int)
Deprecated: Use FetchResult.ProtoReflect.Descriptor instead.
func (*FetchResult) GetJson ¶
func (x *FetchResult) GetJson() []byte
func (*FetchResult) ProtoMessage ¶
func (*FetchResult) ProtoMessage()
func (*FetchResult) ProtoReflect ¶
func (x *FetchResult) ProtoReflect() protoreflect.Message
func (*FetchResult) Reset ¶
func (x *FetchResult) Reset()
func (*FetchResult) String ¶
func (x *FetchResult) String() string
type UnimplementedBluePandaServer ¶
type UnimplementedBluePandaServer struct {
}
UnimplementedBluePandaServer must be embedded to have forward compatible implementations.
func (UnimplementedBluePandaServer) Fetch ¶
func (UnimplementedBluePandaServer) Fetch(*FetchRequest, BluePanda_FetchServer) error
type UnsafeBluePandaServer ¶
type UnsafeBluePandaServer interface {
// contains filtered or unexported methods
}
UnsafeBluePandaServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BluePandaServer will result in compilation errors.
Source Files
Click to show internal directories.
Click to hide internal directories.