record

Documentation

Index

• type Block
• type Eventbus
  • func (b *Eventbus) ReadableLog() []*Eventlog
  • func (b *Eventbus) WritableLog() []*Eventlog
• type Eventlog
  • func (l *Eventlog) Readable() bool
  • func (l *Eventlog) Writable() bool
• type LogMode
  • func (m LogMode) Perm() LogMode
  • func (m LogMode) Readable() bool
  • func (m LogMode) Writable() bool
• type Segment
  • func (s *Segment) GetLeaderEndpoint() string

Types

type Block

type Block struct {
	ID       uint64
	Endpoint string
}

type Eventbus

type Eventbus struct {
	Name string
	Logs []*Eventlog
}

func (*Eventbus) ReadableLog

func (b *Eventbus) ReadableLog() []*Eventlog

ReadableLog return all readable logs.

func (*Eventbus) WritableLog

func (b *Eventbus) WritableLog() []*Eventlog

WritableLog return all writable logs.

type Eventlog

type Eventlog struct {
	ID   uint64
	Mode LogMode
}

func (*Eventlog) Readable

func (l *Eventlog) Readable() bool

func (*Eventlog) Writable

func (l *Eventlog) Writable() bool

type LogMode

type LogMode uint32

const (
	PremWrite LogMode = 1 << 1
	PremRead  LogMode = 1 << 2
)

const (
	ModePerm LogMode = 07
)

func (LogMode) Perm

func (m LogMode) Perm() LogMode

func (LogMode) Readable

func (m LogMode) Readable() bool

func (LogMode) Writable

func (m LogMode) Writable() bool

type Segment

type Segment struct {
	ID               uint64
	StartOffset      int64
	EndOffset        int64
	Writable         bool
	FirstEventBornAt time.Time
	LastEventBornAt  time.Time

	Blocks        map[uint64]*Block
	LeaderBlockID uint64
}

func (*Segment) GetLeaderEndpoint

func (s *Segment) GetLeaderEndpoint() string