extension

package
v0.0.1 Latest Latest
Warning

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

Go to latest
Published: Sep 16, 2021 License: Apache-2.0 Imports: 17 Imported by: 0

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

func (s *Server) SetupCredentials(ns, serviceCertPath, dbCertPath string) (err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL