Documentation ¶
Index ¶
Constants ¶
View Source
const (
DEFAULT_PORT = ":10000"
)
Variables ¶
View Source
var DBCertPath string
View Source
var ServiceCertPath string
Functions ¶
func UnimplementedExtensionServer ¶
func UnimplementedExtensionServer()
Types ¶
type Server ¶
type Server struct { Pi v1alpha1.Pipeline ServiceCreds config.ServiceCredentials DBCreds config.DBCredentials UserDBCreds config.DBCredentials }
func NewExtensionServer ¶
func NewExtensionServer(ns string, debug bool, serviceCertPath string, dbCertPath string, pipeline v1alpha1.Pipeline) *Server
NewExtensionServer constructs a extension server based on the passed configuration, a pointer to the server is returned
func (*Server) Ping ¶
func (s *Server) Ping(ctx context.Context, request *pb.PingRequest) (response *pb.PingResponse, err error)
func (*Server) Push ¶
func (s *Server) Push(ctx context.Context, request *pb.PushRequest) (response *pb.PushResponse, err error)
func (*Server) SetupCredentials ¶
Click to show internal directories.
Click to hide internal directories.