receiver

Documentation

Index

• Constants
• func RunSynchronizerService(link io.ReadWriteCloser) error
• type Chunk
• type File
  • func NewFile(pathName string) (*File, error)
  • func (this *File) NextSignature(dummy int, signature *Signature) (err error)
  • func (this *File) SaveChunk(chunk Chunk, dummy *int) error
  • func (this *File) StartStream(index int, token *string) (err error)
• type Signature
• type Stream
  • func NewStream(filePath string) (*Stream, error)
  • func (this *Stream) Close(dummy int, nothing *int) error
  • func (this *Stream) Write(data []byte, n *int) (err error)
• type Synchronizer
  • func (this *Synchronizer) StartFile(filePath string, token *string) error

Constants

const CHUNK_SIZE = 8 * 4096

Functions

func RunSynchronizerService

func RunSynchronizerService(link io.ReadWriteCloser) error

Types

type Chunk

type Chunk struct {
	Signature
	Data [CHUNK_SIZE]byte
}

type File

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

func NewFile

func NewFile(pathName string) (*File, error)

func (*File) NextSignature

func (this *File) NextSignature(dummy int, signature *Signature) (err error)

func (*File) SaveChunk

func (this *File) SaveChunk(chunk Chunk, dummy *int) error

func (*File) StartStream

func (this *File) StartStream(index int, token *string) (err error)

type Signature

type Signature struct {
	Rolling string
	Strong  string
}

type Stream

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

func NewStream

func NewStream(filePath string) (*Stream, error)

func (*Stream) Close

func (this *Stream) Close(dummy int, nothing *int) error

func (*Stream) Write

func (this *Stream) Write(data []byte, n *int) (err error)

type Synchronizer

type Synchronizer int

func (*Synchronizer) StartFile

func (this *Synchronizer) StartFile(filePath string, token *string) error