etcd

Documentation

Index

• type EtcdSequencer
  • func NewEtcdSequencer() *EtcdSequencer
  • func (e *EtcdSequencer) Close() error
  • func (e *EtcdSequencer) GetNextId(req *sequencer.GetNextIdRequest) (*sequencer.GetNextIdResponse, error)
  • func (e *EtcdSequencer) GetSegment(req *sequencer.GetSegmentRequest) (support bool, result *sequencer.GetSegmentResponse, err error)
  • func (e *EtcdSequencer) Init(config sequencer.Configuration) error
  • func (e *EtcdSequencer) OnLogLevelChanged(level logger.LogLevel)

Types

type EtcdSequencer

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

func NewEtcdSequencer

func NewEtcdSequencer() *EtcdSequencer

EtcdSequencer returns a new etcd sequencer

func (*EtcdSequencer) Close

func (e *EtcdSequencer) Close() error

func (*EtcdSequencer) GetNextId

func (e *EtcdSequencer) GetNextId(req *sequencer.GetNextIdRequest) (*sequencer.GetNextIdResponse, error)

func (*EtcdSequencer) GetSegment

func (e *EtcdSequencer) GetSegment(req *sequencer.GetSegmentRequest) (support bool, result *sequencer.GetSegmentResponse, err error)

func (*EtcdSequencer) Init

func (e *EtcdSequencer) Init(config sequencer.Configuration) error

func (*EtcdSequencer) OnLogLevelChanged

func (e *EtcdSequencer) OnLogLevelChanged(level logger.LogLevel)