pilotutil

Documentation

Index

• func DialPilotService(ctx context.Context, host string, port int) (client pbpilot.PilotServiceClient, conn *grpc.ClientConn, err error)
• func DialPilotServiceForFrontgate_TLS(ctx context.Context, host string, port int, tlsConfig *tls.Config) (client pbpilot.PilotServiceForFrontgateClient, conn *grpc.ClientConn, ...)
• func LoadPilotClientTLSConfig(certFile, keyFile, caCertFile, tlsServerName string) (p *pbtypes.PilotClientTLSConfig, err error)
• func LoadPilotConfig(path string) (*pbtypes.PilotConfig, error)
• func LoadPilotTLSConfig(serverCertFile, serverKeyFile string, clientCertFile, clientKeyFile string, ...) (p *pbtypes.PilotTLSConfig, err error)
• func MustLoadPilotConfig(path string) *pbtypes.PilotConfig
• func NewClientTLSConfigFromPbConfig(pbcfg *pbtypes.PilotClientTLSConfig) (*tls.Config, error)
• func NewServerTLSConfigFromPbConfig(pbcfg *pbtypes.PilotTLSConfig) (*tls.Config, error)
• type FrameChannel
  • func DialFrontgateChannelTLS(ctx context.Context, target string, tlsConfig *tls.Config, ...) (ch *FrameChannel, conn *grpc.ClientConn, err error)
  • func NewFrameChannel(recv func() ([]byte, error), send func(data []byte) error, close func() error) *FrameChannel
  • func NewFrontgateChannelFromClient(ch pbpilot.PilotServiceForFrontgate_FrontgateChannelClient) *FrameChannel
  • func NewFrontgateChannelFromServer(ch pbpilot.PilotServiceForFrontgate_FrontgateChannelServer) *FrameChannel
  • func (p *FrameChannel) Close() error
  • func (p *FrameChannel) Read(data []byte) (n int, err error)
  • func (p *FrameChannel) Write(data []byte) (n int, err error)

Functions

func DialPilotService

func DialPilotService(ctx context.Context, host string, port int) (
	client pbpilot.PilotServiceClient,
	conn *grpc.ClientConn,
	err error,
)

func DialPilotServiceForFrontgate_TLS

func DialPilotServiceForFrontgate_TLS(
	ctx context.Context, host string, port int,
	tlsConfig *tls.Config,
) (
	client pbpilot.PilotServiceForFrontgateClient,
	conn *grpc.ClientConn,
	err error,
)

func LoadPilotClientTLSConfig

func LoadPilotClientTLSConfig(
	certFile, keyFile, caCertFile, tlsServerName string,
) (p *pbtypes.PilotClientTLSConfig, err error)

func LoadPilotConfig

func LoadPilotConfig(path string) (*pbtypes.PilotConfig, error)

func LoadPilotTLSConfig

func LoadPilotTLSConfig(
	serverCertFile, serverKeyFile string,
	clientCertFile, clientKeyFile string,
	caCertFile string,
	tlsServerName string,
) (p *pbtypes.PilotTLSConfig, err error)

func MustLoadPilotConfig

func MustLoadPilotConfig(path string) *pbtypes.PilotConfig

func NewClientTLSConfigFromPbConfig

func NewClientTLSConfigFromPbConfig(pbcfg *pbtypes.PilotClientTLSConfig) (*tls.Config, error)

func NewServerTLSConfigFromPbConfig

func NewServerTLSConfigFromPbConfig(pbcfg *pbtypes.PilotTLSConfig) (*tls.Config, error)

Types

type FrameChannel

type FrameChannel struct {
	RecvMsgFunc func() ([]byte, error)
	SendMsgFunc func(data []byte) error
	CloseFunc   func() error
	// contains filtered or unexported fields
}

func DialFrontgateChannelTLS

func DialFrontgateChannelTLS(
	ctx context.Context, target string, tlsConfig *tls.Config,
	opts ...grpc.DialOption,
) (
	ch *FrameChannel, conn *grpc.ClientConn,
	err error,
)

func NewFrameChannel

func NewFrameChannel(
	recv func() ([]byte, error), send func(data []byte) error,
	close func() error,
) *FrameChannel

func NewFrontgateChannelFromClient

func NewFrontgateChannelFromClient(ch pbpilot.PilotServiceForFrontgate_FrontgateChannelClient) *FrameChannel

func NewFrontgateChannelFromServer

func NewFrontgateChannelFromServer(ch pbpilot.PilotServiceForFrontgate_FrontgateChannelServer) *FrameChannel

func (*FrameChannel) Close

func (p *FrameChannel) Close() error

func (*FrameChannel) Read

func (p *FrameChannel) Read(data []byte) (n int, err error)

func (*FrameChannel) Write

func (p *FrameChannel) Write(data []byte) (n int, err error)