sequence

Documentation

Index

• Constants
• type EtcdSequencer
  • func NewEtcdSequencer(etcdUrls string, metaFolder string) (*EtcdSequencer, error)
  • func (es *EtcdSequencer) GetMax() uint64
  • func (es *EtcdSequencer) NextFileId(count uint64) uint64
  • func (es *EtcdSequencer) Peek() uint64
  • func (es *EtcdSequencer) SetMax(seenValue uint64)
• type MemorySequencer
  • func NewMemorySequencer() (m *MemorySequencer)
  • func (m *MemorySequencer) NextFileId(count uint64) uint64
  • func (m *MemorySequencer) Peek() uint64
  • func (m *MemorySequencer) SetMax(seenValue uint64)
• type Sequencer

Constants

const (
	// EtcdKeyPrefix                   = "/seaweedfs"
	EtcdKeySequence                 = "/master/sequence"
	EtcdContextTimeoutSecond        = 100 * time.Second
	DefaultEtcdSteps         uint64 = 500 // internal counter
	SequencerFileName               = "sequencer.dat"
	FileMaxSequenceLength           = 128
)

Types

type EtcdSequencer

type EtcdSequencer struct {
	// contains filtered or unexported fields
}

func NewEtcdSequencer

func NewEtcdSequencer(etcdUrls string, metaFolder string) (*EtcdSequencer, error)

func (*EtcdSequencer) GetMax

func (es *EtcdSequencer) GetMax() uint64

func (*EtcdSequencer) NextFileId

func (es *EtcdSequencer) NextFileId(count uint64) uint64

func (*EtcdSequencer) Peek

func (es *EtcdSequencer) Peek() uint64

func (*EtcdSequencer) SetMax

func (es *EtcdSequencer) SetMax(seenValue uint64)

* instead of collecting the max value from volume server, the max value should be saved in local config file and ETCD cluster

type MemorySequencer

type MemorySequencer struct {
	// contains filtered or unexported fields
}

just for testing

func NewMemorySequencer

func NewMemorySequencer() (m *MemorySequencer)

func (*MemorySequencer) NextFileId

func (m *MemorySequencer) NextFileId(count uint64) uint64

func (*MemorySequencer) Peek

func (m *MemorySequencer) Peek() uint64

func (*MemorySequencer) SetMax

func (m *MemorySequencer) SetMax(seenValue uint64)

type Sequencer

type Sequencer interface {
	NextFileId(count uint64) uint64
	SetMax(uint64)
	Peek() uint64
}