database

Documentation

Index

• type Server
  • func (server *Server) AddNode(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)
  • func (server *Server) FetchRemoteDatabase(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)
  • func (server *Server) FromBytes(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)
  • func (server *Server) JoinDatabase(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)
  • func (server *Server) LogDatabase(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)
  • func (server *Server) NewDatabase(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)
  • func (server *Server) QueryForAddress(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)
  • func (server *Server) ReadFromMemory(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)
  • func (server *Server) RemoveNode(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)
  • func (server *Server) SendDatabaseMessage(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)
  • func (server *Server) UpdateRemoteDatabase(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)
  • func (server *Server) WriteToMemory(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)

Types

type Server

type Server struct{}

Server - GoP2P RPC server

func (*Server) AddNode

func (server *Server) AddNode(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)

AddNode - database.AddNode RPC handler

func (*Server) FetchRemoteDatabase

func (server *Server) FetchRemoteDatabase(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)

FetchRemoteDatabase - database.FetchRemoteDatabase RPC handler

func (*Server) FromBytes

func (server *Server) FromBytes(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)

FromBytes - database.FromBytes RPC handler

func (*Server) JoinDatabase

func (server *Server) JoinDatabase(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)

JoinDatabase - database.JoinDatabase RPC handler

func (*Server) LogDatabase

func (server *Server) LogDatabase(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)

LogDatabase - database.LogDatabase RPC handler

func (*Server) NewDatabase

func (server *Server) NewDatabase(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)

NewDatabase - database.NewDatabase RPC handler

func (*Server) QueryForAddress

func (server *Server) QueryForAddress(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)

QueryForAddress - database.QueryForAddress RPC handler

func (*Server) ReadFromMemory

func (server *Server) ReadFromMemory(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)

ReadFromMemory - database.ReadDatabaseFromMemory RPC handler

func (*Server) RemoveNode

func (server *Server) RemoveNode(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)

RemoveNode - database.RemoveNode RPC handler

func (*Server) SendDatabaseMessage

func (server *Server) SendDatabaseMessage(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)

SendDatabaseMessage - database.SendDatabaseMessage RPC handler

func (*Server) UpdateRemoteDatabase

func (server *Server) UpdateRemoteDatabase(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)

UpdateRemoteDatabase - database.UpdateRemoteDatabase RPC handler

func (*Server) WriteToMemory

func (server *Server) WriteToMemory(ctx context.Context, req *databaseProto.GeneralRequest) (*databaseProto.GeneralResponse, error)

WriteToMemory - database.WriteToMemory RPC handler