status

Documentation

Index

• Variables
• func BufferStatus(fill, capacity int) string
• type Set
  • func NewBlankSet() *Set
  • func NewSet(statuses []*Status) *Set
  • func (s *Set) Delimiter() string
  • func (s *Set) Display() []string
  • func (s *Set) Header() []string
  • func (s *Set) ToFile() []string
  • func (s *Set) UpdateViewport()
• type Status
  • func New(plan config.OperationPlan) *Status
  • func (s *Status) Display() []string
  • func (s *Status) SetError()
  • func (s *Status) SetNoop()
  • func (s *Status) SetWaiting()

Variables

var (
	EmptyBufferState = "○"
	FillBufferStates = []string{
		"◔",
		"◑",
		"◕",
		"●",
	}
)

BufferStates are single character "fullness" indicators of the buffer

Functions

func BufferStatus

func BufferStatus(fill, capacity int) string

Types

type Set

type Set struct {
	Statuses      []*Status
	ViewportWidth int
}

func NewBlankSet

func NewBlankSet() *Set

func NewSet

func NewSet(statuses []*Status) *Set

func (*Set) Delimiter

func (s *Set) Delimiter() string

Delimiter returns " Current Status " centered in a viewport wide list of ---- markers

func (*Set) Display

func (s *Set) Display() []string

func (*Set) Header

func (s *Set) Header() []string

func (*Set) ToFile

func (s *Set) ToFile() []string

func (*Set) UpdateViewport

func (s *Set) UpdateViewport()

type Status

type Status struct {
	Plan config.OperationPlan

	Description string
	Backfill    string
	Stream      string
	Rate        string
	// contains filtered or unexported fields
}

func New

func New(plan config.OperationPlan) *Status

func (*Status) Display

func (s *Status) Display() []string

func (*Status) SetError

func (s *Status) SetError()

SetError update description to indicate error status

func (*Status) SetNoop

func (s *Status) SetNoop()

SetNoop update description to indicate Noop

func (*Status) SetWaiting

func (s *Status) SetWaiting()

SetWaiting update description to indicate waiting status