upload

Documentation

Index

• Constants
• Variables
• func RegisterUploadServer(s grpc.ServiceRegistrar, srv UploadServer)
• type BytesMessage
  • func (m *BytesMessage) CloneMessageVT() proto.Message
  • func (m *BytesMessage) CloneVT() *BytesMessage
  • func (*BytesMessage) Descriptor() ([]byte, []int)
  • func (this *BytesMessage) EqualMessageVT(thatMsg proto.Message) bool
  • func (this *BytesMessage) EqualVT(that *BytesMessage) bool
  • func (x *BytesMessage) GetData() []byte
  • func (m *BytesMessage) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *BytesMessage) MarshalToVT(dAtA []byte) (int, error)
  • func (m *BytesMessage) MarshalVT() (dAtA []byte, err error)
  • func (*BytesMessage) ProtoMessage()
  • func (x *BytesMessage) ProtoReflect() protoreflect.Message
  • func (x *BytesMessage) Reset()
  • func (m *BytesMessage) SizeVT() (n int)
  • func (x *BytesMessage) String() string
  • func (m *BytesMessage) UnmarshalVT(dAtA []byte) error
• type UnimplementedUploadServer
  • func (UnimplementedUploadServer) Pull(grpc.BidiStreamingServer[BytesMessage, BytesMessage]) error
• type UnsafeUploadServer
• type Upload
  • func New(ctx context.Context, c session.Caller, url *url.URL) (*Upload, error)
  • func (u *Upload) WriteTo(w io.Writer) (int64, error)
• type UploadClient
  • func NewUploadClient(cc grpc.ClientConnInterface) UploadClient
• type UploadServer
• type Upload_PullClient
• type Upload_PullServer

Constants

const (
	Upload_Pull_FullMethodName = "/moby.upload.v1.Upload/Pull"
)

Variables

var File_github_com_moby_buildkit_session_upload_upload_proto protoreflect.FileDescriptor

var Upload_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "moby.upload.v1.Upload",
	HandlerType: (*UploadServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Pull",
			Handler:       _Upload_Pull_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "github.com/moby/buildkit/session/upload/upload.proto",
}

Upload_ServiceDesc is the grpc.ServiceDesc for Upload service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterUploadServer

func RegisterUploadServer(s grpc.ServiceRegistrar, srv UploadServer)

Types

type BytesMessage

type BytesMessage struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

BytesMessage contains a chunk of byte data

func (*BytesMessage) CloneMessageVT

func (m *BytesMessage) CloneMessageVT() proto.Message

func (*BytesMessage) CloneVT

func (m *BytesMessage) CloneVT() *BytesMessage

func (*BytesMessage) Descriptor

func (*BytesMessage) Descriptor() ([]byte, []int)

Deprecated: Use BytesMessage.ProtoReflect.Descriptor instead.

func (*BytesMessage) EqualMessageVT

func (this *BytesMessage) EqualMessageVT(thatMsg proto.Message) bool

func (*BytesMessage) EqualVT

func (this *BytesMessage) EqualVT(that *BytesMessage) bool

func (*BytesMessage) GetData

func (x *BytesMessage) GetData() []byte

func (*BytesMessage) MarshalToSizedBufferVT

func (m *BytesMessage) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BytesMessage) MarshalToVT

func (m *BytesMessage) MarshalToVT(dAtA []byte) (int, error)

func (*BytesMessage) MarshalVT

func (m *BytesMessage) MarshalVT() (dAtA []byte, err error)

func (*BytesMessage) ProtoMessage

func (*BytesMessage) ProtoMessage()

func (*BytesMessage) ProtoReflect

func (x *BytesMessage) ProtoReflect() protoreflect.Message

func (*BytesMessage) Reset

func (x *BytesMessage) Reset()

func (*BytesMessage) SizeVT

func (m *BytesMessage) SizeVT() (n int)

func (*BytesMessage) String

func (x *BytesMessage) String() string

func (*BytesMessage) UnmarshalVT

func (m *BytesMessage) UnmarshalVT(dAtA []byte) error

type UnimplementedUploadServer

type UnimplementedUploadServer struct{}

UnimplementedUploadServer should 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 (UnimplementedUploadServer) Pull

func (UnimplementedUploadServer) Pull(grpc.BidiStreamingServer[BytesMessage, BytesMessage]) error

type UnsafeUploadServer

type UnsafeUploadServer interface {
	// contains filtered or unexported methods
}

UnsafeUploadServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UploadServer will result in compilation errors.

type Upload

type Upload struct {
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, c session.Caller, url *url.URL) (*Upload, error)

func (*Upload) WriteTo

func (u *Upload) WriteTo(w io.Writer) (int64, error)

type UploadClient

type UploadClient interface {
	Pull(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[BytesMessage, BytesMessage], error)
}

UploadClient is the client API for Upload 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 NewUploadClient

func NewUploadClient(cc grpc.ClientConnInterface) UploadClient

type UploadServer

type UploadServer interface {
	Pull(grpc.BidiStreamingServer[BytesMessage, BytesMessage]) error
}

UploadServer is the server API for Upload service. All implementations should embed UnimplementedUploadServer for forward compatibility.

type Upload_PullClient

type Upload_PullClient = grpc.BidiStreamingClient[BytesMessage, BytesMessage]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Upload_PullServer

type Upload_PullServer = grpc.BidiStreamingServer[BytesMessage, BytesMessage]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.