smi

Documentation

Index

• func HTTPRouteGroupFromKube(sp *v1alpha1.HTTPRouteGroup) *sgspecs.HTTPRouteGroup
• func HTTPRouteGroupToKube(resource resources.Resource) (*v1alpha1.HTTPRouteGroup, error)
• func NewHTTPRouteGroupClient(specsClient specsclient.Interface, cache Cache) sgspecs.HTTPRouteGroupClient
• func NewSMICache(ctx context.Context, accessClient accessclient.Interface, ...) (*smiCache, error)
• func NewTrafficSplitClient(splitClient splitclient.Interface, cache Cache) sgsplit.TrafficSplitClient
• func NewTrafficTargetClient(accessClient accessclient.Interface, cache Cache) sgaccess.TrafficTargetClient
• func TrafficSplitFromKube(sp *v1alpha1.TrafficSplit) *sgsplit.TrafficSplit
• func TrafficSplitToKube(resource resources.Resource) (*v1alpha1.TrafficSplit, error)
• func TrafficTargetFromKube(sp *v1alpha1.TrafficTarget) *sgaccess.TrafficTarget
• func TrafficTargetToKube(resource resources.Resource) (*v1alpha1.TrafficTarget, error)
• type Cache

Functions

func HTTPRouteGroupFromKube

func HTTPRouteGroupFromKube(sp *v1alpha1.HTTPRouteGroup) *sgspecs.HTTPRouteGroup

func HTTPRouteGroupToKube

func HTTPRouteGroupToKube(resource resources.Resource) (*v1alpha1.HTTPRouteGroup, error)

func NewHTTPRouteGroupClient

func NewHTTPRouteGroupClient(specsClient specsclient.Interface, cache Cache) sgspecs.HTTPRouteGroupClient

func NewSMICache

func NewSMICache(ctx context.Context,
	accessClient accessclient.Interface,
	specsClient specsclient.Interface,
	splitClient splitclient.Interface) (*smiCache, error)

This context should live as long as the cache is desired. i.e. if the cache is shared across clients, it should get a context that has a longer lifetime than the clients themselves

func NewTrafficSplitClient

func NewTrafficSplitClient(splitClient splitclient.Interface, cache Cache) sgsplit.TrafficSplitClient

func NewTrafficTargetClient

func NewTrafficTargetClient(accessClient accessclient.Interface, cache Cache) sgaccess.TrafficTargetClient

func TrafficSplitFromKube

func TrafficSplitFromKube(sp *v1alpha1.TrafficSplit) *sgsplit.TrafficSplit

func TrafficSplitToKube

func TrafficSplitToKube(resource resources.Resource) (*v1alpha1.TrafficSplit, error)

func TrafficTargetFromKube

func TrafficTargetFromKube(sp *v1alpha1.TrafficTarget) *sgaccess.TrafficTarget

func TrafficTargetToKube

func TrafficTargetToKube(resource resources.Resource) (*v1alpha1.TrafficTarget, error)

Types

type Cache

type Cache interface {
	TrafficTargetLister() accessv1alpha1.TrafficTargetLister
	HTTPRouteGroupLister() specsv1alpha1.HTTPRouteGroupLister
	TrafficSplitLister() splitv1alpha1.TrafficSplitLister
	Subscribe() <-chan struct{}
	Unsubscribe(<-chan struct{})
}