Documentation
¶
Index ¶
Constants ¶
const (
PGService_StreamUpdates_FullMethodName = "/PGService/StreamUpdates"
)
Variables ¶
var File_proto_pg_proto protoreflect.FileDescriptor
var PGService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "PGService", HandlerType: (*PGServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "StreamUpdates", Handler: _PGService_StreamUpdates_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "proto/pg.proto", }
PGService_ServiceDesc is the grpc.ServiceDesc for PGService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterPGServiceServer ¶
func RegisterPGServiceServer(s grpc.ServiceRegistrar, srv PGServiceServer)
Types ¶
type PGServiceClient ¶
type PGServiceClient interface {
StreamUpdates(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[PGUpdate, PGUpdate], error)
}
PGServiceClient is the client API for PGService 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.
A simple symetric service that can be implemented by either the service or app or both. This service streams updates bidirectionally between both sides.
func NewPGServiceClient ¶
func NewPGServiceClient(cc grpc.ClientConnInterface) PGServiceClient
type PGServiceServer ¶
type PGServiceServer interface {
StreamUpdates(grpc.BidiStreamingServer[PGUpdate, PGUpdate]) error
// contains filtered or unexported methods
}
PGServiceServer is the server API for PGService service. All implementations must embed UnimplementedPGServiceServer for forward compatibility.
A simple symetric service that can be implemented by either the service or app or both. This service streams updates bidirectionally between both sides.
type PGService_StreamUpdatesClient ¶
type PGService_StreamUpdatesClient = grpc.BidiStreamingClient[PGUpdate, PGUpdate]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type PGService_StreamUpdatesServer ¶
type PGService_StreamUpdatesServer = grpc.BidiStreamingServer[PGUpdate, PGUpdate]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type PGUpdate ¶
type PGUpdate struct {
// CBOR encoded structure representing the update.
Cbor []byte `protobuf:"bytes,1,opt,name=cbor,proto3" json:"cbor,omitempty"`
// contains filtered or unexported fields
}
func (*PGUpdate) Descriptor
deprecated
func (*PGUpdate) ProtoMessage ¶
func (*PGUpdate) ProtoMessage()
func (*PGUpdate) ProtoReflect ¶
func (x *PGUpdate) ProtoReflect() protoreflect.Message
type UnimplementedPGServiceServer ¶
type UnimplementedPGServiceServer struct{}
UnimplementedPGServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedPGServiceServer) StreamUpdates ¶
func (UnimplementedPGServiceServer) StreamUpdates(grpc.BidiStreamingServer[PGUpdate, PGUpdate]) error
type UnsafePGServiceServer ¶
type UnsafePGServiceServer interface {
// contains filtered or unexported methods
}
UnsafePGServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PGServiceServer will result in compilation errors.
Source Files