load

Documentation

Index

• type Action
  • func ParseAction(actionStr string) (Action, error)
  • func ParseGenerateAction(args []string) (Action, error)
  • func ParseLoadDigestsAction(args []string) (Action, error)
  • func ParseReadAction(args []string) (Action, error)
  • func ParseSaveDigestsAction(args []string) (Action, error)
• type ActionContext
  • func (ac *ActionContext) AddKnownDigest(digest *remote_pb.Digest, present bool)
  • func (ac *ActionContext) GetKnownDigests(presence bool) []*remote_pb.Digest

Types

type Action

type Action interface {
	RunAction(actionContext *ActionContext) error
}

func ParseAction

func ParseAction(actionStr string) (Action, error)

func ParseGenerateAction

func ParseGenerateAction(args []string) (Action, error)

func ParseLoadDigestsAction

func ParseLoadDigestsAction(args []string) (Action, error)

func ParseReadAction

func ParseReadAction(args []string) (Action, error)

func ParseSaveDigestsAction

func ParseSaveDigestsAction(args []string) (Action, error)

type ActionContext

type ActionContext struct {
	// Go context for the current operation.
	Ctx context.Context

	// Clients to use to access the CAS.
	CasClient        remote_pb.ContentAddressableStorageClient
	BytestreamClient bytestream_pb.ByteStreamClient
	InstanceName     string
	MaxBatchBlobSize int64
	WriteChunkSize   int64

	// Map of a digest in string form to a bool representing whether it is known to be present or missing
	// in the CAS.
	KnownDigests map[string]bool
	// contains filtered or unexported fields
}

func (*ActionContext) AddKnownDigest

func (ac *ActionContext) AddKnownDigest(digest *remote_pb.Digest, present bool)

func (*ActionContext) GetKnownDigests

func (ac *ActionContext) GetKnownDigests(presence bool) []*remote_pb.Digest