package upload

buildkit – github.com/moby/buildkit/session/upload Index | Files | Directories

import "github.com/moby/buildkit/session/upload"

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]