istio

Documentation

Index

• Variables
• func NewHTTPRoute(watcher *v1beta2.Watcher) (*istioapiv1beta1.HTTPRoute, error)
• type Client
  • func NewIstioClient(cfg *rest.Config, logger logr.Logger) (*Client, error)
  • func (c *Client) CreateVirtualService(ctx context.Context, virtualService *istioclientapiv1beta1.VirtualService) error
  • func (c *Client) DeleteVirtualService(ctx context.Context, name, namespace string) error
  • func (c *Client) GetVirtualService(ctx context.Context, name, namespace string) (*istioclientapiv1beta1.VirtualService, error)
  • func (c *Client) ListGatewaysByLabelSelector(ctx context.Context, labelSelector *apimetav1.LabelSelector, ...) (*istioclientapiv1beta1.GatewayList, error)
  • func (c *Client) ListVirtualServices(ctx context.Context, namespace string) (*istioclientapiv1beta1.VirtualServiceList, error)
  • func (c *Client) UpdateVirtualService(ctx context.Context, ...) error
• type VirtualServiceFactory
• type VirtualServiceService
  • func NewVirtualServiceService(scheme *machineryruntime.Scheme) (*VirtualServiceService, error)
  • func (vss *VirtualServiceService) NewVirtualService(watcher *v1beta2.Watcher, gateways *istioclientapiv1beta1.GatewayList) (*istioclientapiv1beta1.VirtualService, error)

Variables

var (
	ErrFailedToCreateIstioClient         = errors.New("failed to create istio client from config")
	ErrFailedToGetVirtualService         = errors.New("failed to get virtual service")
	ErrFailedToListVirtualServices       = errors.New("failed to list virtual services")
	ErrFailedToCreateVirtualService      = errors.New("failed to create virtual service")
	ErrFailedToUpdateVirtualService      = errors.New("failed to update virtual service")
	ErrFailedToDeleteVirtualService      = errors.New("failed to delete virtual service")
	ErrFailedToConvertLabelSelector      = errors.New("failed to convert label selector to selector")
	ErrFailedToGetGatewayByLabelSelector = errors.New("failed to get gateway by label selector")
	ErrFailedToAddOwnerReference         = errors.New("failed to add owner reference")
	ErrCantFindMatchingGateway           = errors.New("can't find matching Istio Gateway")
	ErrInvalidArgument                   = errors.New("invalid argument")
	ErrCantFindGatewayServersHost        = errors.New("can't find Istio Gateway servers hosts")
)

Functions

func NewHTTPRoute

func NewHTTPRoute(watcher *v1beta2.Watcher) (*istioapiv1beta1.HTTPRoute, error)

Types

type Client

type Client struct {
	istioclient.Interface
	// contains filtered or unexported fields
}

func NewIstioClient

func NewIstioClient(cfg *rest.Config, logger logr.Logger) (*Client, error)

func (*Client) CreateVirtualService

func (c *Client) CreateVirtualService(ctx context.Context, virtualService *istioclientapiv1beta1.VirtualService) error

func (*Client) DeleteVirtualService

func (c *Client) DeleteVirtualService(ctx context.Context, name, namespace string,
) error

func (*Client) GetVirtualService

func (c *Client) GetVirtualService(ctx context.Context, name, namespace string) (*istioclientapiv1beta1.VirtualService,
	error,
)

func (*Client) ListGatewaysByLabelSelector

func (c *Client) ListGatewaysByLabelSelector(ctx context.Context, labelSelector *apimetav1.LabelSelector,
	gatewayNamespace string) (*istioclientapiv1beta1.GatewayList,
	error,
)

func (*Client) ListVirtualServices

func (c *Client) ListVirtualServices(ctx context.Context, namespace string) (*istioclientapiv1beta1.VirtualServiceList,
	error,
)

func (*Client) UpdateVirtualService

func (c *Client) UpdateVirtualService(ctx context.Context, virtualService,
	virtualServiceRemote *istioclientapiv1beta1.VirtualService,
) error

type VirtualServiceFactory

type VirtualServiceFactory interface {
	NewVirtualService(watcher *v1beta2.Watcher, gateways *istioclientapiv1beta1.GatewayList) (*istioclientapiv1beta1.VirtualService, error)
}

type VirtualServiceService

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

func NewVirtualServiceService

func NewVirtualServiceService(scheme *machineryruntime.Scheme) (*VirtualServiceService, error)

func (*VirtualServiceService) NewVirtualService

func (vss *VirtualServiceService) NewVirtualService(watcher *v1beta2.Watcher, gateways *istioclientapiv1beta1.GatewayList) (*istioclientapiv1beta1.VirtualService, error)