server

Documentation

Index

• func AddCommands(rootCmd *cobra.Command, defaultNodeHome string, appCreator types.AppCreator, ...)
• func BuildTx(tx evmtypes.MsgEthereumTx) datamodel.Node
• func ConnectTmWS(tmRPCAddr, tmEndpoint string, logger tmlog.Logger) *rpcclient.WSClient
• func MountGRPCWebServices(router *mux.Router, grpcWeb *grpcweb.WrappedGrpcServer, grpcResources []string, ...)
• func PrintProgress(ctx context.Context, pgChan <-chan gsync.ResponseProgress)
• func ReadCAR() ([]cid.Cid, blocks.Block, datamodel.Node, error)
• func ReceivedTxMessage(ctx *server.Context, evt *jsonrpc.RPCResponse, router gsync.GraphExchange) ([]byte, error)
• func StartCmd(appCreator types.AppCreator, defaultNodeHome string) *cobra.Command
• func StartJSONRPC(ctx *server.Context, clientCtx client.Context, tmRPCAddr, tmEndpoint string, ...) (*http.Server, chan struct{}, error)
• func VerifyHasErrors(ctx context.Context, errChan <-chan error) error
• type GraphsyncServer
  • func NewGraphsyncHost(ctx *server.Context, clientCtx client.Context, address string) *GraphsyncServer
  • func (gs *GraphsyncServer) ListenAndServe() error
• type ReceivedMessage
• type Receiver
  • func (r *Receiver) Connected(p peer.ID)
  • func (r *Receiver) Disconnected(p peer.ID)
  • func (r *Receiver) ReceiveError(_ peer.ID, err error)
  • func (r *Receiver) ReceiveMessage(ctx context.Context, sender peer.ID, incoming gsmsg.GraphSyncMessage)

Functions

func AddCommands

func AddCommands(rootCmd *cobra.Command, defaultNodeHome string, appCreator types.AppCreator, appExport types.AppExporter, addStartFlags types.ModuleInitFlags)

add server commands

func BuildTx

func BuildTx(tx evmtypes.MsgEthereumTx) datamodel.Node

func ConnectTmWS

func ConnectTmWS(tmRPCAddr, tmEndpoint string, logger tmlog.Logger) *rpcclient.WSClient

func MountGRPCWebServices

func MountGRPCWebServices(
	router *mux.Router,
	grpcWeb *grpcweb.WrappedGrpcServer,
	grpcResources []string,
	logger tmlog.Logger,
)

func PrintProgress

func PrintProgress(ctx context.Context, pgChan <-chan gsync.ResponseProgress)

VerifyHasErrors verifies that at least one error was sent over a channel

func ReadCAR

func ReadCAR() ([]cid.Cid, blocks.Block, datamodel.Node, error)

WriteCAR

func ReceivedTxMessage

func ReceivedTxMessage(ctx *server.Context, evt *jsonrpc.RPCResponse, router gsync.GraphExchange) ([]byte, error)

func StartCmd

func StartCmd(appCreator types.AppCreator, defaultNodeHome string) *cobra.Command

StartCmd runs the service passed in, either stand-alone or in-process with Tendermint.

func StartJSONRPC

func StartJSONRPC(ctx *server.Context, clientCtx client.Context, tmRPCAddr, tmEndpoint string, config config.Config) (*http.Server, chan struct{}, error)

StartJSONRPC starts the JSON-RPC server

func VerifyHasErrors

func VerifyHasErrors(ctx context.Context, errChan <-chan error) error

VerifyHasErrors verifies that at least one error was sent over a channel

Types

type GraphsyncServer

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

func NewGraphsyncHost

func NewGraphsyncHost(ctx *server.Context, clientCtx client.Context, address string) *GraphsyncServer

func (*GraphsyncServer) ListenAndServe

func (gs *GraphsyncServer) ListenAndServe() error

type ReceivedMessage

type ReceivedMessage struct {
	Message gsmsg.GraphSyncMessage
	Sender  peer.ID
}

type Receiver

type Receiver struct {
	MessageReceived chan ReceivedMessage
}

Receiver is an interface for receiving messages from the GraphSyncNetwork.

func (*Receiver) Connected

func (r *Receiver) Connected(p peer.ID)

func (*Receiver) Disconnected

func (r *Receiver) Disconnected(p peer.ID)

func (*Receiver) ReceiveError

func (r *Receiver) ReceiveError(_ peer.ID, err error)

func (*Receiver) ReceiveMessage

func (r *Receiver) ReceiveMessage(
	ctx context.Context,
	sender peer.ID,
	incoming gsmsg.GraphSyncMessage)