rpcserver

Documentation

Index

• Constants
• type Option
  • func WithGRPCServerOptions(opts []grpc.ServerOption) Option
  • func WithSelfSignedCert(tlsCert *tls.Certificate) Option
• type SelfSignedCert
• type Server
  • func New(cfg *config.Config, database *database.Database, cache *cache.Cache, ...) (*Server, *grpc.Server, error)

Constants

const (
	// DefaultPeerCacheExpiration is default expiration of peer cache.
	DefaultPeerCacheExpiration = 10 * time.Minute

	// DefaultPeerCacheCleanupInterval is default cleanup interval of peer cache.
	DefaultPeerCacheCleanupInterval = 1 * time.Minute
)

Types

type Option

type Option func(s *Server) error

Option is a functional option for rpc server.

func WithGRPCServerOptions

func WithGRPCServerOptions(opts []grpc.ServerOption) Option

WithGRPCServerOptions set the server options of grpc.

func WithSelfSignedCert

func WithSelfSignedCert(tlsCert *tls.Certificate) Option

WithCertificate set the self signed certificate for server.

type SelfSignedCert

type SelfSignedCert struct {
	// TLSCert is certificate of tls.
	TLSCert *tls.Certificate

	// X509Cert is certificate of x509.
	X509Cert *x509.Certificate

	// CertChain is certificate chain of ASN.1 DER form.
	CertChain [][]byte
}

SelfSignedCert is self signed certificate.

type Server

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

Server is grpc server.

func New

func New(
	cfg *config.Config, database *database.Database, cache *cache.Cache, searcher searcher.Searcher,
	objectStorage objectstorage.ObjectStorage, objectStorageConfig *config.ObjectStorageConfig, opts ...Option,
) (*Server, *grpc.Server, error)

New returns a new manager server from the given options.