Versions in this module Expand all Collapse all v0 v0.0.1 Sep 16, 2021 Changes in this version + const DEFAULT_PORT + var DBCertPath string + var ServiceCertPath string + func UnimplementedExtensionServer() + type Server struct + DBCreds config.DBCredentials + Pi v1alpha1.Pipeline + ServiceCreds config.ServiceCredentials + UserDBCreds config.DBCredentials + func NewExtensionServer(ns string, debug bool, serviceCertPath string, dbCertPath string, ...) *Server + func (s *Server) Ping(ctx context.Context, request *pb.PingRequest) (response *pb.PingResponse, err error) + func (s *Server) Push(ctx context.Context, request *pb.PushRequest) (response *pb.PushResponse, err error) + func (s *Server) SetupCredentials(ns, serviceCertPath, dbCertPath string) (err error)