cacheutils

package

v2.0.0-...-6fac617 Latest Latest Go to latest Published: Jan 25, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kubeflow/pipelines

Documentation ¶

Index ¶

Constants
func GenerateCacheKey(inputs *pipelinespec.ExecutorInput_Inputs, ...) (*cachekey.CacheKey, error)
func GenerateFingerPrint(cacheKey *cachekey.CacheKey) (string, error)
type Client
- func NewClient() (*Client, error)
- func (c *Client) CreateExecutionCache(ctx context.Context, task *api.Task) error
- func (c *Client) GetExecutionCache(fingerPrint, pipelineName, namespace string) (string, error)

Constants ¶

View Source

const (
	// MaxGRPCMessageSize contains max grpc message size supported by the client
	MaxClientGRPCMessageSize = 100 * 1024 * 1024
)

Variables ¶

This section is empty.

Functions ¶

func GenerateCacheKey ¶

func GenerateCacheKey(
	inputs *pipelinespec.ExecutorInput_Inputs,
	outputs *pipelinespec.ExecutorInput_Outputs,
	outputParametersTypeMap map[string]string,
	cmdArgs []string, image string) (*cachekey.CacheKey, error)

func GenerateFingerPrint ¶

func GenerateFingerPrint(cacheKey *cachekey.CacheKey) (string, error)

Types ¶

type Client ¶

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

Client is an KFP service client.

func NewClient ¶

func NewClient() (*Client, error)

NewClient creates a Client.

func (*Client) CreateExecutionCache ¶

func (c *Client) CreateExecutionCache(ctx context.Context, task *api.Task) error

func (*Client) GetExecutionCache ¶

func (c *Client) GetExecutionCache(fingerPrint, pipelineName, namespace string) (string, error)

Source Files ¶

View all Source files

cache.go

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