endpoints

Documentation

Index

• 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(ctx 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 HasRest(ctx 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 (http *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 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(ctx 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 HasRest

func HasRest(ctx 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 {
}

func (*RestApi) Proto

func (http *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