cacheutils

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

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

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)