rpcutil

Documentation

Overview

Package rpcutil provides utility methods to perform go-libp2p-gorpc calls, particularly gorpc.MultiCall().

Index

• func CheckErrs(errs []error) error
• func CopyEmptyStructToIfaces(in []struct{}) []interface{}
• func CopyIDSliceToIfaces(in [][]api.ID) []interface{}
• func CopyIDsToIfaces(in []api.ID) []interface{}
• func CopyPinInfoSliceToIfaces(in [][]api.PinInfo) []interface{}
• func CopyPinInfoToIfaces(in []api.PinInfo) []interface{}
• func CopyRepoGCSliceToIfaces(in []api.RepoGC) []interface{}
• func CtxsWithCancel(parent context.Context, n int) ([]context.Context, []context.CancelFunc)
• func CtxsWithTimeout(parent context.Context, n int, timeout time.Duration) ([]context.Context, []context.CancelFunc)
• func MultiCancel(cancels []context.CancelFunc)
• func RPCDiscardReplies(n int) []interface{}

Functions

func CheckErrs

func CheckErrs(errs []error) error

CheckErrs returns nil if all the errors in a slice are nil, otherwise it returns a single error formed by joining the error messages existing in the slice with a line-break.

func CopyEmptyStructToIfaces

func CopyEmptyStructToIfaces(in []struct{}) []interface{}

CopyEmptyStructToIfaces converts an empty struct slice to an empty interface slice using pointers to each elements of the original slice. Useful to handle gorpc.MultiCall() replies.

func CopyIDSliceToIfaces

func CopyIDSliceToIfaces(in [][]api.ID) []interface{}

CopyIDSliceToIfaces converts an api.ID slice of slices to an empty interface slice using pointers to each elements of the original slice. Useful to handle gorpc.MultiCall() replies.

func CopyIDsToIfaces

func CopyIDsToIfaces(in []api.ID) []interface{}

CopyIDsToIfaces converts an api.ID slice to an empty interface slice using pointers to each elements of the original slice. Useful to handle gorpc.MultiCall() replies.

func CopyPinInfoSliceToIfaces

func CopyPinInfoSliceToIfaces(in [][]api.PinInfo) []interface{}

CopyPinInfoSliceToIfaces converts an api.PinInfo slice of slices to an empty interface slice using pointers to each elements of the original slice. Useful to handle gorpc.MultiCall() replies.

func CopyPinInfoToIfaces

func CopyPinInfoToIfaces(in []api.PinInfo) []interface{}

CopyPinInfoToIfaces converts an api.PinInfo slice to an empty interface slice using pointers to each elements of the original slice. Useful to handle gorpc.MultiCall() replies.

func CopyRepoGCSliceToIfaces

func CopyRepoGCSliceToIfaces(in []api.RepoGC) []interface{}

CopyRepoGCSliceToIfaces converts an api.RepoGC slice to an empty interface slice using pointers to each elements of the original slice. Useful to handle gorpc.MultiCall() replies.

func CtxsWithCancel

func CtxsWithCancel(
	parent context.Context,
	n int,
) ([]context.Context, []context.CancelFunc)

CtxsWithCancel returns n cancellable contexts, derived from the given parent.

func CtxsWithTimeout

func CtxsWithTimeout(
	parent context.Context,
	n int,
	timeout time.Duration,
) ([]context.Context, []context.CancelFunc)

CtxsWithTimeout returns n contexts, derived from the given parent using the given timeout.

func MultiCancel

func MultiCancel(cancels []context.CancelFunc)

MultiCancel calls all the provided CancelFuncs. It is useful with "defer Multicancel()"

func RPCDiscardReplies

func RPCDiscardReplies(n int) []interface{}

RPCDiscardReplies returns a []interface{} slice made from a []struct{} slice of then given length. Useful for RPC methods which have no response types (so they use empty structs).