Documentation
¶
Overview ¶
Package isolatedclient implements the API to communicate with the Isolated server and to process '.isolated' files.
Index ¶
- Constants
- type Client
- func (i *Client) Contains(c context.Context, items []*isolateservice.HandlersEndpointsV1Digest) (out []*PushState, err error)
- func (i *Client) Fetch(c context.Context, digest isolated.HexDigest, dest io.Writer) error
- func (i *Client) Hash() crypto.Hash
- func (i *Client) Push(c context.Context, state *PushState, source Source) (err error)
- func (i *Client) ServerCapabilities(c context.Context) (*isolateservice.HandlersEndpointsV1ServerDetails, error)
- type CloudStorage
- type Flags
- type Option
- type PushState
- type Source
Constants ¶
const DefaultNamespace = "default-gzip"
DefaultNamespace is the namespace that should be used with the New function.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client is a client to an isolated server.
func (*Client) Contains ¶
func (i *Client) Contains(c context.Context, items []*isolateservice.HandlersEndpointsV1Digest) (out []*PushState, err error)
Contains looks up cache presence on the server of multiple items.
The returned list is in the same order as 'items', with entries nil for items that were present.
func (*Client) ServerCapabilities ¶
func (i *Client) ServerCapabilities(c context.Context) (*isolateservice.HandlersEndpointsV1ServerDetails, error)
ServerCapabilities returns the server details.
type CloudStorage ¶
type CloudStorage interface {
// Fetch is a handler for retrieving specified content from GCS and storing
// the response in the provided destination buffer.
Fetch(context.Context, *Client, isolateservice.HandlersEndpointsV1RetrievedContent, io.Writer) error
// Push is a handler for pushing content from provided buffer to GCS.
Push(context.Context, *Client, isolateservice.HandlersEndpointsV1PreuploadStatus, Source) error
}
CloudStorage is the interface for clients to fetch from and push to GCS storage.
type Flags ¶
Flags contains values parsed from command line arguments.
type Option ¶
type Option func(*Client)
func WithAnonymousClient ¶
WithAnonymousClient returns Option that sets client which will be used by gcsHandler.
func WithAuthClient ¶
WithAuthClient returns Option that sets client with authentication sufficient to talk to Isolate server (OAuth tokens with 'email' scope).
func WithGCSHandler ¶
func WithGCSHandler(gcs CloudStorage) Option
func WithNamespace ¶
func WithRetryFactory ¶
func WithUserAgent ¶
type PushState ¶
type PushState struct {
// contains filtered or unexported fields
}
PushState is per-item state passed from IsolateServer.Contains() to IsolateServer.Push().
Its content is implementation specific.
type Source ¶
type Source func() (io.ReadCloser, error)
Source is a generator method to return source data. A generated Source must be Closed before the generator is called again.
func NewBytesSource ¶
NewBytesSource returns a Source implementation that reads from the supplied byte slice.
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package isolatedfake implements an in-process fake Isolated server for integration testing.
|
Package isolatedfake implements an in-process fake Isolated server for integration testing. |