Documentation ¶
Overview ¶
Code generated by protoc-gen-go-ttrpc. DO NOT EDIT. source: github.com/containerd/containerd/api/services/streaming/v1/streaming.proto
Index ¶
- Variables
- func RegisterStreamingServer(s grpc.ServiceRegistrar, srv StreamingServer)
- func RegisterTTRPCStreamingService(srv *ttrpc.Server, svc TTRPCStreamingService)
- type StreamInit
- type StreamingClient
- type StreamingServer
- type Streaming_StreamClient
- type Streaming_StreamServer
- type TTRPCStreamingClient
- type TTRPCStreamingService
- type TTRPCStreaming_StreamClient
- type TTRPCStreaming_StreamServer
- type UnimplementedStreamingServer
- type UnsafeStreamingServer
Constants ¶
This section is empty.
Variables ¶
var File_github_com_containerd_containerd_api_services_streaming_v1_streaming_proto protoreflect.FileDescriptor
var Streaming_ServiceDesc = grpc.ServiceDesc{ ServiceName: "containerd.services.streaming.v1.Streaming", HandlerType: (*StreamingServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Stream", Handler: _Streaming_Stream_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "github.com/containerd/containerd/api/services/streaming/v1/streaming.proto", }
Streaming_ServiceDesc is the grpc.ServiceDesc for Streaming service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterStreamingServer ¶
func RegisterStreamingServer(s grpc.ServiceRegistrar, srv StreamingServer)
func RegisterTTRPCStreamingService ¶
func RegisterTTRPCStreamingService(srv *ttrpc.Server, svc TTRPCStreamingService)
Types ¶
type StreamInit ¶
type StreamInit struct { ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*StreamInit) Descriptor
deprecated
func (*StreamInit) Descriptor() ([]byte, []int)
Deprecated: Use StreamInit.ProtoReflect.Descriptor instead.
func (*StreamInit) GetID ¶
func (x *StreamInit) GetID() string
func (*StreamInit) ProtoMessage ¶
func (*StreamInit) ProtoMessage()
func (*StreamInit) ProtoReflect ¶
func (x *StreamInit) ProtoReflect() protoreflect.Message
func (*StreamInit) Reset ¶
func (x *StreamInit) Reset()
func (*StreamInit) String ¶
func (x *StreamInit) String() string
type StreamingClient ¶
type StreamingClient interface {
Stream(ctx context.Context, opts ...grpc.CallOption) (Streaming_StreamClient, error)
}
StreamingClient is the client API for Streaming 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 NewStreamingClient ¶
func NewStreamingClient(cc grpc.ClientConnInterface) StreamingClient
type StreamingServer ¶
type StreamingServer interface { Stream(Streaming_StreamServer) error // contains filtered or unexported methods }
StreamingServer is the server API for Streaming service. All implementations must embed UnimplementedStreamingServer for forward compatibility
type Streaming_StreamClient ¶
type Streaming_StreamServer ¶
type TTRPCStreamingClient ¶
type TTRPCStreamingClient interface {
Stream(context.Context) (TTRPCStreaming_StreamClient, error)
}
func NewTTRPCStreamingClient ¶
func NewTTRPCStreamingClient(client *ttrpc.Client) TTRPCStreamingClient
type TTRPCStreamingService ¶
type TTRPCStreamingService interface {
Stream(context.Context, TTRPCStreaming_StreamServer) error
}
type UnimplementedStreamingServer ¶
type UnimplementedStreamingServer struct { }
UnimplementedStreamingServer must be embedded to have forward compatible implementations.
func (UnimplementedStreamingServer) Stream ¶
func (UnimplementedStreamingServer) Stream(Streaming_StreamServer) error
type UnsafeStreamingServer ¶
type UnsafeStreamingServer interface {
// contains filtered or unexported methods
}
UnsafeStreamingServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamingServer will result in compilation errors.