server

package

v0.5.0 Latest Latest Go to latest Published: Sep 8, 2021 License: MIT Imports: 18 Imported by: 0

Details

This section is empty.

View Source

var ErrKeyExists = fmt.Errorf("key already exists")

View Source

var ErrNotAuthorized = fmt.Errorf("not authorized")

View Source

var ErrNotFound = fmt.Errorf("not found")

func Int64ToBytes(i int64) []byte

type DumpServer struct {
	pb.UnimplementedDMSDumpServiceServer
	// contains filtered or unexported fields
}

func NewDumpServer(baseDir string, lookupClient pb.LookupServiceClient, maxMessageAgeHours int) (*DumpServer, error)

func (s *DumpServer) Receive(ctx context.Context, req *pb.ReceiveRequest) (*pb.ReceiveResponse, error)

func (s *DumpServer) Send(ctx context.Context, req *pb.SendRequest) (*pb.SendResponse, error)

type Server struct {
	pb.UnimplementedIdentityServiceServer
	pb.UnimplementedLookupServiceServer
	// contains filtered or unexported fields
}

func NewServer(d *badger.DB) *Server

func (s *Server) DisableKey(ctx context.Context, req *pb.SignedWithPow) (*pb.KeyDisableResponse, error)

func (s *Server) LookupAddress(ctx context.Context, req *pb.LookupAddressRequest) (*pb.LookupAddressResponse, error)

func (s *Server) LookupKey(ctx context.Context, req *pb.LookupKeyRequest) (*pb.LookupKeyResponse, error)

func (s *Server) LookupName(ctx context.Context, req *pb.LookupNameRequest) (*pb.LookupNameResponse, error)

func (s *Server) RegisterAddress(ctx context.Context, req *pb.SignedWithPow) (*pb.AddressRegistrationResponse, error)

func (s *Server) RegisterKey(ctx context.Context, req *pb.SignedWithPow) (*pb.KeyRegistrationResponse, error)

func (s *Server) RegisterKeyRelationship(ctx context.Context, req *pb.SignedWithPow) (*pb.KeyRelationshipRegistrationResponse, error)

func (s *Server) RegisterName(ctx context.Context, req *pb.SignedWithPow) (*pb.NameRegistrationResponse, error)