server

package
v0.55.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 22, 2026 License: Unlicense Imports: 15 Imported by: 0

Documentation

Overview

Package server provides a shared gRPC database server implementation.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
	// Listen is the gRPC server listen address
	Listen string

	// LogLevel is the logging level
	LogLevel string

	// StreamBatchSize is the number of events per stream batch
	StreamBatchSize int

	// MaxConcurrentQueries is the max concurrent queries
	MaxConcurrentQueries int
}

Config holds configuration for the database gRPC server.

type DatabaseConfig 

type DatabaseConfig struct {
	DataDir             string
	LogLevel            string
	BlockCacheMB        int
	IndexCacheMB        int
	ZSTDLevel           int
	QueryCacheSizeMB    int
	QueryCacheMaxAge    time.Duration
	QueryCacheDisabled  bool
	SerialCachePubkeys  int
	SerialCacheEventIds int
}

DatabaseConfig holds Badger-specific configuration.

type DatabaseService 

type DatabaseService struct {
	orlydbv1.UnimplementedDatabaseServiceServer
	// contains filtered or unexported fields
}

DatabaseService implements the orlydbv1.DatabaseServiceServer interface.

func NewDatabaseService 

func NewDatabaseService(db database.Database, cfg *Config) *DatabaseService

NewDatabaseService creates a new database service.

func (*DatabaseService) AddNIP43Member 

func (s *DatabaseService) AddNIP43Member(ctx context.Context, req *orlydbv1.AddNIP43MemberRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) CacheEvents 

func (s *DatabaseService) CacheEvents(ctx context.Context, req *orlydbv1.CacheEventsRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) CacheMarshaledJSON 

func (s *DatabaseService) CacheMarshaledJSON(ctx context.Context, req *orlydbv1.CacheMarshaledJSONRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) CheckForDeleted 

func (s *DatabaseService) CheckForDeleted(ctx context.Context, req *orlydbv1.CheckForDeletedRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) CountEvents 

func (s *DatabaseService) CountEvents(ctx context.Context, req *orlydbv1.QueryEventsRequest) (*orlydbv1.CountEventsResponse, error)

func (*DatabaseService) DeleteBlob 

func (s *DatabaseService) DeleteBlob(ctx context.Context, req *orlydbv1.DeleteBlobRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) DeleteEvent 

func (s *DatabaseService) DeleteEvent(ctx context.Context, req *orlydbv1.DeleteEventRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) DeleteEventBySerial 

func (s *DatabaseService) DeleteEventBySerial(ctx context.Context, req *orlydbv1.DeleteEventBySerialRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) DeleteExpired 

func (s *DatabaseService) DeleteExpired(ctx context.Context, req *orlydbv1.Empty) (*orlydbv1.Empty, error)

func (*DatabaseService) DeleteInviteCode 

func (s *DatabaseService) DeleteInviteCode(ctx context.Context, req *orlydbv1.DeleteInviteCodeRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) DeleteMarker 

func (s *DatabaseService) DeleteMarker(ctx context.Context, req *orlydbv1.DeleteMarkerRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) EventIdsBySerial 

func (s *DatabaseService) EventIdsBySerial(ctx context.Context, req *orlydbv1.EventIdsBySerialRequest) (*orlydbv1.EventIdsBySerialResponse, error)

func (*DatabaseService) Export 

func (s *DatabaseService) Export(req *orlydbv1.ExportRequest, stream orlydbv1.DatabaseService_ExportServer) error

func (*DatabaseService) ExtendBlossomSubscription 

func (s *DatabaseService) ExtendBlossomSubscription(ctx context.Context, req *orlydbv1.ExtendBlossomSubscriptionRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) ExtendSubscription 

func (s *DatabaseService) ExtendSubscription(ctx context.Context, req *orlydbv1.ExtendSubscriptionRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) FetchEventBySerial 

func (s *DatabaseService) FetchEventBySerial(ctx context.Context, req *orlydbv1.FetchEventBySerialRequest) (*orlydbv1.FetchEventBySerialResponse, error)

func (*DatabaseService) FetchEventsBySerials 

func (s *DatabaseService) FetchEventsBySerials(ctx context.Context, req *orlydbv1.FetchEventsBySerialRequest) (*orlydbv1.EventMap, error)

func (*DatabaseService) GetAllNIP43Members 

func (s *DatabaseService) GetAllNIP43Members(ctx context.Context, req *orlydbv1.Empty) (*orlydbv1.PubkeyList, error)

func (*DatabaseService) GetBlob 

func (s *DatabaseService) GetBlob(ctx context.Context, req *orlydbv1.GetBlobRequest) (*orlydbv1.GetBlobResponse, error)

func (*DatabaseService) GetBlobMetadata 

func (s *DatabaseService) GetBlobMetadata(ctx context.Context, req *orlydbv1.GetBlobMetadataRequest) (*orlydbv1.BlobMetadata, error)

func (*DatabaseService) GetBlossomStorageQuota 

func (s *DatabaseService) GetBlossomStorageQuota(ctx context.Context, req *orlydbv1.GetBlossomStorageQuotaRequest) (*orlydbv1.GetBlossomStorageQuotaResponse, error)

func (*DatabaseService) GetCachedEvents 

func (s *DatabaseService) GetCachedEvents(ctx context.Context, req *orlydbv1.GetCachedEventsRequest) (*orlydbv1.GetCachedEventsResponse, error)

func (*DatabaseService) GetCachedJSON 

func (s *DatabaseService) GetCachedJSON(ctx context.Context, req *orlydbv1.GetCachedJSONRequest) (*orlydbv1.GetCachedJSONResponse, error)

func (*DatabaseService) GetEventAccessInfo 

func (s *DatabaseService) GetEventAccessInfo(ctx context.Context, req *orlydbv1.GetEventAccessInfoRequest) (*orlydbv1.GetEventAccessInfoResponse, error)

func (*DatabaseService) GetFullIdPubkeyBySerial 

func (s *DatabaseService) GetFullIdPubkeyBySerial(ctx context.Context, req *orlydbv1.GetFullIdPubkeyBySerialRequest) (*orlydbv1.IdPkTs, error)

func (*DatabaseService) GetFullIdPubkeyBySerials 

func (s *DatabaseService) GetFullIdPubkeyBySerials(ctx context.Context, req *orlydbv1.GetFullIdPubkeyBySerialsRequest) (*orlydbv1.IdPkTsList, error)

func (*DatabaseService) GetLeastAccessedEvents 

func (s *DatabaseService) GetLeastAccessedEvents(ctx context.Context, req *orlydbv1.GetLeastAccessedEventsRequest) (*orlydbv1.SerialList, error)

func (*DatabaseService) GetMarker 

func (s *DatabaseService) GetMarker(ctx context.Context, req *orlydbv1.GetMarkerRequest) (*orlydbv1.GetMarkerResponse, error)

func (*DatabaseService) GetNIP43Membership 

func (s *DatabaseService) GetNIP43Membership(ctx context.Context, req *orlydbv1.GetNIP43MembershipRequest) (*orlydbv1.NIP43Membership, error)

func (*DatabaseService) GetOrCreateRelayIdentitySecret 

func (s *DatabaseService) GetOrCreateRelayIdentitySecret(ctx context.Context, req *orlydbv1.Empty) (*orlydbv1.GetRelayIdentitySecretResponse, error)

func (*DatabaseService) GetPath 

func (s *DatabaseService) GetPath(ctx context.Context, req *orlydbv1.Empty) (*orlydbv1.PathResponse, error)

func (*DatabaseService) GetPaymentHistory 

func (s *DatabaseService) GetPaymentHistory(ctx context.Context, req *orlydbv1.GetPaymentHistoryRequest) (*orlydbv1.PaymentList, error)

func (*DatabaseService) GetRelayIdentitySecret 

func (s *DatabaseService) GetRelayIdentitySecret(ctx context.Context, req *orlydbv1.Empty) (*orlydbv1.GetRelayIdentitySecretResponse, error)

func (*DatabaseService) GetSerialById 

func (s *DatabaseService) GetSerialById(ctx context.Context, req *orlydbv1.GetSerialByIdRequest) (*orlydbv1.GetSerialByIdResponse, error)

func (*DatabaseService) GetSerialsByIds 

func (s *DatabaseService) GetSerialsByIds(ctx context.Context, req *orlydbv1.GetSerialsByIdsRequest) (*orlydbv1.SerialMap, error)

func (*DatabaseService) GetSerialsByRange 

func (s *DatabaseService) GetSerialsByRange(ctx context.Context, req *orlydbv1.GetSerialsByRangeRequest) (*orlydbv1.SerialList, error)

func (*DatabaseService) GetSerialsFromFilter 

func (s *DatabaseService) GetSerialsFromFilter(ctx context.Context, req *orlydbv1.GetSerialsFromFilterRequest) (*orlydbv1.SerialList, error)

func (*DatabaseService) GetSubscription 

func (s *DatabaseService) GetSubscription(ctx context.Context, req *orlydbv1.GetSubscriptionRequest) (*orlydbv1.Subscription, error)

func (*DatabaseService) GetTotalBlobStorageUsed 

func (s *DatabaseService) GetTotalBlobStorageUsed(ctx context.Context, req *orlydbv1.GetTotalBlobStorageUsedRequest) (*orlydbv1.GetTotalBlobStorageUsedResponse, error)

func (*DatabaseService) HasBlob 

func (s *DatabaseService) HasBlob(ctx context.Context, req *orlydbv1.HasBlobRequest) (*orlydbv1.HasBlobResponse, error)

func (*DatabaseService) HasMarker 

func (s *DatabaseService) HasMarker(ctx context.Context, req *orlydbv1.HasMarkerRequest) (*orlydbv1.HasMarkerResponse, error)

func (*DatabaseService) Import 

func (s *DatabaseService) Import(stream orlydbv1.DatabaseService_ImportServer) error

func (*DatabaseService) ImportEventsFromStrings 

func (s *DatabaseService) ImportEventsFromStrings(ctx context.Context, req *orlydbv1.ImportEventsFromStringsRequest) (*orlydbv1.ImportResponse, error)

func (*DatabaseService) InvalidateQueryCache 

func (s *DatabaseService) InvalidateQueryCache(ctx context.Context, req *orlydbv1.Empty) (*orlydbv1.Empty, error)

func (*DatabaseService) IsFirstTimeUser 

func (s *DatabaseService) IsFirstTimeUser(ctx context.Context, req *orlydbv1.IsFirstTimeUserRequest) (*orlydbv1.IsFirstTimeUserResponse, error)

func (*DatabaseService) IsNIP43Member 

func (s *DatabaseService) IsNIP43Member(ctx context.Context, req *orlydbv1.IsNIP43MemberRequest) (*orlydbv1.IsNIP43MemberResponse, error)

func (*DatabaseService) IsSubscriptionActive 

func (s *DatabaseService) IsSubscriptionActive(ctx context.Context, req *orlydbv1.IsSubscriptionActiveRequest) (*orlydbv1.IsSubscriptionActiveResponse, error)

func (*DatabaseService) ListAllBlobUserStats 

func (s *DatabaseService) ListAllBlobUserStats(ctx context.Context, req *orlydbv1.Empty) (*orlydbv1.ListAllBlobUserStatsResponse, error)

func (*DatabaseService) ListBlobs 

func (s *DatabaseService) ListBlobs(ctx context.Context, req *orlydbv1.ListBlobsRequest) (*orlydbv1.ListBlobsResponse, error)

func (*DatabaseService) ProcessDelete 

func (s *DatabaseService) ProcessDelete(ctx context.Context, req *orlydbv1.ProcessDeleteRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) PublishNIP43MembershipEvent 

func (s *DatabaseService) PublishNIP43MembershipEvent(ctx context.Context, req *orlydbv1.PublishNIP43MembershipEventRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) QueryAllVersions 

func (s *DatabaseService) QueryAllVersions(req *orlydbv1.QueryEventsRequest, stream orlydbv1.DatabaseService_QueryAllVersionsServer) error

func (*DatabaseService) QueryDeleteEventsByTargetId 

func (s *DatabaseService) QueryDeleteEventsByTargetId(req *orlydbv1.QueryDeleteEventsByTargetIdRequest, stream orlydbv1.DatabaseService_QueryDeleteEventsByTargetIdServer) error

func (*DatabaseService) QueryEvents 

func (s *DatabaseService) QueryEvents(req *orlydbv1.QueryEventsRequest, stream orlydbv1.DatabaseService_QueryEventsServer) error

func (*DatabaseService) QueryEventsWithOptions 

func (s *DatabaseService) QueryEventsWithOptions(req *orlydbv1.QueryEventsWithOptionsRequest, stream orlydbv1.DatabaseService_QueryEventsWithOptionsServer) error

func (*DatabaseService) QueryForIds 

func (s *DatabaseService) QueryForIds(ctx context.Context, req *orlydbv1.QueryEventsRequest) (*orlydbv1.IdPkTsList, error)

func (*DatabaseService) QueryForSerials 

func (s *DatabaseService) QueryForSerials(ctx context.Context, req *orlydbv1.QueryEventsRequest) (*orlydbv1.SerialList, error)

func (*DatabaseService) Ready 

func (s *DatabaseService) Ready(ctx context.Context, req *orlydbv1.Empty) (*orlydbv1.ReadyResponse, error)

func (*DatabaseService) RecordEventAccess 

func (s *DatabaseService) RecordEventAccess(ctx context.Context, req *orlydbv1.RecordEventAccessRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) RecordPayment 

func (s *DatabaseService) RecordPayment(ctx context.Context, req *orlydbv1.RecordPaymentRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) RemoveNIP43Member 

func (s *DatabaseService) RemoveNIP43Member(ctx context.Context, req *orlydbv1.RemoveNIP43MemberRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) RunMigrations 

func (s *DatabaseService) RunMigrations(ctx context.Context, req *orlydbv1.Empty) (*orlydbv1.Empty, error)

func (*DatabaseService) SaveBlob 

func (s *DatabaseService) SaveBlob(ctx context.Context, req *orlydbv1.SaveBlobRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) SaveBlobReport 

func (s *DatabaseService) SaveBlobReport(ctx context.Context, req *orlydbv1.SaveBlobReportRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) SaveEvent 

func (s *DatabaseService) SaveEvent(ctx context.Context, req *orlydbv1.SaveEventRequest) (*orlydbv1.SaveEventResponse, error)

func (*DatabaseService) SetLogLevel 

func (s *DatabaseService) SetLogLevel(ctx context.Context, req *orlydbv1.SetLogLevelRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) SetMarker 

func (s *DatabaseService) SetMarker(ctx context.Context, req *orlydbv1.SetMarkerRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) SetRelayIdentitySecret 

func (s *DatabaseService) SetRelayIdentitySecret(ctx context.Context, req *orlydbv1.SetRelayIdentitySecretRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) StoreInviteCode 

func (s *DatabaseService) StoreInviteCode(ctx context.Context, req *orlydbv1.StoreInviteCodeRequest) (*orlydbv1.Empty, error)

func (*DatabaseService) Sync 

func (s *DatabaseService) Sync(ctx context.Context, req *orlydbv1.Empty) (*orlydbv1.Empty, error)

func (*DatabaseService) ValidateInviteCode 

func (s *DatabaseService) ValidateInviteCode(ctx context.Context, req *orlydbv1.ValidateInviteCodeRequest) (*orlydbv1.ValidateInviteCodeResponse, error)

func (*DatabaseService) WouldReplaceEvent 

func (s *DatabaseService) WouldReplaceEvent(ctx context.Context, req *orlydbv1.WouldReplaceEventRequest) (*orlydbv1.WouldReplaceEventResponse, error)

type Server 

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

Server wraps a gRPC database server.

func New 

func New(db database.Database, cfg *Config) *Server

New creates a new database gRPC server.

func (*Server) ListenAndServe 

func (s *Server) ListenAndServe(ctx context.Context, cancel context.CancelFunc) error

ListenAndServe starts the gRPC server.

func (*Server) Stop 

func (s *Server) Stop()

Stop stops the server.

Source Files

  • config.go
  • server.go
  • service.go

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.