helpers

Documentation

Index

• func AddrFromPeer(remote *peer.Peer) (peerHost string)
• func ExtractTarGz(localPath string, r io.ReadCloser) error
• func FailIfMultiNodes(ctx context.Context, command string) error
• func Fatalf(message string, args ...interface{})
• func RemotePeer(ctx context.Context) (peerHost string)
• func Should(err error)
• func Warning(message string, args ...interface{})
• func WithCLIContext(ctx context.Context, f func(context.Context) error) error

Functions

func AddrFromPeer

func AddrFromPeer(remote *peer.Peer) (peerHost string)

AddrFromPeer extracts peer address from grpc Peer.

func ExtractTarGz

func ExtractTarGz(localPath string, r io.ReadCloser) error

ExtractTarGz extracts .tar.gz archive from r into filesystem under localPath.

nolint: gocyclo

func FailIfMultiNodes

func FailIfMultiNodes(ctx context.Context, command string) error

FailIfMultiNodes checks if ctx contains multi-node request metadata.

func Fatalf

func Fatalf(message string, args ...interface{})

Fatalf prints formatted message to stderr and aborts execution

func RemotePeer

func RemotePeer(ctx context.Context) (peerHost string)

RemotePeer parses remote peer address from grpc stream context.

func Should

func Should(err error)

Should panics if err != nil

Should is useful when error should never happen in customer environment, it can only be development error.

func Warning

func Warning(message string, args ...interface{})

Warning prints formatted message to stderr

func WithCLIContext

func WithCLIContext(ctx context.Context, f func(context.Context) error) error

WithCLIContext wraps function call to provide a context cancellable with ^C.