sessions

Documentation

Index

• Constants
• func EnsureDirectory(path string) error
• func GetFilename(dataDir string, path string) (string, error)
• type Event
• type Recorder
  • func NewRecorder(ctx context.Context, filename string, stream stream.Stream) (*Recorder, error)
  • func (s *Recorder) Events() []Event
  • func (s *Recorder) Read(p []byte) (n int, err error)
  • func (s *Recorder) Resize(size stream.Size) error
  • func (s *Recorder) Write(data []byte) (n int, err error)
• type SessionReader
  • func Open(filename string) (SessionReader, error)
• type SessionWriter
  • func Create(filename string) (SessionWriter, error)

Constants

const (
	SESSION_FILE_VERSION = 1
)

Functions

func EnsureDirectory

func EnsureDirectory(path string) error

EnsureDirectory creates a directory if it does not exist and checks whether other users can read and write files in it.

func GetFilename

func GetFilename(dataDir string, path string) (string, error)

Types

type Event

type Event struct {
	Stamp   time.Time
	Message P.Message
}

type Recorder

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

func NewRecorder

func NewRecorder(ctx context.Context, filename string, stream stream.Stream) (*Recorder, error)

func (*Recorder) Events

func (s *Recorder) Events() []Event

func (*Recorder) Read

func (s *Recorder) Read(p []byte) (n int, err error)

func (*Recorder) Resize

func (s *Recorder) Resize(size stream.Size) error

func (*Recorder) Write

func (s *Recorder) Write(data []byte) (n int, err error)

type SessionReader

type SessionReader interface {
	Read() (Event, error)
}

func Open

func Open(filename string) (SessionReader, error)

type SessionWriter

type SessionWriter interface {
	Write(event Event) error
	Close() error
}

func Create

func Create(filename string) (SessionWriter, error)