tns

Documentation

Index

• Variables
• func New(ctx context.Context, node peer.Node) (tns.Client, error)
• type Client
  • func (c *Client) Close()
  • func (c *Client) Database() tns.StructureIface[*structureSpec.Database]
  • func (c *Client) Domain() tns.StructureIface[*structureSpec.Domain]
  • func (c *Client) Fetch(path tns.Path) (tns.Object, error)
  • func (c *Client) Function() tns.StructureIface[*structureSpec.Function]
  • func (c *Client) Library() tns.StructureIface[*structureSpec.Library]
  • func (c *Client) List(depth int) ([]string, error)
  • func (c *Client) Lookup(query tns.Query) (interface{}, error)
  • func (c *Client) Messaging() tns.StructureIface[*structureSpec.Messaging]
  • func (c *Client) Peers(pids ...peerCore.ID) tns.Client
  • func (c *Client) Push(path []string, data interface{}) error
  • func (c *Client) Service() tns.StructureIface[*structureSpec.Service]
  • func (c *Client) Simple() tns.SimpleIface
  • func (c *Client) SmartOp() tns.StructureIface[*structureSpec.SmartOp]
  • func (c *Client) Stats() iface.Stats
  • func (c *Client) Storage() tns.StructureIface[*structureSpec.Storage]
  • func (c *Client) Website() tns.StructureIface[*structureSpec.Website]
• type Stats
  • func (h *Stats) Database() (kvdbIface.Stats, error)

Variables

var (
	CacheFetchRetryWait       = 1 * time.Second
	MaximumCacheFetchInterval = 1 * time.Second
)

Functions

func New

func New(ctx context.Context, node peer.Node) (tns.Client, error)

Types

type Client

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

func (*Client) Close

func (c *Client) Close()

func (*Client) Database

func (c *Client) Database() tns.StructureIface[*structureSpec.Database]

func (*Client) Domain

func (c *Client) Domain() tns.StructureIface[*structureSpec.Domain]

func (*Client) Fetch

func (c *Client) Fetch(path tns.Path) (tns.Object, error)

***** FETCH ****** Fetch a key, does not watch nor cache value

func (*Client) Function

func (c *Client) Function() tns.StructureIface[*structureSpec.Function]

func (*Client) Library

func (c *Client) Library() tns.StructureIface[*structureSpec.Library]

func (*Client) List

func (c *Client) List(depth int) ([]string, error)

***** LIST ******

func (*Client) Lookup

func (c *Client) Lookup(query tns.Query) (interface{}, error)

***** FETCH ****** Fetch a key, does not watch nor cache value

func (*Client) Messaging

func (c *Client) Messaging() tns.StructureIface[*structureSpec.Messaging]

func (*Client) Peers

func (c *Client) Peers(pids ...peerCore.ID) tns.Client

func (*Client) Push

func (c *Client) Push(path []string, data interface{}) error

func (*Client) Service

func (c *Client) Service() tns.StructureIface[*structureSpec.Service]

func (*Client) Simple

func (c *Client) Simple() tns.SimpleIface

func (*Client) SmartOp

func (c *Client) SmartOp() tns.StructureIface[*structureSpec.SmartOp]

func (*Client) Stats

func (c *Client) Stats() iface.Stats

func (*Client) Storage

func (c *Client) Storage() tns.StructureIface[*structureSpec.Storage]

func (*Client) Website

func (c *Client) Website() tns.StructureIface[*structureSpec.Website]

type Stats

type Stats Client

func (*Stats) Database

func (h *Stats) Database() (kvdbIface.Stats, error)