store

package
v0.18.19 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const ImageTagKey = "dagger.imageload"

TODO: should be "dagger.store.tag" but breaks client<->server compat

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:stylecheck

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 {
	// TODO: rename when breaking client<->server compat
	// rpc WriteTarball(stream Data) returns (google.protobuf.Empty);
	LoadTarball(ctx context.Context, opts ...grpc.CallOption) (BasicStore_LoadTarballClient, 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 {
	// TODO: rename when breaking client<->server compat
	// rpc WriteTarball(stream Data) returns (google.protobuf.Empty);
	LoadTarball(BasicStore_LoadTarballServer) error
	ReadTarball(*emptypb.Empty, BasicStore_ReadTarballServer) error
}

BasicStoreServer is the server API for BasicStore service.

type BasicStore_LoadTarballClient 

type BasicStore_LoadTarballClient interface {
	Send(*Data) error
	CloseAndRecv() (*LoadResponse, error)
	grpc.ClientStream
}

type BasicStore_LoadTarballServer 

type BasicStore_LoadTarballServer interface {
	SendAndClose(*LoadResponse) error
	Recv() (*Data, error)
	grpc.ServerStream
}

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 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 LoadResponse 

type LoadResponse struct {
}

func (*LoadResponse) Descriptor 

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

func (*LoadResponse) Equal 

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

func (*LoadResponse) GoString 

func (this *LoadResponse) GoString() string

func (*LoadResponse) Marshal 

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

func (*LoadResponse) MarshalTo 

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

func (*LoadResponse) MarshalToSizedBuffer 

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

func (*LoadResponse) ProtoMessage 

func (*LoadResponse) ProtoMessage()

func (*LoadResponse) Reset 

func (m *LoadResponse) Reset()

func (*LoadResponse) Size 

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

func (*LoadResponse) String 

func (this *LoadResponse) String() string

func (*LoadResponse) Unmarshal 

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

func (*LoadResponse) XXX_DiscardUnknown 

func (m *LoadResponse) XXX_DiscardUnknown()

func (*LoadResponse) XXX_Marshal 

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

func (*LoadResponse) XXX_Merge 

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

func (*LoadResponse) XXX_Size 

func (m *LoadResponse) XXX_Size() int

func (*LoadResponse) XXX_Unmarshal 

func (m *LoadResponse) 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) LoadTarball 

func (*UnimplementedBasicStoreServer) LoadTarball(srv BasicStore_LoadTarballServer) error

func (*UnimplementedBasicStoreServer) ReadTarball added in v0.18.17 

func (*UnimplementedBasicStoreServer) ReadTarball(req *emptypb.Empty, srv BasicStore_ReadTarballServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.