helpers

Oct 7, 2024

Changes in this version

type Args

+ DisOrder bool

May 9, 2024

Changes in this version

+ func CPUInfo() string

+ func MemoryInfo() string

+ func OSInfo() string

+ func PrintDiskUsage(dir string, maxDepth, curDepth int)

Oct 17, 2023

Changes in this version

+ func ListKeys(serverAddress string, prefix string) (map[string]*databasev1.Node, error)

Nov 5, 2022

Changes in this version

+ func HTTPHealthCheck(addr string) func() error

+ func TimeRange(args Args, shardContext SharedContext) *model_v1.TimeRange

+ func UnmarshalYAML(ii []byte, m proto.Message)

+ type Args struct

+ Begin *timestamppb.Timestamp

+ Duration time.Duration

+ End *timestamppb.Timestamp

+ Input string

+ Offset time.Duration

+ Want string

+ WantEmpty bool

+ WantErr bool

+ type SharedContext struct

+ BaseTime time.Time

+ Connection *grpclib.ClientConn

Jun 2, 2022

Changes in this version

+ var ErrServiceUnhealthy = errors.New("service is unhealthy")

+ func HealthCheck(addr string, connTimeout time.Duration, rpcTimeout time.Duration) func() error

+ type FailInterceptor struct

+ func NewFailInterceptor(fail types.GomegaFailHandler) *FailInterceptor

+ func (f *FailInterceptor) DidFail() bool

+ func (f *FailInterceptor) Fail(message string, callerSkip ...int)

+ func (f *FailInterceptor) Reset()