utils

Aug 12, 2022

Changes in this version

+ func GetRandomPort() string

+ func IsPortOpen(t *testing.T, port string) bool

+ func MustRandomPort(t *testing.T) string

Jun 23, 2022

Changes in this version

+ func HashReport(ctx types.ReportContext, r types.Report) ([]byte, error)

+ func RawReportContext(repctx types.ReportContext) [3][32]byte

+ type Subprocesses struct

+ func (s *Subprocesses) Go(f func())

+ func (s *Subprocesses) Wait()

Jun 13, 2022

Changes in this version

type Duration

+ func MustNewDuration(d time.Duration) *Duration

+ type URL url.URL

+ func MustParseURL(s string) *URL

+ func ParseURL(s string) (*URL, error)

+ func (u *URL) MarshalText() ([]byte, error)

+ func (u *URL) UnmarshalText(input []byte) error

May 16, 2022

Changes in this version

+ func ContextFromChan(chStop <-chan struct{}) (context.Context, context.CancelFunc)

+ func WithJitter(d time.Duration) time.Duration

+ type Duration struct

+ func NewDuration(d time.Duration) (Duration, error)

+ func (d *Duration) Scan(v interface{}) (err error)

+ func (d *Duration) UnmarshalJSON(input []byte) error

+ func (d *Duration) UnmarshalText(input []byte) error

+ func (d Duration) Duration() time.Duration

+ func (d Duration) MarshalJSON() ([]byte, error)

+ func (d Duration) MarshalText() ([]byte, error)

+ func (d Duration) String() string

+ func (d Duration) Value() (driver.Value, error)

+ type StartStopOnce struct

+ func (s *StartStopOnce) Healthy() error

+ func (s *StartStopOnce) IfNotStopped(f func()) (ok bool)

+ func (s *StartStopOnce) IfStarted(f func()) (ok bool)

+ func (s *StartStopOnce) Ready() error

+ func (s *StartStopOnce) StartOnce(name string, fn func() error) error

+ func (s *StartStopOnce) State() startStopOnceState

+ func (s *StartStopOnce) StopOnce(name string, fn func() error) error