store

package
v0.19.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 23, 2025 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

View Source
const ImageTagKey = "dagger.store.tag"

Variables

View Source
var (
	ErrInvalidLengthBasic        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBasic          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBasic = fmt.Errorf("proto: unexpected end of group")
)
View Source
var BasicStore_serviceDesc = _BasicStore_serviceDesc //nolint:staticcheck

Functions

func NewImageLoaderAttachable

func NewImageLoaderAttachable(loader *imageload.Loader) (session.Attachable, error)

func RegisterBasicStoreServer

func RegisterBasicStoreServer(s *grpc.Server, srv BasicStoreServer)

Types

type BasicStoreClient

type BasicStoreClient interface {
	WriteTarball(ctx context.Context, opts ...grpc.CallOption) (BasicStore_WriteTarballClient, error)
	ReadTarball(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (BasicStore_ReadTarballClient, error)
}

BasicStoreClient is the client API for BasicStore service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewBasicStoreClient

func NewBasicStoreClient(cc *grpc.ClientConn) BasicStoreClient

type BasicStoreServer

type BasicStoreServer interface {
	WriteTarball(BasicStore_WriteTarballServer) error
	ReadTarball(*emptypb.Empty, BasicStore_ReadTarballServer) error
}

BasicStoreServer is the server API for BasicStore service.

type BasicStore_ReadTarballClient added in v0.18.17

type BasicStore_ReadTarballClient interface {
	Recv() (*Data, error)
	grpc.ClientStream
}

type BasicStore_ReadTarballServer added in v0.18.17

type BasicStore_ReadTarballServer interface {
	Send(*Data) error
	grpc.ServerStream
}

type BasicStore_WriteTarballClient added in v0.19.3

type BasicStore_WriteTarballClient interface {
	Send(*Data) error
	CloseAndRecv() (*emptypb.Empty, error)
	grpc.ClientStream
}

type BasicStore_WriteTarballServer added in v0.19.3

type BasicStore_WriteTarballServer interface {
	SendAndClose(*emptypb.Empty) error
	Recv() (*Data, error)
	grpc.ServerStream
}

type Data

type Data struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Data) Descriptor

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

func (*Data) Equal

func (this *Data) Equal(that interface{}) bool

func (*Data) GetData

func (m *Data) GetData() []byte

func (*Data) GoString

func (this *Data) GoString() string

func (*Data) Marshal

func (m *Data) Marshal() (dAtA []byte, err error)

func (*Data) MarshalTo

func (m *Data) MarshalTo(dAtA []byte) (int, error)

func (*Data) MarshalToSizedBuffer

func (m *Data) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Data) ProtoMessage

func (*Data) ProtoMessage()

func (*Data) Reset

func (m *Data) Reset()

func (*Data) Size

func (m *Data) Size() (n int)

func (*Data) String

func (this *Data) String() string

func (*Data) Unmarshal

func (m *Data) Unmarshal(dAtA []byte) error

func (*Data) XXX_DiscardUnknown

func (m *Data) XXX_DiscardUnknown()

func (*Data) XXX_Marshal

func (m *Data) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Data) XXX_Merge

func (m *Data) XXX_Merge(src proto.Message)

func (*Data) XXX_Size

func (m *Data) XXX_Size() int

func (*Data) XXX_Unmarshal

func (m *Data) XXX_Unmarshal(b []byte) error

type TarballReader

type TarballReader struct {
	ReadF  func() (*Data, error)
	CloseF func() error
	// contains filtered or unexported fields
}

func (*TarballReader) Close added in v0.18.17

func (pio *TarballReader) Close() error

func (*TarballReader) Read

func (pio *TarballReader) Read(p []byte) (n int, err error)

type TarballWriter

type TarballWriter struct {
	SendF  func(*Data) error
	CloseF func() error
}

func (*TarballWriter) Close

func (pio *TarballWriter) Close() error

func (*TarballWriter) Write

func (pio *TarballWriter) Write(p []byte) (n int, err error)

type UnimplementedBasicStoreServer

type UnimplementedBasicStoreServer struct {
}

UnimplementedBasicStoreServer can be embedded to have forward compatible implementations.

func (*UnimplementedBasicStoreServer) ReadTarball added in v0.18.17

func (*UnimplementedBasicStoreServer) WriteTarball added in v0.19.3

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL