store

package
v0.19.7 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2025 License: Apache-2.0 Imports: 32 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 BasicStoreProxy added in v0.19.7 

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

func NewBasicStoreProxy added in v0.19.7 

func NewBasicStoreProxy(client BasicStoreClient) BasicStoreProxy

func (BasicStoreProxy) ReadTarball added in v0.19.7 

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

func (BasicStoreProxy) Register added in v0.19.7 

func (p BasicStoreProxy) Register(server *grpc.Server)

func (BasicStoreProxy) WriteTarball added in v0.19.7 

func (p BasicStoreProxy) WriteTarball(srv BasicStore_WriteTarballServer) error

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.0 

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

type BasicStore_WriteTarballServer added in v0.19.0 

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

type ContentProxy added in v0.19.7 

type ContentProxy struct {
	contentapi.UnimplementedContentServer
	// contains filtered or unexported fields
}

func NewContentProxy added in v0.19.7 

func NewContentProxy(client contentapi.ContentClient) ContentProxy

func (ContentProxy) Abort added in v0.19.7 

func (p ContentProxy) Abort(ctx context.Context, req *contentapi.AbortRequest) (*emptypb.Empty, error)

func (ContentProxy) Delete added in v0.19.7 

func (p ContentProxy) Delete(ctx context.Context, req *contentapi.DeleteContentRequest) (*emptypb.Empty, error)

func (ContentProxy) Info added in v0.19.7 

func (p ContentProxy) Info(ctx context.Context, req *contentapi.InfoRequest) (*contentapi.InfoResponse, error)

func (ContentProxy) List added in v0.19.7 

func (p ContentProxy) List(req *contentapi.ListContentRequest, srv contentapi.Content_ListServer) error

func (ContentProxy) ListStatuses added in v0.19.7 

func (p ContentProxy) ListStatuses(ctx context.Context, req *contentapi.ListStatusesRequest) (*contentapi.ListStatusesResponse, error)

func (ContentProxy) Read added in v0.19.7 

func (p ContentProxy) Read(req *contentapi.ReadContentRequest, srv contentapi.Content_ReadServer) error

func (ContentProxy) Register added in v0.19.7 

func (p ContentProxy) Register(server *grpc.Server)

func (ContentProxy) Status added in v0.19.7 

func (p ContentProxy) Status(ctx context.Context, req *contentapi.StatusRequest) (*contentapi.StatusResponse, error)

func (ContentProxy) Update added in v0.19.7 

func (p ContentProxy) Update(ctx context.Context, req *contentapi.UpdateRequest) (*contentapi.UpdateResponse, error)

func (ContentProxy) Write added in v0.19.7 

func (p ContentProxy) Write(srv contentapi.Content_WriteServer) error

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 ImagesProxy added in v0.19.7 

type ImagesProxy struct {
	imagesapi.UnimplementedImagesServer
	// contains filtered or unexported fields
}

func NewImagesProxy added in v0.19.7 

func NewImagesProxy(client imagesapi.ImagesClient) ImagesProxy

func (ImagesProxy) Create added in v0.19.7 

func (p ImagesProxy) Create(ctx context.Context, req *imagesapi.CreateImageRequest) (*imagesapi.CreateImageResponse, error)

func (ImagesProxy) Delete added in v0.19.7 

func (p ImagesProxy) Delete(ctx context.Context, req *imagesapi.DeleteImageRequest) (*emptypb.Empty, error)

func (ImagesProxy) Get added in v0.19.7 

func (p ImagesProxy) Get(ctx context.Context, req *imagesapi.GetImageRequest) (*imagesapi.GetImageResponse, error)

func (ImagesProxy) List added in v0.19.7 

func (p ImagesProxy) List(ctx context.Context, req *imagesapi.ListImagesRequest) (*imagesapi.ListImagesResponse, error)

func (ImagesProxy) Register added in v0.19.7 

func (p ImagesProxy) Register(server *grpc.Server)

func (ImagesProxy) Update added in v0.19.7 

func (p ImagesProxy) Update(ctx context.Context, req *imagesapi.UpdateImageRequest) (*imagesapi.UpdateImageResponse, error)

type LeasesProxy added in v0.19.7 

type LeasesProxy struct {
	leasesapi.UnimplementedLeasesServer
	// contains filtered or unexported fields
}

func NewLeasesProxy added in v0.19.7 

func NewLeasesProxy(client leasesapi.LeasesClient) LeasesProxy

func (LeasesProxy) AddResource added in v0.19.7 

func (p LeasesProxy) AddResource(ctx context.Context, req *leasesapi.AddResourceRequest) (*emptypb.Empty, error)

func (LeasesProxy) Create added in v0.19.7 

func (p LeasesProxy) Create(ctx context.Context, req *leasesapi.CreateRequest) (*leasesapi.CreateResponse, error)

func (LeasesProxy) Delete added in v0.19.7 

func (p LeasesProxy) Delete(ctx context.Context, req *leasesapi.DeleteRequest) (*emptypb.Empty, error)

func (LeasesProxy) DeleteResource added in v0.19.7 

func (p LeasesProxy) DeleteResource(ctx context.Context, req *leasesapi.DeleteResourceRequest) (*emptypb.Empty, error)

func (LeasesProxy) List added in v0.19.7 

func (p LeasesProxy) List(ctx context.Context, req *leasesapi.ListRequest) (*leasesapi.ListResponse, error)

func (LeasesProxy) ListResources added in v0.19.7 

func (p LeasesProxy) ListResources(ctx context.Context, req *leasesapi.ListResourcesRequest) (*leasesapi.ListResourcesResponse, error)

func (LeasesProxy) Register added in v0.19.7 

func (p LeasesProxy) Register(server *grpc.Server)

type StoreProxy added in v0.19.7 

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

StoreProxy registers proxies for all store-related services so they can be forwarded over a session (used for scale-out).

func NewStoreProxy added in v0.19.7 

func NewStoreProxy(conn *grpc.ClientConn) StoreProxy

func (StoreProxy) Register added in v0.19.7 

func (p StoreProxy) Register(server *grpc.Server)

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) ReadTarball(req *emptypb.Empty, srv BasicStore_ReadTarballServer) error

func (*UnimplementedBasicStoreServer) WriteTarball added in v0.19.0 

func (*UnimplementedBasicStoreServer) WriteTarball(srv BasicStore_WriteTarballServer) 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.