util

Documentation

Index

• Constants
• func Docker(stdout, stderr io.Writer, stdin io.Reader, args ...string) error
• func DockerRun(stdout, stderr io.Writer, stdin io.Reader, image string, ...) error
• func ExecCmd(stdout, stderr io.Writer, stdin io.Reader, cmd string, args ...string) error
• func ExecOutput(stdin io.Reader, cmd string, args ...string) (string, error)
• func MarshalBytes(pb proto.Message) ([]byte, error)
• func MarshalStruct(m proto.Message) (*structpb.Struct, error)
• func RetryOn500(retryable func() error) error
• func RetryOnFunc(retryable func() error, retryIf func(err error) bool, opts ...retry.Option) error
• func SplitImageRef(ref string) (string, string, error)
• func Tar(src string, writers ...io.Writer) error
• func UnmarshalBytes(b []byte, pb proto.Message) error
• func UnmarshalStruct(s *structpb.Struct, m proto.Message) error
• func Untar(dst string, r io.Reader) error

Constants

const (
	WasmFilterName = "envoy.filters.http.wasm"
)

Functions

func Docker

func Docker(stdout, stderr io.Writer, stdin io.Reader, args ...string) error

func DockerRun

func DockerRun(stdout, stderr io.Writer, stdin io.Reader, image string, runArgs, imageArgs []string) error

func ExecCmd

func ExecCmd(stdout, stderr io.Writer, stdin io.Reader, cmd string, args ...string) error

func ExecOutput

func ExecOutput(stdin io.Reader, cmd string, args ...string) (string, error)

func MarshalBytes

func MarshalBytes(pb proto.Message) ([]byte, error)

func MarshalStruct

func MarshalStruct(m proto.Message) (*structpb.Struct, error)

func RetryOn500

func RetryOn500(retryable func() error) error

add some retry logic here as some registries can be flaky

func RetryOnFunc

func RetryOnFunc(retryable func() error, retryIf func(err error) bool, opts ...retry.Option) error

add some retry logic here as some registries can be flaky

func SplitImageRef

func SplitImageRef(ref string) (string, string, error)

splits a ref into the repo and tag if tag is empty, returns "latest"

func Tar

func Tar(src string, writers ...io.Writer) error

Tar takes a source and variable writers and walks 'source' writing each file found to the tar writer; the purpose for accepting multiple writers is to allow for multiple outputs (for example a file, or md5 hash)

func UnmarshalBytes

func UnmarshalBytes(b []byte, pb proto.Message) error

func UnmarshalStruct

func UnmarshalStruct(s *structpb.Struct, m proto.Message) error

func Untar

func Untar(dst string, r io.Reader) error

Untar takes a destination path and a reader; a tar reader loops over the tarfile creating the file structure at 'dst' along the way, and writing any files