endpoints

package

v0.0.60 Latest Latest Go to latest Published: Dec 19, 2023 License: MIT Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/codefly-dev/core

Links

Open Source Insights

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(ctx context.Context, endpoint *configurations.Endpoint, filename string) (*basev1.Endpoint, error)
func NewRestAPI(ctx context.Context, 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(ctx context.Context, 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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func BaseProto ¶ added in v0.0.51

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

func Condensed ¶ added in v0.0.31

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

func CondensedOutput ¶ added in v0.0.31

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

func Destination ¶ added in v0.0.31

func Destination(e *basev1.Endpoint) string

func DetectNewRoutes ¶ added in v0.0.28

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

func FindEndpointForRoute ¶ added in v0.0.32

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

func FlattenEndpoints ¶ added in v0.0.28

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

func FlattenRestRoutes ¶ added in v0.0.28

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

func FromProtoAPI ¶ added in v0.0.51

func FromProtoAPI(api *basev1.API) string

func FromProtoEndpoint ¶

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

func FromProtoEndpoints ¶ added in v0.0.51

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

func HasRest ¶ added in v0.0.32

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

func Light ¶

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

func LightAPI ¶ added in v0.0.51

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

func NewGrpcAPI ¶ added in v0.0.51

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

func NewRestAPI ¶ added in v0.0.51

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

func NewRestAPIFromOpenAPI ¶ added in v0.0.51

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

func StandardPort ¶

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

func WhichAPI ¶ added in v0.0.51

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

func WhichAPIFromEndpoint ¶ added in v0.0.51

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

func WithAPI ¶ added in v0.0.51

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

Types ¶

type APISource ¶ added in v0.0.51

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

type Forwarding ¶

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

type GrpcAPI ¶ added in v0.0.51

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

func (*GrpcAPI) Proto ¶ added in v0.0.51

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

type NilAPIError ¶ added in v0.0.51

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

func (*NilAPIError) Error ¶ added in v0.0.51

func (err *NilAPIError) Error() string

type NilEndpointError ¶

type NilEndpointError struct{}

func (NilEndpointError) Error ¶

func (n NilEndpointError) Error() string

type RestAPI ¶ added in v0.0.51

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

func (*RestAPI) Proto ¶ added in v0.0.51

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 ¶ added in v0.0.51

type TCP struct{}

func NewTCP ¶ added in v0.0.51

func NewTCP() (*TCP, error)

func (*TCP) Proto ¶ added in v0.0.51

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

type UnknownAPIError ¶ added in v0.0.51

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

func (*UnknownAPIError) Error ¶ added in v0.0.51

func (err *UnknownAPIError) Error() string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL