endpoints

Documentation

Index

• func BaseProto(e *configurations.Endpoint) *basev1.Endpoint
• func Condensed(es []*basev1.Endpoint) []string
• func CondensedOutput(group *basev1.EndpointGroup) []string
• func Destination(e *basev1.Endpoint) string
• func DetectNewRoutes(ctx context.Context, known []*configurations.RestRoute, ...) []*configurations.RestRoute
• func FindEndpointForRoute(ctx context.Context, endpoints []*basev1.Endpoint, ...) *basev1.Endpoint
• func FlattenEndpoints(_ context.Context, group *basev1.EndpointGroup) []*basev1.Endpoint
• func FlattenRestRoutes(ctx context.Context, group *basev1.EndpointGroup) []*basev1.RestRoute
• func FromProtoAPI(api *basev1.API) string
• func FromProtoEndpoint(e *basev1.Endpoint) (*configurations.Endpoint, error)
• func FromProtoEndpoints(es ...*basev1.Endpoint) ([]*configurations.Endpoint, error)
• func HasRest(_ context.Context, api *basev1.API) *basev1.RestAPI
• func Light(e *basev1.Endpoint) *basev1.Endpoint
• func LightAPI(api *basev1.API) *basev1.API
• func NewGrpcAPI(endpoint *configurations.Endpoint, filename string) (*basev1.Endpoint, error)
• func NewRestAPI(endpoint *configurations.Endpoint) (*basev1.Endpoint, error)
• func NewRestAPIFromOpenAPI(ctx context.Context, endpoint *configurations.Endpoint, filename string) (*basev1.Endpoint, error)
• func StandardPort(api *basev1.API) (int, error)
• func WhichAPI(api *basev1.API) (string, error)
• func WhichAPIFromEndpoint(endpoint *basev1.Endpoint) (string, error)
• func WithAPI(endpoint *configurations.Endpoint, source APISource) (*basev1.Endpoint, error)
• type APISource
• type Forwarding
• type GrpcAPI
  • func (grpc *GrpcAPI) Proto() (*basev1.API, error)
• type NilAPIError
  • func (err *NilAPIError) Error() string
• type NilEndpointError
  • func (n NilEndpointError) Error() string
• type RestAPI
  • func (rest *RestAPI) Proto() (*basev1.API, error)
• type ServiceForwarding
  • func (s ServiceForwarding) Forward(r *configurations.RestRoute) (*configurations.RestRoute, error)
• type TCP
  • func NewTCP() (*TCP, error)
  • func (*TCP) Proto() (*basev1.API, error)
• type UnknownAPIError
  • func (err *UnknownAPIError) Error() string

Functions

func BaseProto

func BaseProto(e *configurations.Endpoint) *basev1.Endpoint

func Condensed

func Condensed(es []*basev1.Endpoint) []string

func CondensedOutput

func CondensedOutput(group *basev1.EndpointGroup) []string

func Destination

func Destination(e *basev1.Endpoint) string

func DetectNewRoutes

func DetectNewRoutes(ctx context.Context, known []*configurations.RestRoute, group *basev1.EndpointGroup) []*configurations.RestRoute

func FindEndpointForRoute

func FindEndpointForRoute(ctx context.Context, endpoints []*basev1.Endpoint, route *configurations.RestRoute) *basev1.Endpoint

func FlattenEndpoints

func FlattenEndpoints(_ context.Context, group *basev1.EndpointGroup) []*basev1.Endpoint

func FlattenRestRoutes

func FlattenRestRoutes(ctx context.Context, group *basev1.EndpointGroup) []*basev1.RestRoute

func FromProtoAPI

func FromProtoAPI(api *basev1.API) string

func FromProtoEndpoint

func FromProtoEndpoint(e *basev1.Endpoint) (*configurations.Endpoint, error)

func FromProtoEndpoints

func FromProtoEndpoints(es ...*basev1.Endpoint) ([]*configurations.Endpoint, error)

func HasRest

func HasRest(_ context.Context, api *basev1.API) *basev1.RestAPI

func Light

func Light(e *basev1.Endpoint) *basev1.Endpoint

func LightAPI

func LightAPI(api *basev1.API) *basev1.API

func NewGrpcAPI

func NewGrpcAPI(endpoint *configurations.Endpoint, filename string) (*basev1.Endpoint, error)

func NewRestAPI

func NewRestAPI(endpoint *configurations.Endpoint) (*basev1.Endpoint, error)

func NewRestAPIFromOpenAPI

func NewRestAPIFromOpenAPI(ctx context.Context, endpoint *configurations.Endpoint, filename string) (*basev1.Endpoint, error)

func StandardPort

func StandardPort(api *basev1.API) (int, error)

func WhichAPI

func WhichAPI(api *basev1.API) (string, error)

func WhichAPIFromEndpoint

func WhichAPIFromEndpoint(endpoint *basev1.Endpoint) (string, error)

func WithAPI

func WithAPI(endpoint *configurations.Endpoint, source APISource) (*basev1.Endpoint, error)

Types

type APISource

type APISource interface {
	Proto() (*basev1.API, error)
}

type Forwarding

type Forwarding interface {
	Forward(r *configurations.RestRoute) (*configurations.RestRoute, error)
}

type GrpcAPI

type GrpcAPI struct {
	// contains filtered or unexported fields
}

func (*GrpcAPI) Proto

func (grpc *GrpcAPI) Proto() (*basev1.API, error)

type NilAPIError

type NilAPIError struct {
	// contains filtered or unexported fields
}

func (*NilAPIError) Error

func (err *NilAPIError) Error() string

type NilEndpointError

type NilEndpointError struct{}

func (NilEndpointError) Error

func (n NilEndpointError) Error() string

type RestAPI

type RestAPI struct {
	// contains filtered or unexported fields
}

func (*RestAPI) Proto

func (rest *RestAPI) Proto() (*basev1.API, error)

type ServiceForwarding

type ServiceForwarding struct {
	// contains filtered or unexported fields
}

func (ServiceForwarding) Forward

func (s ServiceForwarding) Forward(r *configurations.RestRoute) (*configurations.RestRoute, error)

type TCP

type TCP struct{}

func NewTCP

func NewTCP() (*TCP, error)

func (*TCP) Proto

func (*TCP) Proto() (*basev1.API, error)

type UnknownAPIError

type UnknownAPIError struct {
	// contains filtered or unexported fields
}

func (*UnknownAPIError) Error

func (err *UnknownAPIError) Error() string