Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SafeTransport ¶
func SafeTransport(rw io.ReadWriteCloser) rpc.Transport
Types ¶
type RegistrationClient ¶
type RegistrationClient interface { RegisterConnection( ctx context.Context, auth pogs.TunnelAuth, tunnelID uuid.UUID, options *pogs.ConnectionOptions, connIndex uint8, edgeAddress net.IP, ) (*pogs.ConnectionDetails, error) SendLocalConfiguration(ctx context.Context, config []byte) error GracefulShutdown(ctx context.Context, gracePeriod time.Duration) error Close() }
func NewRegistrationClient ¶
func NewRegistrationClient(ctx context.Context, stream io.ReadWriteCloser, requestTimeout time.Duration) RegistrationClient
type RegistrationServer ¶
type RegistrationServer struct {
// contains filtered or unexported fields
}
RegistrationServer provides a handler interface for a client to provide methods to handle the different types of requests that can be communicated by the stream.
func NewRegistrationServer ¶
func NewRegistrationServer(registrationServer pogs.RegistrationServer) *RegistrationServer
func (*RegistrationServer) Serve ¶
func (s *RegistrationServer) Serve(ctx context.Context, stream io.ReadWriteCloser) error
Serve listens for all RegistrationServer RPCs, including UnregisterConnection until the underlying connection is terminated.
Click to show internal directories.
Click to hide internal directories.