pilotutil

Documentation

Index

• func DialPilotService(ctx context.Context, host string, port int) (client pbpilot.PilotServiceClient, conn *grpc.ClientConn, err error)
• func LoadPilotConfig(path string) (*pbtypes.PilotConfig, error)
• func MustLoadPilotConfig(path string) *pbtypes.PilotConfig
• type FrameChannel
  • func DialFrontgateChannel(ctx context.Context, target string, opts ...grpc.DialOption) (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.PilotService_FrontgateChannelClient) *FrameChannel
  • func NewFrontgateChannelFromServer(ch pbpilot.PilotService_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 LoadPilotConfig

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

func MustLoadPilotConfig

func MustLoadPilotConfig(path string) *pbtypes.PilotConfig

Types

type FrameChannel

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

func DialFrontgateChannel

func DialFrontgateChannel(
	ctx context.Context, target string,
	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.PilotService_FrontgateChannelClient) *FrameChannel

func NewFrontgateChannelFromServer

func NewFrontgateChannelFromServer(ch pbpilot.PilotService_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)