admin

Documentation

Index

• type Client
  • func NewClient(log *logging.Logger, config Config) *Client
  • func (s *Client) NodeWalletReload(ctx context.Context, chain string) (*NodeWalletReloadReply, error)
  • func (s *Client) NodeWalletShow(ctx context.Context, chain string) (*Wallet, error)
  • func (s *Client) UpgradeStatus(ctx context.Context) (*types.UpgradeStatus, error)
• type Config
  • func NewDefaultConfig() Config
• type NodeWallet
  • func NewNodeWallet(log *logging.Logger, vegaPaths paths.Paths, nodeWalletPassphrase string, ...) (*NodeWallet, error)
  • func (nw *NodeWallet) Reload(r *http.Request, args *NodeWalletArgs, reply *NodeWalletReloadReply) error
  • func (nw *NodeWallet) Show(r *http.Request, args *NodeWalletArgs, reply *Wallet) error
• type NodeWalletArgs
• type NodeWalletReloadReply
• type ProtocolUpgradeAdminService
  • func NewProtocolUpgradeService(protocolUpgradeService ProtocolUpgradeService) *ProtocolUpgradeAdminService
  • func (p *ProtocolUpgradeAdminService) UpgradeStatus(r *http.Request, args *ReadyForUpgradeArgs, reply *types.UpgradeStatus) error
• type ProtocolUpgradeService
• type ReadyForUpgradeArgs
• type Server
  • func NewNonValidatorServer(log *logging.Logger, config Config, vegaPaths paths.Paths, ...) (*Server, error)
  • func NewValidatorServer(log *logging.Logger, config Config, vegaPaths paths.Paths, ...) (*Server, error)
  • func (s *Server) ReloadConf(cfg Config)
  • func (s *Server) Start()
  • func (s *Server) Stop()
• type ServerConfig
• type Wallet
  • func (w *Wallet) String() string

Types

type Client

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

Client implement a socket client allowing to run simple RPC commands.

func NewClient

func NewClient(
	log *logging.Logger,
	config Config,
) *Client

Client returns a new instance of the RPC socket client.

func (*Client) NodeWalletReload

func (s *Client) NodeWalletReload(ctx context.Context, chain string) (*NodeWalletReloadReply, error)

func (*Client) NodeWalletShow

func (s *Client) NodeWalletShow(ctx context.Context, chain string) (*Wallet, error)

func (*Client) UpgradeStatus

func (s *Client) UpgradeStatus(ctx context.Context) (*types.UpgradeStatus, error)

type Config

type Config struct {
	Level  encoding.LogLevel `long:"log-level"`
	Server ServerConfig      `group:"Server" namespace:"server"`
}

Config represents the configuration of the admin package.

func NewDefaultConfig

func NewDefaultConfig() Config

NewDefaultConfig creates an instance of the package specific configuration, given a pointer to a logger instance to be used for logging within the package.

type NodeWallet

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

func NewNodeWallet

func NewNodeWallet(
	log *logging.Logger,
	vegaPaths paths.Paths,
	nodeWalletPassphrase string,
	nodeWallets *nodewallets.NodeWallets,
) (*NodeWallet, error)

func (*NodeWallet) Reload

func (nw *NodeWallet) Reload(r *http.Request, args *NodeWalletArgs, reply *NodeWalletReloadReply) error

func (*NodeWallet) Show

func (nw *NodeWallet) Show(r *http.Request, args *NodeWalletArgs, reply *Wallet) error

type NodeWalletArgs

type NodeWalletArgs struct {
	Chain string
}

type NodeWalletReloadReply

type NodeWalletReloadReply struct {
	OldWallet Wallet
	NewWallet Wallet
}

type ProtocolUpgradeAdminService

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

func NewProtocolUpgradeService

func NewProtocolUpgradeService(protocolUpgradeService ProtocolUpgradeService) *ProtocolUpgradeAdminService

func (*ProtocolUpgradeAdminService) UpgradeStatus

func (p *ProtocolUpgradeAdminService) UpgradeStatus(r *http.Request, args *ReadyForUpgradeArgs, reply *types.UpgradeStatus) error

type ProtocolUpgradeService

type ProtocolUpgradeService interface {
	// is vega core ready to be stopped and upgraded
	GetUpgradeStatus() types.UpgradeStatus
}

type ReadyForUpgradeArgs

type ReadyForUpgradeArgs struct{}

type Server

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

Server implement a socket server allowing to run simple RPC commands.

func NewNonValidatorServer

func NewNonValidatorServer(log *logging.Logger,
	config Config,
	vegaPaths paths.Paths,
	protocolUpgradeService ProtocolUpgradeService,
) (*Server, error)

func NewValidatorServer

func NewValidatorServer(
	log *logging.Logger,
	config Config,
	vegaPaths paths.Paths,
	nodeWalletPassphrase string,
	nodeWallets *nodewallets.NodeWallets,
	protocolUpgradeService ProtocolUpgradeService,
) (*Server, error)

NewServer returns a new instance of the RPC socket server.

func (*Server) ReloadConf

func (s *Server) ReloadConf(cfg Config)

ReloadConf update the internal configuration of the server.

func (*Server) Start

func (s *Server) Start()

Start start the server.

func (*Server) Stop

func (s *Server) Stop()

Stop stops the server.

type ServerConfig

type ServerConfig struct {
	SocketPath string `long:"socket-path" description:"Listen for connection on UNIX socket path <file-path>"`
	HTTPPath   string `long:"http-path" description:"Http path of the socket HTTP RPC server"`
}

ServerConfig represent the configuration of the server.

type Wallet

type Wallet struct {
	Name      string `json:"name"`
	PublicKey string `json:"public_key"`
}

func (*Wallet) String

func (w *Wallet) String() string