client

Documentation

Index

• func NewMDSClient(port int) metadata.MetadataServiceClient
• type Client
  • func New(mdsPort int, pefetchThreshold int) *Client
  • func (c *Client) ClearCache()
  • func (c *Client) CreateFile(name string, data []byte) (int, error)
  • func (c *Client) CreateFileWithStream(name string, data []byte) (int, error)
  • func (c *Client) DeleteAllData()
  • func (c *Client) GetFile(name string) ([]byte, error)
  • func (c *Client) GetFileFromPort(port int32, name string) ([]byte, error)
  • func (c *Client) GetFileFromPortWithStream(port int32, name string) ([]byte, error)
  • func (c *Client) GetFileWithStream(name string) ([]byte, error)
  • func (c *Client) GrepOnFileServer(fileName string, word string, port int32) (int, error)
  • func (c *Client) MkDir(name string) error
  • func (c *Client) OpenDir(name string) (string, error)
  • func (c *Client) ReadDir(name string, index int, useCache bool) (*metadata.FileInfo, error)
• type ClientCache

Functions

func NewMDSClient

func NewMDSClient(port int) metadata.MetadataServiceClient

Types

type Client

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

func New

func New(mdsPort int, pefetchThreshold int) *Client

func (*Client) ClearCache

func (c *Client) ClearCache()

func (*Client) CreateFile

func (c *Client) CreateFile(name string, data []byte) (int, error)

func (*Client) CreateFileWithStream

func (c *Client) CreateFileWithStream(name string, data []byte) (int, error)

func (*Client) DeleteAllData

func (c *Client) DeleteAllData()

func (*Client) GetFile

func (c *Client) GetFile(name string) ([]byte, error)

func (*Client) GetFileFromPort

func (c *Client) GetFileFromPort(port int32, name string) ([]byte, error)

func (*Client) GetFileFromPortWithStream

func (c *Client) GetFileFromPortWithStream(port int32, name string) ([]byte, error)

func (*Client) GetFileWithStream

func (c *Client) GetFileWithStream(name string) ([]byte, error)

func (*Client) GrepOnFileServer

func (c *Client) GrepOnFileServer(fileName string, word string, port int32) (int, error)

func (*Client) MkDir

func (c *Client) MkDir(name string) error

func (*Client) OpenDir

func (c *Client) OpenDir(name string) (string, error)

open a directory

func (*Client) ReadDir

func (c *Client) ReadDir(name string, index int, useCache bool) (*metadata.FileInfo, error)

type ClientCache

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

this client cache will the used for caching metadata as part of the metadata prefetching optimization