service

Documentation

Index

• Variables
• func JSON(c *gin.Context, v interface{}, e error)
• type APIContext
  • func NewAPIContext(cfg *config.Config, m core.NodeManager, c *controller.Controller) *APIContext
  • func (c *APIContext) API() core.API
  • func (c *APIContext) Add(ctx context.Context, req *core.AddReq) (*core.AddResp, error)
  • func (c *APIContext) DataStoreAPI() core.DataStoreAPI
  • func (c *APIContext) ID(ctx context.Context, req *core.IDReq) (*core.IDResp, error)
  • func (c *APIContext) Initialize() error
  • func (c *APIContext) IsReady() bool
  • func (c *APIContext) Link(ctx context.Context, req *core.NodeLinkReq) (*core.NodeLinkResp, error)
  • func (c *APIContext) List(ctx context.Context, req *core.NodeListReq) (*core.NodeListResp, error)
  • func (c *APIContext) MessageHandle(f func(s string))
  • func (c *APIContext) NodeAPI() core.NodeAPI
  • func (c *APIContext) NodeAddrInfo(ctx context.Context, req *core.AddrReq) (*core.AddrResp, error)
  • func (c *APIContext) PinLs(ctx context.Context, req *core.DataStoreReq) (*core.DataStoreResp, error)
  • func (c *APIContext) Ping(ctx context.Context, req *core.PingReq) (*core.PingResp, error)
  • func (c *APIContext) Start() error
  • func (c *APIContext) Stop() error
  • func (c *APIContext) Unlink(ctx context.Context, req *core.NodeUnlinkReq) (*core.NodeUnlinkResp, error)
• type BustLinker
  • func NewBustLinker(cfg *config.Config) (linker *BustLinker, err error)
  • func (l *BustLinker) Run()
  • func (l *BustLinker) Start()
  • func (l *BustLinker) Stop()
  • func (l *BustLinker) WaitingForReady()

Variables

var LogOutput = true

LogOutput ...

Functions

func JSON

func JSON(c *gin.Context, v interface{}, e error)

JSON ...

Types

type APIContext

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

APIContext ...

func NewAPIContext

func NewAPIContext(cfg *config.Config, m core.NodeManager, c *controller.Controller) *APIContext

NewAPIContext ...

func (*APIContext) API

func (c *APIContext) API() core.API

API ...

func (*APIContext) Add

func (c *APIContext) Add(ctx context.Context, req *core.AddReq) (*core.AddResp, error)

Add ...

func (*APIContext) DataStoreAPI

func (c *APIContext) DataStoreAPI() core.DataStoreAPI

DataStoreAPI ...

func (*APIContext) ID

func (c *APIContext) ID(ctx context.Context, req *core.IDReq) (*core.IDResp, error)

ID ...

func (*APIContext) Initialize

func (c *APIContext) Initialize() error

Initialize ...

func (*APIContext) IsReady

func (c *APIContext) IsReady() bool

IsReady ...

func (*APIContext) Link

func (c *APIContext) Link(ctx context.Context, req *core.NodeLinkReq) (*core.NodeLinkResp, error)

Link ...

func (*APIContext) List

func (c *APIContext) List(ctx context.Context, req *core.NodeListReq) (*core.NodeListResp, error)

List ...

func (*APIContext) MessageHandle

func (c *APIContext) MessageHandle(f func(s string))

MessageHandle ...

func (*APIContext) NodeAPI

func (c *APIContext) NodeAPI() core.NodeAPI

NodeAPI ...

func (*APIContext) NodeAddrInfo

func (c *APIContext) NodeAddrInfo(ctx context.Context, req *core.AddrReq) (*core.AddrResp, error)

NodeAddrInfo ...

func (*APIContext) PinLs

func (c *APIContext) PinLs(ctx context.Context, req *core.DataStoreReq) (*core.DataStoreResp, error)

PinLs ...

func (*APIContext) Ping

func (c *APIContext) Ping(ctx context.Context, req *core.PingReq) (*core.PingResp, error)

Ping ...

func (*APIContext) Start

func (c *APIContext) Start() error

Start ...

func (*APIContext) Stop

func (c *APIContext) Stop() error

Stop ...

func (*APIContext) Unlink

func (c *APIContext) Unlink(ctx context.Context, req *core.NodeUnlinkReq) (*core.NodeUnlinkResp, error)

Unlink ...

type BustLinker

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

BustLinker ...

func NewBustLinker

func NewBustLinker(cfg *config.Config) (linker *BustLinker, err error)

NewBustLinker ...

func (*BustLinker) Run

func (l *BustLinker) Run()

Run ...

func (*BustLinker) Start

func (l *BustLinker) Start()

Start ...

func (*BustLinker) Stop

func (l *BustLinker) Stop()

Stop ...

func (*BustLinker) WaitingForReady

func (l *BustLinker) WaitingForReady()

WaitingForReady ...