cursor

Documentation

Index

• Constants
• type Cursor
  • func BeginningOfStream(stream string, server string) *Cursor
  • func CursorFromserialized(serialized string) (*Cursor, error)
  • func CursorFromserializedMust(serialized string) *Cursor
  • func ForOffsetQuery(stream string) *Cursor
  • func New(stream string, chunk int, offset int, server string) *Cursor
  • func (c *Cursor) IsAheadComparedTo(other *Cursor) bool
  • func (c *Cursor) OffsetString() string
  • func (c *Cursor) PositionEquals(other *Cursor) bool
  • func (c *Cursor) Serialize() string
  • func (c *Cursor) ToChunkPath() string
  • func (c *Cursor) ToChunkSafePath() string

Constants

const (
	NoServer      = ""
	UnknownServer = "?"
)

Types

type Cursor

type Cursor struct {
	Stream string
	Chunk  int
	Offset int
	Server string
}

func BeginningOfStream

func BeginningOfStream(stream string, server string) *Cursor

func CursorFromserialized

func CursorFromserialized(serialized string) (*Cursor, error)

stream:chunk:pos

/tenants/1:13:42

stream:chunk:pos:server

func CursorFromserializedMust

func CursorFromserializedMust(serialized string) *Cursor

func ForOffsetQuery

func ForOffsetQuery(stream string) *Cursor

func New

func New(stream string, chunk int, offset int, server string) *Cursor

func (*Cursor) IsAheadComparedTo

func (c *Cursor) IsAheadComparedTo(other *Cursor) bool

func (*Cursor) OffsetString

func (c *Cursor) OffsetString() string

for displaying in logs. not to be machine parsed. example: "3:10534"

func (*Cursor) PositionEquals

func (c *Cursor) PositionEquals(other *Cursor) bool

func (*Cursor) Serialize

func (c *Cursor) Serialize() string

func (*Cursor) ToChunkPath

func (c *Cursor) ToChunkPath() string

"/tenants/foo" => "/tenants/foo/_/0.log" "/" => "/tenants/foo/_/0.log"

func (*Cursor) ToChunkSafePath

func (c *Cursor) ToChunkSafePath() string

"_tenants_foo___0.log"