temp

package

v0.0.1 Latest Latest Go to latest Published: Apr 27, 2016 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.looper.workers.dev/coreos/torus

Links

Open Source Insights

Documentation ¶

Index ¶

func NewTemp(cfg agro.Config) (agro.MetadataService, error)
type Client
- func NewClient(cfg agro.Config, srv *Server) *Client
type Server
- func NewServer() *Server

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewTemp ¶

func NewTemp(cfg agro.Config) (agro.MetadataService, error)

Types ¶

type Client ¶

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

func NewClient ¶

func NewClient(cfg agro.Config, srv *Server) *Client

func (*Client) Close ¶

func (t *Client) Close() error

func (*Client) CommitINodeIndex ¶

func (t *Client) CommitINodeIndex(vol agro.VolumeID) (agro.INodeID, error)

func (*Client) GetData ¶

func (t *Client) GetData(x string) (interface{}, bool)

func (*Client) GetINodeIndex ¶

func (t *Client) GetINodeIndex(volume agro.VolumeID) (agro.INodeID, error)

func (*Client) GetINodeIndexes ¶

func (t *Client) GetINodeIndexes() (map[agro.VolumeID]agro.INodeID, error)

func (*Client) GetLease ¶

func (t *Client) GetLease() (int64, error)

func (*Client) GetPeers ¶

func (t *Client) GetPeers() (agro.PeerInfoList, error)

func (*Client) GetRing ¶

func (t *Client) GetRing() (agro.Ring, error)

func (*Client) GetVolume ¶

func (t *Client) GetVolume(volume string) (*models.Volume, error)

func (*Client) GetVolumes ¶

func (t *Client) GetVolumes() ([]*models.Volume, error)

func (*Client) GlobalMetadata ¶

func (t *Client) GlobalMetadata() (agro.GlobalMetadata, error)

func (*Client) Kind ¶

func (t *Client) Kind() agro.MetadataKind

func (*Client) LockData ¶

func (t *Client) LockData()

func (*Client) NewVolumeID ¶

func (t *Client) NewVolumeID() (agro.VolumeID, error)

func (*Client) RegisterPeer ¶

func (t *Client) RegisterPeer(_ int64, pi *models.PeerInfo) error

func (*Client) SetData ¶

func (t *Client) SetData(x string, v interface{})

func (*Client) SetRing ¶

func (t *Client) SetRing(ring agro.Ring) error

func (*Client) SubscribeNewRings ¶

func (t *Client) SubscribeNewRings(ch chan agro.Ring)

func (*Client) UUID ¶

func (t *Client) UUID() string

func (*Client) UnlockData ¶

func (t *Client) UnlockData()

func (*Client) UnsubscribeNewRings ¶

func (t *Client) UnsubscribeNewRings(ch chan agro.Ring)

func (*Client) WithContext ¶

func (t *Client) WithContext(_ context.Context) agro.MetadataService

type Server ¶

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

func NewServer ¶

func NewServer() *Server

func (*Server) Close ¶

func (s *Server) Close() error

func (*Server) SetRing ¶

func (s *Server) SetRing(ring agro.Ring) error

func (*Server) SubscribeNewRings ¶

func (s *Server) SubscribeNewRings(ch chan agro.Ring)

func (*Server) UnsubscribeNewRings ¶

func (s *Server) UnsubscribeNewRings(ch chan agro.Ring)

Source Files ¶

View all Source files

temp.go

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