remote

Documentation

Index

• Constants
• type Server
  • func New(l hclog.Logger, certPool *x509.CertPool, cert *tls.Certificate, ...) *Server
  • func (s *Server) Closed() bool
  • func (s *Server) DestroyService(ctx context.Context, dr *shipyard.DestroyRequest) (*shipyard.NullMessage, error)
  • func (s *Server) ExposeService(ctx context.Context, r *shipyard.ExposeRequest) (*shipyard.ExposeResponse, error)
  • func (s *Server) ListServices(ctx context.Context, m *shipyard.NullMessage) (*shipyard.ListResponse, error)
  • func (s *Server) OpenStream(svr shipyard.RemoteConnection_OpenStreamServer) error
  • func (s *Server) Shutdown()

Constants

const MessageSize = 4096 // 4k data payload

Types

type Server

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

func New

func New(l hclog.Logger, certPool *x509.CertPool, cert *tls.Certificate, integr integrations.Integration) *Server

New creates a new gRPC remote connector server

func (*Server) Closed

func (s *Server) Closed() bool

Closed returns true or false if server shutdown has been called

func (*Server) DestroyService

func (s *Server) DestroyService(ctx context.Context, dr *shipyard.DestroyRequest) (*shipyard.NullMessage, error)

DestroyService is the public gRPC API method to remove a service

func (*Server) ExposeService

func (s *Server) ExposeService(ctx context.Context, r *shipyard.ExposeRequest) (*shipyard.ExposeResponse, error)

ExposeService is the public gRPC API method for creating a service connection

func (*Server) ListServices

func (s *Server) ListServices(ctx context.Context, m *shipyard.NullMessage) (*shipyard.ListResponse, error)

ListServices returns a list of active services along with their state

func (*Server) OpenStream

func (s *Server) OpenStream(svr shipyard.RemoteConnection_OpenStreamServer) error

OpenStream is a called by a remote server to open a bidirectional stream between two Connectors

func (*Server) Shutdown

func (s *Server) Shutdown()

Shutdown the server, closing all connections and listeners