adminhttpclient

Documentation

Index

• type Client
  • func New(baseURL string, options ...httpclient.Option) (*Client, error)
  • func (c *Client) Allow(ctx context.Context, peerID peer.ID) error
  • func (c *Client) Block(ctx context.Context, peerID peer.ID) error
  • func (c *Client) ImportFromCidList(ctx context.Context, fileName string, provID peer.ID, ...) error
  • func (c *Client) ImportFromManifest(ctx context.Context, fileName string, provID peer.ID, ...) error
  • func (c *Client) ListLogSubSystems(ctx context.Context) ([]string, error)
  • func (c *Client) ReloadPolicy(ctx context.Context) error
  • func (c *Client) SetLogLevels(ctx context.Context, sysLvl map[string]string) error
  • func (c *Client) Sync(ctx context.Context, peerID peer.ID, peerAddr multiaddr.Multiaddr, depth int64, ...) error

Types

type Client

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

Client is an http client for the indexer finder API,

func New

func New(baseURL string, options ...httpclient.Option) (*Client, error)

New creates a new admin HTTP client.

func (*Client) Allow

func (c *Client) Allow(ctx context.Context, peerID peer.ID) error

Allow configures the indexer to allow the peer to publish messages and provide content.

func (*Client) Block

func (c *Client) Block(ctx context.Context, peerID peer.ID) error

Block configures indexer to block the peer from publishing messages and providing content.

func (*Client) ImportFromCidList

func (c *Client) ImportFromCidList(ctx context.Context, fileName string, provID peer.ID, contextID, metadata []byte) error

ImportFromCidList process entries from a cidlist and imprts it into the indexer.

func (*Client) ImportFromManifest

func (c *Client) ImportFromManifest(ctx context.Context, fileName string, provID peer.ID, contextID, metadata []byte) error

ImportFromManifest processes entries from manifest and imports them into the indexer.

func (*Client) ListLogSubSystems

func (c *Client) ListLogSubSystems(ctx context.Context) ([]string, error)

func (*Client) ReloadPolicy

func (c *Client) ReloadPolicy(ctx context.Context) error

ReloadPolicy reloads the policy from the configuration file.

func (*Client) SetLogLevels

func (c *Client) SetLogLevels(ctx context.Context, sysLvl map[string]string) error

func (*Client) Sync

func (c *Client) Sync(ctx context.Context, peerID peer.ID, peerAddr multiaddr.Multiaddr, depth int64, resync bool) error

Sync with a data peer up to the latest ID.