status

Documentation

Index

• type GlobalStatus
  • func NewGlobalStatus(limit int32) *GlobalStatus
  • func (gs *GlobalStatus) AddReadError(err *joberror.JobError)
  • func (gs *GlobalStatus) AddWriteError(err *joberror.JobError)
  • func (gs *GlobalStatus) HasErrors() bool
  • func (gs *GlobalStatus) PrintResult(w io.Writer, schema *typedef.Schema, version string)
  • func (gs *GlobalStatus) PrintResultAsJSON(w io.Writer, schema *typedef.Schema, version string) error
  • func (gs *GlobalStatus) String() string
• type Uint64
  • func (u *Uint64) MarshalJSON() ([]byte, error)

Types

type GlobalStatus

type GlobalStatus struct {
	Errors      *joberror.ErrorList `json:"errors,omitempty"`
	WriteOps    Uint64              `json:"write_ops"`
	WriteErrors Uint64              `json:"write_errors"`
	ReadOps     Uint64              `json:"read_ops"`
	ReadErrors  Uint64              `json:"read_errors"`
}

func NewGlobalStatus

func NewGlobalStatus(limit int32) *GlobalStatus

func (*GlobalStatus) AddReadError

func (gs *GlobalStatus) AddReadError(err *joberror.JobError)

func (*GlobalStatus) AddWriteError

func (gs *GlobalStatus) AddWriteError(err *joberror.JobError)

func (*GlobalStatus) HasErrors

func (gs *GlobalStatus) HasErrors() bool

func (*GlobalStatus) PrintResult

func (gs *GlobalStatus) PrintResult(w io.Writer, schema *typedef.Schema, version string)

func (*GlobalStatus) PrintResultAsJSON

func (gs *GlobalStatus) PrintResultAsJSON(w io.Writer, schema *typedef.Schema, version string) error

func (*GlobalStatus) String

func (gs *GlobalStatus) String() string

type Uint64

type Uint64 struct {
	atomic.Uint64
}

func (*Uint64) MarshalJSON

func (u *Uint64) MarshalJSON() ([]byte, error)