status

Documentation

Index

• Constants
• Variables
• type ActionRow
• type ActionRowStatus
• type AsyncStatus
  • func (status *AsyncStatus) Cancel(command string, err error) error
  • func (status *AsyncStatus) CancelAll(cancelMsg string)
  • func (status *AsyncStatus) CheckCommandInProgress(command string) bool
  • func (status *AsyncStatus) GetContextWithCancel(commandId int) (context.Context, context.CancelFunc, error)
  • func (status *AsyncStatus) GetStatus(current bool, filter string, last int) []ActionRowStatus
  • func (status *AsyncStatus) InProgress() bool
  • func (status *AsyncStatus) Start(command string) (int, context.Context)
  • func (status *AsyncStatus) Stop(commandId int, err error)

Constants

const (
	InProgressStatus = "in progress"
	SuccessStatus    = "success"
	CancelStatus     = "cancel"
	ErrorStatus      = "error"
)

const NotFromAPI = int(-1)

Variables

var Current = &AsyncStatus{
	log: apexLog.WithField("logger", "status"),
}

Types

type ActionRow

type ActionRow struct {
	ActionRowStatus
	Ctx    context.Context
	Cancel context.CancelFunc
}

type ActionRowStatus

type ActionRowStatus struct {
	Command string `json:"command"`
	Status  string `json:"status"`
	Start   string `json:"start,omitempty"`
	Finish  string `json:"finish,omitempty"`
	Error   string `json:"error,omitempty"`
}

type AsyncStatus

type AsyncStatus struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*AsyncStatus) Cancel

func (status *AsyncStatus) Cancel(command string, err error) error

func (*AsyncStatus) CancelAll

func (status *AsyncStatus) CancelAll(cancelMsg string)

func (*AsyncStatus) CheckCommandInProgress

func (status *AsyncStatus) CheckCommandInProgress(command string) bool

func (*AsyncStatus) GetContextWithCancel

func (status *AsyncStatus) GetContextWithCancel(commandId int) (context.Context, context.CancelFunc, error)

func (*AsyncStatus) GetStatus

func (status *AsyncStatus) GetStatus(current bool, filter string, last int) []ActionRowStatus

func (*AsyncStatus) InProgress

func (status *AsyncStatus) InProgress() bool

InProgress any .Status == InProgressStatus command shall return true, https://github.com/Altinity/clickhouse-backup/issues/827

func (*AsyncStatus) Start

func (status *AsyncStatus) Start(command string) (int, context.Context)

func (*AsyncStatus) Stop

func (status *AsyncStatus) Stop(commandId int, err error)