Documentation ¶
Index ¶
- Constants
- func PeekManifest(in io.Reader) (r io.Reader, isShadow bool, err error)
- type Chunk
- type ChunkSlice
- type Data
- type ID
- type IDSlice
- type Manifest
- func (s Manifest) MarshalThrift() (res wire.Manifest, err error)
- func (s *Manifest) ParseBlob(in io.Reader, chunkSize int64) (err error)
- func (s *Manifest) ParseManifest(in io.Reader) (err error)
- func (s *Manifest) Serialize(out io.Writer) (err error)
- func (s Manifest) String() (res string)
- func (s *Manifest) UnmarshalThrift(data wire.Manifest) (err error)
- type ManifestSlice
- type ServerInfo
- type Spec
Constants ¶
View Source
const CHUNK_SIZE = 1024 * 1024 * 2
View Source
const (
MANIFEST_HEADER = "BAR:MANIFEST"
)
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ChunkSlice ¶
type ChunkSlice []Chunk
slice of unique chunks
func (ChunkSlice) MarshalThrift ¶
func (s ChunkSlice) MarshalThrift() (data []*wire.Chunk, err error)
func (*ChunkSlice) UnmarshalThrift ¶
func (s *ChunkSlice) UnmarshalThrift(data []*wire.Chunk) (err error)
type IDSlice ¶
type IDSlice []ID
func (IDSlice) MarshalThrift ¶
NOTE: strange behaviour of thrift compiller should be []ID.
func (*IDSlice) UnmarshalThrift ¶
type Manifest ¶
func NewFromBLOB ¶
Make shadow from BLOB
func NewFromManifest ¶
Make shadow from manifest
func (*Manifest) ParseManifest ¶
Parse manifest
type ManifestSlice ¶
type ManifestSlice []Manifest
func (ManifestSlice) GetChunkSlice ¶
func (s ManifestSlice) GetChunkSlice() (res IDSlice)
Get slice with unique chunk ids
func (ManifestSlice) MarshalThrift ¶
func (s ManifestSlice) MarshalThrift() (res []*wire.Manifest, err error)
func (*ManifestSlice) UnmarshalThrift ¶
func (s *ManifestSlice) UnmarshalThrift(data []*wire.Manifest) (err error)
type ServerInfo ¶
type ServerInfo struct { // HTTP Endpoint HTTPEndpoint string // RPC Endpoint RPCEndpoints []string // Preferred chunk size ChunkSize int64 // Preferred number of connections from client PoolSize int // Thrift rpc buffer size BufferSize int }
Server info
func (*ServerInfo) JoinRPCEndpoints ¶
func (i *ServerInfo) JoinRPCEndpoints() string
func (ServerInfo) MarshalThrift ¶
func (i ServerInfo) MarshalThrift() (res wire.ServerInfo, err error)
func (*ServerInfo) UnmarshalThrift ¶
func (i *ServerInfo) UnmarshalThrift(data wire.ServerInfo) (err error)
Click to show internal directories.
Click to hide internal directories.