grpc

Documentation

Index

• Constants
• type ClientConn
  • func Dial(ctx context.Context, target string, conf *tls.Config, opts ...grpc.DialOption) (*ClientConn, error)
  • func (c *ClientConn) Close() error
  • func (c *ClientConn) NewApplicationDeploymentServiceClient() evapb.ApplicationDeploymentServiceClient
  • func (c *ClientConn) NewApplicationLifecycleServiceClient() evapb.ApplicationLifecycleServiceClient
  • func (c *ClientConn) NewApplicationPolicyServiceClient() elapb.ApplicationPolicyServiceClient
  • func (c *ClientConn) NewDNSServiceClient() elapb.DNSServiceClient
  • func (c *ClientConn) NewInterfacePolicyServiceClient() elapb.InterfacePolicyServiceClient
  • func (c *ClientConn) NewInterfaceServiceClient() elapb.InterfaceServiceClient
  • func (c *ClientConn) NewZoneServiceClient() elapb.ZoneServiceClient
• type Server
  • func NewServer(controller *cce.Controller, conf *tls.Config) *Server
  • func (s *Server) GetContainerByIP(ctx context.Context, containerIP *evapb.ContainerIP) (*evapb.ContainerInfo, error)
  • func (s *Server) GracefulStop()
  • func (s *Server) RequestCredentials(ctx context.Context, id *authpb.Identity) (*authpb.Credentials, error)
  • func (s *Server) Serve(lis net.Listener) error
  • func (s *Server) Stop()

Constants

const (
	// SNI is the server name for TLS when connecting to the Controller post-enrollment
	SNI = "controller.openness"
	// EnrollmentSNI is the server name for TLS when connecting to the Controller for enrollment
	EnrollmentSNI = "enroll.controller.openness"
)

Types

type ClientConn

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

ClientConn wraps grpc.ClientConn

func Dial

func Dial(ctx context.Context, target string, conf *tls.Config, opts ...grpc.DialOption) (*ClientConn, error)

Dial dials the remote server.

func (*ClientConn) Close

func (c *ClientConn) Close() error

Close wraps grpc.Close()

func (*ClientConn) NewApplicationDeploymentServiceClient

func (c *ClientConn) NewApplicationDeploymentServiceClient() evapb.ApplicationDeploymentServiceClient

NewApplicationDeploymentServiceClient wraps the pb function.

func (*ClientConn) NewApplicationLifecycleServiceClient

func (c *ClientConn) NewApplicationLifecycleServiceClient() evapb.ApplicationLifecycleServiceClient

NewApplicationLifecycleServiceClient wraps the pb function.

func (*ClientConn) NewApplicationPolicyServiceClient

func (c *ClientConn) NewApplicationPolicyServiceClient() elapb.ApplicationPolicyServiceClient

NewApplicationPolicyServiceClient wraps the pb function.

func (*ClientConn) NewDNSServiceClient

func (c *ClientConn) NewDNSServiceClient() elapb.DNSServiceClient

NewDNSServiceClient wraps the pb function.

func (*ClientConn) NewInterfacePolicyServiceClient

func (c *ClientConn) NewInterfacePolicyServiceClient() elapb.InterfacePolicyServiceClient

NewInterfacePolicyServiceClient wraps the pb function.

func (*ClientConn) NewInterfaceServiceClient

func (c *ClientConn) NewInterfaceServiceClient() elapb.InterfaceServiceClient

NewInterfaceServiceClient wraps the pb function.

func (*ClientConn) NewZoneServiceClient

func (c *ClientConn) NewZoneServiceClient() elapb.ZoneServiceClient

NewZoneServiceClient wraps the pb function.

type Server

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

Server wraps grpc.Server

func NewServer

func NewServer(controller *cce.Controller, conf *tls.Config) *Server

NewServer creates a new Server.

func (*Server) GetContainerByIP

func (s *Server) GetContainerByIP(ctx context.Context, containerIP *evapb.ContainerIP) (*evapb.ContainerInfo, error)

GetContainerByIP retrieves info of deployed application with IP provided

func (*Server) GracefulStop

func (s *Server) GracefulStop()

GracefulStop wraps grpc.Server.GracefulStop.

func (*Server) RequestCredentials

func (s *Server) RequestCredentials(ctx context.Context, id *authpb.Identity) (
	*authpb.Credentials,
	error,
)

RequestCredentials requests authentication endpoint credentials.

func (*Server) Serve

func (s *Server) Serve(lis net.Listener) error

Serve wraps grpc.Server.Serve.

func (*Server) Stop

func (s *Server) Stop()

Stop wraps grpc.Server.Stop.