state

Documentation

Index

• type TableSinkState
  • func (s *TableSinkState) CompareAndSwap(old, new TableSinkState) bool
  • func (s *TableSinkState) Load() TableSinkState
  • func (s *TableSinkState) Store(new TableSinkState)
  • func (s TableSinkState) String() string

Types

type TableSinkState

type TableSinkState int32

TableSinkState is state of the table sink.

const (
	TableSinkStateUnknown TableSinkState = iota
	// TableSinkSinking indicate that the table is sinking.
	TableSinkSinking
	// TableSinkStopping means the table sink is stopping, but not guaranteed yet.
	TableSinkStopping
	// TableSinkStopped means sink stop all works.
	TableSinkStopped
)

State for table sink

func (*TableSinkState) CompareAndSwap

func (s *TableSinkState) CompareAndSwap(old, new TableSinkState) bool

CompareAndSwap is just like sync/atomic.Atomic*.CompareAndSwap.

func (*TableSinkState) Load

func (s *TableSinkState) Load() TableSinkState

Load state. This is THREAD-SAFE.

func (*TableSinkState) Store

func (s *TableSinkState) Store(new TableSinkState)

Store state. This is THREAD-SAFE.

func (TableSinkState) String

func (s TableSinkState) String() string