Documentation
¶
Index ¶
- Variables
- func RegisterPipelanerServer(s grpc.ServiceRegistrar, srv PipelanerServer)
- type Message
- func (*Message) Descriptor() ([]byte, []int)deprecated
- func (x *Message) GetBytesValue() []byte
- func (m *Message) GetData() isMessage_Data
- func (x *Message) GetJsonValue() []byte
- func (x *Message) GetStringValue() string
- func (*Message) ProtoMessage()
- func (x *Message) ProtoReflect() protoreflect.Message
- func (x *Message) Reset()
- func (x *Message) String() string
- type Message_BytesValue
- type Message_JsonValue
- type Message_StringValue
- type PipelanerClient
- type PipelanerServer
- type Pipelaner_SinkStreamClient
- type Pipelaner_SinkStreamServer
- type UnimplementedPipelanerServer
- type UnsafePipelanerServer
Constants ¶
This section is empty.
Variables ¶
var File_service_proto protoreflect.FileDescriptor
var Pipelaner_ServiceDesc = grpc.ServiceDesc{ ServiceName: "pipelaner.service.Pipelaner", HandlerType: (*PipelanerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Sink", Handler: _Pipelaner_Sink_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "SinkStream", Handler: _Pipelaner_SinkStream_Handler, ClientStreams: true, }, }, Metadata: "service.proto", }
Pipelaner_ServiceDesc is the grpc.ServiceDesc for Pipelaner service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterPipelanerServer ¶
func RegisterPipelanerServer(s grpc.ServiceRegistrar, srv PipelanerServer)
Types ¶
type Message ¶
type Message struct {
// Types that are assignable to Data:
//
// *Message_StringValue
// *Message_BytesValue
// *Message_JsonValue
Data isMessage_Data `protobuf_oneof:"data"`
// contains filtered or unexported fields
}
func (*Message) Descriptor
deprecated
func (*Message) GetBytesValue ¶
func (*Message) GetJsonValue ¶
func (*Message) GetStringValue ¶
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) ProtoReflect ¶
func (x *Message) ProtoReflect() protoreflect.Message
type Message_BytesValue ¶
type Message_BytesValue struct {
BytesValue []byte `protobuf:"bytes,2,opt,name=bytes_value,json=bytesValue,proto3,oneof"`
}
type Message_JsonValue ¶
type Message_JsonValue struct {
JsonValue []byte `protobuf:"bytes,3,opt,name=json_value,json=jsonValue,proto3,oneof"`
}
type Message_StringValue ¶
type Message_StringValue struct {
StringValue string `protobuf:"bytes,1,opt,name=string_value,json=stringValue,proto3,oneof"`
}
type PipelanerClient ¶
type PipelanerClient interface {
Sink(ctx context.Context, in *Message, opts ...grpc.CallOption) (*emptypb.Empty, error)
SinkStream(ctx context.Context, opts ...grpc.CallOption) (Pipelaner_SinkStreamClient, error)
}
PipelanerClient is the client API for Pipelaner 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 NewPipelanerClient ¶
func NewPipelanerClient(cc grpc.ClientConnInterface) PipelanerClient
type PipelanerServer ¶
type PipelanerServer interface {
Sink(context.Context, *Message) (*emptypb.Empty, error)
SinkStream(Pipelaner_SinkStreamServer) error
}
PipelanerServer is the server API for Pipelaner service. All implementations should embed UnimplementedPipelanerServer for forward compatibility
type UnimplementedPipelanerServer ¶
type UnimplementedPipelanerServer struct {
}
UnimplementedPipelanerServer should be embedded to have forward compatible implementations.
func (UnimplementedPipelanerServer) SinkStream ¶
func (UnimplementedPipelanerServer) SinkStream(Pipelaner_SinkStreamServer) error
type UnsafePipelanerServer ¶
type UnsafePipelanerServer interface {
// contains filtered or unexported methods
}
UnsafePipelanerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PipelanerServer will result in compilation errors.
Source Files