endpoint

Documentation

Index

• Constants
• Variables
• func GetConn(r *http.Request) net.Conn
• type Bootstrap
  • func (b *Bootstrap) FileWatcherProvider() *FileWatcherCertProviderConfig
• type CertificateProvider
• type Config
• type EchoGrpcHandler
  • 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 FileWatcherCertProviderConfig
• type Instance
  • func New(cfg Config) (Instance, error)
• type IsServerReadyFunc
• type OnReadyFunc

Constants

const FileWatcherCertProviderName = "file_watcher"

Variables

var ConnContextKey = &contextKey{"http-conn"}

Functions

func GetConn

func GetConn(r *http.Request) net.Conn

Types

type Bootstrap

type Bootstrap struct {
	CertProviders map[string]CertificateProvider `json:"certificate_providers,omitempty"`
}

func (*Bootstrap) FileWatcherProvider

func (b *Bootstrap) FileWatcherProvider() *FileWatcherCertProviderConfig

FileWatcherProvider returns the FileWatcherCertProviderConfig if one exists in CertProviders

type CertificateProvider

type CertificateProvider struct {
	PluginName string                        `json:"plugin_name,omitempty"`
	Config     FileWatcherCertProviderConfig `json:"config,omitempty"`
}

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
	Namespace     string
	DisableALPN   bool
	ReportRequest func()
}

Config for a single endpoint Instance.

type EchoGrpcHandler

type EchoGrpcHandler struct {
	proto.UnimplementedEchoTestServiceServer
	Config
	Forwarder *forwarder.Instance
}

func (*EchoGrpcHandler) Echo

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

func (*EchoGrpcHandler) ForwardEcho

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

type FileWatcherCertProviderConfig

type FileWatcherCertProviderConfig struct {
	CertificateFile   string          `json:"certificate_file,omitempty"`
	PrivateKeyFile    string          `json:"private_key_file,omitempty"`
	CACertificateFile string          `json:"ca_certificate_file,omitempty"`
	RefreshDuration   json.RawMessage `json:"refresh_interval,omitempty"`
}

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

func New(cfg Config) (Instance, error)

New creates a new endpoint Instance.

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.