nodeservice

Documentation

Index

• Constants
• Variables
• func DownloadFromURL(digest utils.Digest, url string) ([]byte, error)
• type IndexClient
  • func (c IndexClient) Get(ctx context.Context, digest utils.Digest) ([]byte, error)
  • func (c IndexClient) Has(ctx context.Context, h utils.Digest) (bool, error)
• type Inner
  • func NewRemote(name string, url string, apiKey string) Inner
• type ObjectGetter
• type ObjectStore
• type Remote
  • func (s Remote) Get(ctx context.Context, digest utils.Digest) ([]byte, error)
  • func (s Remote) Has(ctx context.Context, digest utils.Digest) (bool, error)
  • func (s Remote) Put(ctx context.Context, size uint64, r io.Reader) (utils.Digest, error)
• type Sequence
  • func (s Sequence) Get(ctx context.Context, digest utils.Digest) ([]byte, error)
  • func (s Sequence) Has(ctx context.Context, digest utils.Digest) (bool, error)
  • func (s Sequence) Put(ctx context.Context, b []byte) (utils.Digest, error)

Constants

const (
	APIKeyHeader = "x-api-key"
)

Variables

var (
	ErrNotFound = fmt.Errorf("not found")
)

Functions

func DownloadFromURL

func DownloadFromURL(digest utils.Digest, url string) ([]byte, error)

Types

type IndexClient

type IndexClient struct {
	BaseURL string
}

func (IndexClient) Get

func (c IndexClient) Get(ctx context.Context, digest utils.Digest) ([]byte, error)

func (IndexClient) Has

func (c IndexClient) Has(ctx context.Context, h utils.Digest) (bool, error)

type Inner

type Inner struct {
	Name         string
	ObjectGetter ObjectGetter
}

func NewRemote

func NewRemote(name string, url string, apiKey string) Inner

type ObjectGetter

type ObjectGetter interface {
	Get(ctx context.Context, h utils.Digest) ([]byte, error)
	// TODO: GetMetadata
	Has(ctx context.Context, h utils.Digest) (bool, error)
}

type ObjectStore

type ObjectStore interface {
	ObjectGetter
	Put(ctx context.Context, b []byte) (utils.Digest, error)
}

type Remote

type Remote struct {
	APIURL string
	APIKey string
	GRPC   pb.EntClient
}

func (Remote) Get

func (s Remote) Get(ctx context.Context, digest utils.Digest) ([]byte, error)

func (Remote) Has

func (s Remote) Has(ctx context.Context, digest utils.Digest) (bool, error)

func (Remote) Put

func (s Remote) Put(ctx context.Context, size uint64, r io.Reader) (utils.Digest, error)

type Sequence

type Sequence struct {
	Inner []Inner
}

func (Sequence) Get

func (s Sequence) Get(ctx context.Context, digest utils.Digest) ([]byte, error)

func (Sequence) Has

func (s Sequence) Has(ctx context.Context, digest utils.Digest) (bool, error)

func (Sequence) Put

func (s Sequence) Put(ctx context.Context, b []byte) (utils.Digest, error)