models

Documentation

Index

• Constants
• type ExceptionCode
• type Result
  • func NewResult(id int64, status Status) Result
  • func (p *Result) GetId() int64
  • func (p *Result) GetStatus() Status
  • func (p *Result) SetId(id int64)
  • func (p *Result) SetStatus(status Status)
• type Segment
• type SegmentBuffer
• type SegmentBufferView
• type Status

Constants

const (
	EXCEPTION_ID_IDCACHE_INIT_FALSE    ExceptionCode = -1
	EXCEPTION_ID_KEY_NOT_EXISTS                      = -2
	EXCEPTION_ID_TWO_SEGMENTS_ARE_NULL               = -3
)

Types

type ExceptionCode

type ExceptionCode int

type Result

type Result struct {
	Id     int64  `json:"id"`
	Status Status `json:"status"`
}

func NewResult

func NewResult(id int64, status Status) Result

func (*Result) GetId

func (p *Result) GetId() int64

func (*Result) GetStatus

func (p *Result) GetStatus() Status

func (*Result) SetId

func (p *Result) SetId(id int64)

func (*Result) SetStatus

func (p *Result) SetStatus(status Status)

type Segment

type Segment struct {
	Value *atomic.Int64
	Max   int64
	Step  int
}

type SegmentBuffer

type SegmentBuffer struct {
	Key           string
	RWMutex       *sync.RWMutex
	CurrentPos    int
	NextReady     bool
	InitOk        bool
	ThreadRunning *atomic.Bool
	Step          int
	MinStep       int
	UpdatedAt     int64
}

type SegmentBufferView

type SegmentBufferView struct {
	Key       string
	Value0    int64
	Step0     int
	Max0      int64
	Value1    int64
	Step1     int
	Max1      int64
	Pos       int
	NextReady bool
	InitOk    bool
}

type Status

type Status int

const (
	SUCCESS   Status = 0
	EXCEPTION Status = 1
)