filesystem

package
v0.0.0-...-1af2926 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 20, 2018 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FileFilter

type FileFilter interface {
	Filter(route string, files map[string][]string)
}

type FileSystem

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

func (*FileSystem) Files

func (f *FileSystem) Files(route string, ctx context.Context, meta []byte) (files map[string][]string, err error)

func (*FileSystem) Reader

func (f *FileSystem) Reader(file string, ctx context.Context, meta []byte) (reader func() (data []byte, err error), err error)

type Hasher

type Hasher interface {
	HashString(s string) (hash uint64)
}

type NodeClient

type NodeClient interface {
	talaria.NodeClient
}

type NodeReadClient

type NodeReadClient interface {
	talaria.Node_ReadClient
}

type RouteFilter

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

func NewRouteFilter

func NewRouteFilter(h Hasher) *RouteFilter

func (*RouteFilter) Filter

func (f *RouteFilter) Filter(route string, files map[string][]string)

type SchedulerClient

type SchedulerClient interface {
	talaria.SchedulerClient
}

type StringHasher

type StringHasher struct {
}

func NewHasher

func NewHasher() *StringHasher

func (*StringHasher) HashString

func (h *StringHasher) HashString(s string) (hash uint64)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL