endpoint

type Config ¶

type Config struct {
	IsServerReady IsServerReadyFunc
	Version       string
	Cluster       string
	TLSCert       string
	TLSKey        string
	UDSServer     string
	Dialer        common.Dialer
	Port          *common.Port
	ListenerIP    string
	IstioVersion  string
	DisableALPN   bool
}

Config for a single endpoint Instance.

type EchoGrpcHandler ¶

type EchoGrpcHandler struct {
	proto.UnimplementedEchoTestServiceServer
	Config
}

func (h *EchoGrpcHandler) Echo(ctx context.Context, req *proto.EchoRequest) (*proto.EchoResponse, error)

func (h *EchoGrpcHandler) ForwardEcho(ctx context.Context, req *proto.ForwardEchoRequest) (*proto.ForwardEchoResponse, error)

type Instance ¶

type Instance interface {
	io.Closer
	Start(onReady OnReadyFunc) error
	GetConfig() Config
}

Instance of an endpoint that serves the Echo application on a single port/protocol.

func New(cfg Config) (Instance, error)

type IsServerReadyFunc ¶

type IsServerReadyFunc func() bool

IsServerReadyFunc is a function that indicates whether the server is currently ready to handle traffic.

type OnReadyFunc ¶

type OnReadyFunc func()

OnReadyFunc is a callback function that informs the server that the endpoint is ready.