osc

package

Go to main page

Versions in this module

v0

v0.2.6

Dec 20, 2024

v0.2.5

Aug 27, 2024

v0.2.4

Aug 9, 2024

Changes in this version

+ func NewOscClient(regionName string) (context.Context, *osc.APIClient, error)

v0.2.3

Jul 17, 2023

v0.2.2

Jul 12, 2023

v0.2.1

Jul 10, 2023

v0.2.0

Jan 9, 2023

Changes in this version

+ const ServiceAnnotationLoadBalancerSubnetID

type FakeComputeImpl

+ MainSecurityGroup *osc.SecurityGroup

type FakeELB

+ LoadBalancers map[string]*elb.LoadBalancerDescription

v0.1.1

Nov 8, 2022

v0.1.0

Oct 14, 2022

Changes in this version

+ const DefaultSgOwnerID

+ const DefaultSrcSgName

+ const LbNameMaxLength

+ const MaxReadThenCreateRetries

+ const NLBClientRuleDescription

+ const NLBHealthCheckRuleDescription

+ const NLBMtuDiscoveryRuleDescription

+ const ProviderName

+ const ProxyProtocolPolicyName

+ const ResourceLifecycleOwned

+ const ResourceLifecycleShared

+ const SSLNegotiationPolicyNameFormat

+ const ServiceAnnotationLoadBalancerAccessLogEmitInterval

+ const ServiceAnnotationLoadBalancerAccessLogEnabled

+ const ServiceAnnotationLoadBalancerAccessLogS3BucketName

+ const ServiceAnnotationLoadBalancerAccessLogS3BucketPrefix

+ const ServiceAnnotationLoadBalancerAdditionalTags

+ const ServiceAnnotationLoadBalancerBEProtocol

+ const ServiceAnnotationLoadBalancerCertificate

+ const ServiceAnnotationLoadBalancerConnectionDrainingEnabled

+ const ServiceAnnotationLoadBalancerConnectionDrainingTimeout

+ const ServiceAnnotationLoadBalancerConnectionIdleTimeout

+ const ServiceAnnotationLoadBalancerCrossZoneLoadBalancingEnabled

+ const ServiceAnnotationLoadBalancerExtraSecurityGroups

+ const ServiceAnnotationLoadBalancerHCHealthyThreshold

+ const ServiceAnnotationLoadBalancerHCInterval

+ const ServiceAnnotationLoadBalancerHCTimeout

+ const ServiceAnnotationLoadBalancerHCUnhealthyThreshold

+ const ServiceAnnotationLoadBalancerInternal

+ const ServiceAnnotationLoadBalancerName

+ const ServiceAnnotationLoadBalancerNameLength

+ const ServiceAnnotationLoadBalancerProxyProtocol

+ const ServiceAnnotationLoadBalancerSSLNegotiationPolicy

+ const ServiceAnnotationLoadBalancerSSLPorts

+ const ServiceAnnotationLoadBalancerSecurityGroups

+ const TagNameClusterNode

+ const TagNameKubernetesClusterLegacy

+ const TagNameKubernetesClusterPrefix

+ const TagNameKubernetesService

+ const TagNameMainSG

+ const TagNameSubnetInternalELB

+ const TagNameSubnetPublicELB

+ func Contains(list []string, element string) bool

+ func Endpoint(region string, service string) string

+ func NewSession(meta EC2Metadata) (*session.Session, error)

+ func SetupMetadataResolver() endpoints.ResolverFunc

+ func SetupServiceResolver(region string) endpoints.ResolverFunc

+ type Backoff struct

+ func (b *Backoff) ComputeDelayForRequest(now time.Time) time.Duration

+ func (b *Backoff) ReportError()

+ type Cloud struct

+ func (c *Cloud) AddSSHKeyToAllInstances(ctx context.Context, user string, keyData []byte) error

+ func (c *Cloud) Clusters() (cloudprovider.Clusters, bool)

+ func (c *Cloud) CreateRoute(ctx context.Context, clusterName string, nameHint string, ...) error

+ func (c *Cloud) CurrentNodeName(ctx context.Context, hostname string) (types.NodeName, error)

+ func (c *Cloud) DeleteRoute(ctx context.Context, clusterName string, route *cloudprovider.Route) error

+ func (c *Cloud) EnsureLoadBalancer(ctx context.Context, clusterName string, apiService *v1.Service, ...) (*v1.LoadBalancerStatus, error)

+ func (c *Cloud) EnsureLoadBalancerDeleted(ctx context.Context, clusterName string, service *v1.Service) error

+ func (c *Cloud) GetLoadBalancer(ctx context.Context, clusterName string, service *v1.Service) (*v1.LoadBalancerStatus, bool, error)

+ func (c *Cloud) GetLoadBalancerName(ctx context.Context, clusterName string, service *v1.Service) string

+ func (c *Cloud) GetZone(ctx context.Context) (cloudprovider.Zone, error)

+ func (c *Cloud) GetZoneByNodeName(ctx context.Context, nodeName types.NodeName) (cloudprovider.Zone, error)

+ func (c *Cloud) GetZoneByProviderID(ctx context.Context, providerID string) (cloudprovider.Zone, error)

+ func (c *Cloud) HasClusterID() bool

+ func (c *Cloud) Initialize(clientBuilder cloudprovider.ControllerClientBuilder, stop <-chan struct{})

+ func (c *Cloud) InstanceExistsByProviderID(ctx context.Context, providerID string) (bool, error)

+ func (c *Cloud) InstanceID(ctx context.Context, nodeName types.NodeName) (string, error)

+ func (c *Cloud) InstanceShutdownByProviderID(ctx context.Context, providerID string) (bool, error)

+ func (c *Cloud) InstanceType(ctx context.Context, nodeName types.NodeName) (string, error)

+ func (c *Cloud) InstanceTypeByProviderID(ctx context.Context, providerID string) (string, error)

+ func (c *Cloud) Instances() (cloudprovider.Instances, bool)

+ func (c *Cloud) InstancesV2() (cloudprovider.InstancesV2, bool)

+ func (c *Cloud) ListRoutes(ctx context.Context, clusterName string) ([]*cloudprovider.Route, error)

+ func (c *Cloud) LoadBalancer() (cloudprovider.LoadBalancer, bool)

+ func (c *Cloud) NodeAddresses(ctx context.Context, name types.NodeName) ([]v1.NodeAddress, error)

+ func (c *Cloud) NodeAddressesByProviderID(ctx context.Context, providerID string) ([]v1.NodeAddress, error)

+ func (c *Cloud) ProviderName() string

+ func (c *Cloud) Routes() (cloudprovider.Routes, bool)

+ func (c *Cloud) SetInformers(informerFactory informers.SharedInformerFactory)

+ func (c *Cloud) UpdateLoadBalancer(ctx context.Context, clusterName string, service *v1.Service, nodes []*v1.Node) error

+ func (c *Cloud) Zones() (cloudprovider.Zones, bool)

+ type CloudConfig struct

+ Global struct{ ... }

+ ServiceOverride map[string]...

+ type Compute interface

+ CreateRoute func(request *osc.CreateRouteRequest) (*osc.CreateRouteResponse, error)

+ CreateSecurityGroup func(request *osc.CreateSecurityGroupRequest) (*osc.CreateSecurityGroupResponse, error)

+ CreateSecurityGroupRule func(request *osc.CreateSecurityGroupRuleRequest) (*osc.CreateSecurityGroupRuleResponse, error)

+ CreateTags func(*osc.CreateTagsRequest) (*osc.CreateTagsResponse, error)

+ DeleteRoute func(request *osc.DeleteRouteRequest) (*osc.DeleteRouteResponse, error)

+ DeleteSecurityGroup func(request *osc.DeleteSecurityGroupRequest) (*osc.DeleteSecurityGroupResponse, error)

+ DeleteSecurityGroupRule func(request *osc.DeleteSecurityGroupRuleRequest) (*osc.DeleteSecurityGroupRuleResponse, error)

+ DescribeSubnets func(*osc.ReadSubnetsRequest) ([]osc.Subnet, error)

+ ReadRouteTables func(request *osc.ReadRouteTablesRequest) ([]osc.RouteTable, error)

+ ReadSecurityGroups func(request *osc.ReadSecurityGroupsRequest) ([]osc.SecurityGroup, error)

+ ReadVms func(request *osc.ReadVmsRequest) ([]osc.Vm, error)

+ UpdateVM func(request *osc.UpdateVmRequest) (*osc.UpdateVmResponse, error)

+ type CrossRequestRetryDelay struct

+ func NewCrossRequestRetryDelay() *CrossRequestRetryDelay

+ func (c *CrossRequestRetryDelay) AfterRetry(r *request.Request)

+ func (c *CrossRequestRetryDelay) BeforeSign(r *request.Request)

+ type EC2Metadata interface

+ Available func() bool

+ GetInstanceIdentityDocument func() (ec2metadata.EC2InstanceIdentityDocument, error)

+ GetMetadata func(path string) (string, error)

+ type FakeCompute interface

+ CreateRouteTable func(*ec2.RouteTable) (*ec2.CreateRouteTableOutput, error)

+ CreateSubnet func(*ec2.Subnet) (*ec2.CreateSubnetOutput, error)

+ RemoveRouteTables func()

+ RemoveSubnets func()

+ type FakeComputeImpl struct

+ DescribeRouteTablesInput *osc.ReadRouteTablesRequest

+ DescribeSubnetsInput *osc.ReadSubnetsRequest

+ RouteTables []osc.RouteTable

+ Subnets []osc.Subnet

+ func (ec2i *FakeComputeImpl) CreateRoute(request *osc.CreateRouteRequest) (*osc.CreateRouteResponse, error)

+ func (ec2i *FakeComputeImpl) CreateRouteTable(request *ec2.RouteTable) (*ec2.CreateRouteTableOutput, error)

+ func (ec2i *FakeComputeImpl) CreateSecurityGroup(request *osc.CreateSecurityGroupRequest) (*osc.CreateSecurityGroupResponse, error)

+ func (ec2i *FakeComputeImpl) CreateSecurityGroupRule(request *osc.CreateSecurityGroupRuleRequest) (*osc.CreateSecurityGroupRuleResponse, error)

+ func (ec2i *FakeComputeImpl) CreateSubnet(request *ec2.Subnet) (*ec2.CreateSubnetOutput, error)

+ func (ec2i *FakeComputeImpl) CreateTags(request *osc.CreateTagsRequest) (*osc.CreateTagsResponse, error)

+ func (ec2i *FakeComputeImpl) DeleteRoute(request *osc.DeleteRouteRequest) (*osc.DeleteRouteResponse, error)

+ func (ec2i *FakeComputeImpl) DeleteSecurityGroup(request *osc.DeleteSecurityGroupRequest) (*osc.DeleteSecurityGroupResponse, error)

+ func (ec2i *FakeComputeImpl) DeleteSecurityGroupRule(request *osc.DeleteSecurityGroupRuleRequest) (*osc.DeleteSecurityGroupRuleResponse, error)

+ func (ec2i *FakeComputeImpl) DescribeSubnets(request *osc.ReadSubnetsRequest) ([]osc.Subnet, error)

+ func (ec2i *FakeComputeImpl) ReadRouteTables(request *osc.ReadRouteTablesRequest) ([]osc.RouteTable, error)

+ func (ec2i *FakeComputeImpl) ReadSecurityGroups(request *osc.ReadSecurityGroupsRequest) ([]osc.SecurityGroup, error)

+ func (ec2i *FakeComputeImpl) ReadVms(request *osc.ReadVmsRequest) ([]osc.Vm, error)

+ func (ec2i *FakeComputeImpl) RemoveRouteTables()

+ func (ec2i *FakeComputeImpl) RemoveSubnets()

+ func (ec2i *FakeComputeImpl) UpdateVM(request *osc.UpdateVmRequest) (*osc.UpdateVmResponse, error)

+ type FakeELB struct

+ func (elb *FakeELB) AddTags(input *elb.AddTagsInput) (*elb.AddTagsOutput, error)

+ func (elb *FakeELB) ApplySecurityGroupsToLoadBalancer(*elb.ApplySecurityGroupsToLoadBalancerInput) (*elb.ApplySecurityGroupsToLoadBalancerOutput, error)

+ func (elb *FakeELB) AttachLoadBalancerToSubnets(*elb.AttachLoadBalancerToSubnetsInput) (*elb.AttachLoadBalancerToSubnetsOutput, error)

+ func (elb *FakeELB) ConfigureHealthCheck(*elb.ConfigureHealthCheckInput) (*elb.ConfigureHealthCheckOutput, error)

+ func (elb *FakeELB) CreateLoadBalancer(*elb.CreateLoadBalancerInput) (*elb.CreateLoadBalancerOutput, error)

+ func (elb *FakeELB) CreateLoadBalancerListeners(*elb.CreateLoadBalancerListenersInput) (*elb.CreateLoadBalancerListenersOutput, error)

+ func (elb *FakeELB) CreateLoadBalancerPolicy(*elb.CreateLoadBalancerPolicyInput) (*elb.CreateLoadBalancerPolicyOutput, error)

+ func (elb *FakeELB) DeleteLoadBalancer(input *elb.DeleteLoadBalancerInput) (*elb.DeleteLoadBalancerOutput, error)

+ func (elb *FakeELB) DeleteLoadBalancerListeners(*elb.DeleteLoadBalancerListenersInput) (*elb.DeleteLoadBalancerListenersOutput, error)

+ func (elb *FakeELB) DeregisterInstancesFromLoadBalancer(*elb.DeregisterInstancesFromLoadBalancerInput) (*elb.DeregisterInstancesFromLoadBalancerOutput, error)

+ func (elb *FakeELB) DescribeLoadBalancerAttributes(*elb.DescribeLoadBalancerAttributesInput) (*elb.DescribeLoadBalancerAttributesOutput, error)

+ func (elb *FakeELB) DescribeLoadBalancerPolicies(input *elb.DescribeLoadBalancerPoliciesInput) (*elb.DescribeLoadBalancerPoliciesOutput, error)

+ func (elb *FakeELB) DescribeLoadBalancers(input *elb.DescribeLoadBalancersInput) (*elb.DescribeLoadBalancersOutput, error)

+ func (elb *FakeELB) DetachLoadBalancerFromSubnets(*elb.DetachLoadBalancerFromSubnetsInput) (*elb.DetachLoadBalancerFromSubnetsOutput, error)

+ func (elb *FakeELB) ModifyLoadBalancerAttributes(*elb.ModifyLoadBalancerAttributesInput) (*elb.ModifyLoadBalancerAttributesOutput, error)

+ func (elb *FakeELB) RegisterInstancesWithLoadBalancer(*elb.RegisterInstancesWithLoadBalancerInput) (*elb.RegisterInstancesWithLoadBalancerOutput, error)

+ func (elb *FakeELB) SetLoadBalancerPoliciesForBackendServer(*elb.SetLoadBalancerPoliciesForBackendServerInput) (*elb.SetLoadBalancerPoliciesForBackendServerOutput, error)

+ func (elb *FakeELB) SetLoadBalancerPoliciesOfListener(input *elb.SetLoadBalancerPoliciesOfListenerInput) (*elb.SetLoadBalancerPoliciesOfListenerOutput, error)

+ type FakeMetadata struct

+ func (m *FakeMetadata) Available() bool

+ func (m *FakeMetadata) GetAvailabilityZone() string

+ func (m *FakeMetadata) GetInstanceID() string

+ func (m *FakeMetadata) GetInstanceIdentityDocument() (ec2metadata.EC2InstanceIdentityDocument, error)

+ func (m *FakeMetadata) GetInstanceType() string

+ func (m *FakeMetadata) GetMetadata(key string) (string, error)

+ func (m *FakeMetadata) GetRegion() string

+ type FakeOscServices struct

+ func NewFakeAWSServices(clusterID string) *FakeOscServices

+ func (s *FakeOscServices) Compute(region string) (Compute, error)

+ func (s *FakeOscServices) LoadBalancing(region string) (LoadBalancer, error)

+ func (s *FakeOscServices) Metadata() (EC2Metadata, error)

+ func (s *FakeOscServices) WithAz(az string) *FakeOscServices

+ type IPRulesSet map[string]osc.SecurityGroupRule

+ func NewIPRulesSet(items ...osc.SecurityGroupRule) IPRulesSet

+ func NewIPRulesSetFromAWS(items ...*ec2.IpPermission) IPRulesSet

+ func (s IPRulesSet) Difference(s2 IPRulesSet) IPRulesSet

+ func (s IPRulesSet) Insert(items ...osc.SecurityGroupRule)

+ func (s IPRulesSet) Len() int

+ func (s IPRulesSet) List() []osc.SecurityGroupRule

+ func (s IPRulesSet) Ungroup() IPRulesSet

+ type InstanceID string

+ type KubernetesInstanceID string

+ func (name KubernetesInstanceID) MapToAWSInstanceID() (InstanceID, error)

+ type LoadBalancer interface

+ AddTags func(*elb.AddTagsInput) (*elb.AddTagsOutput, error)

+ ApplySecurityGroupsToLoadBalancer func(*elb.ApplySecurityGroupsToLoadBalancerInput) (*elb.ApplySecurityGroupsToLoadBalancerOutput, error)

+ AttachLoadBalancerToSubnets func(*elb.AttachLoadBalancerToSubnetsInput) (*elb.AttachLoadBalancerToSubnetsOutput, error)

+ ConfigureHealthCheck func(*elb.ConfigureHealthCheckInput) (*elb.ConfigureHealthCheckOutput, error)

+ CreateLoadBalancer func(*elb.CreateLoadBalancerInput) (*elb.CreateLoadBalancerOutput, error)

+ CreateLoadBalancerListeners func(*elb.CreateLoadBalancerListenersInput) (*elb.CreateLoadBalancerListenersOutput, error)

+ CreateLoadBalancerPolicy func(*elb.CreateLoadBalancerPolicyInput) (*elb.CreateLoadBalancerPolicyOutput, error)

+ DeleteLoadBalancer func(*elb.DeleteLoadBalancerInput) (*elb.DeleteLoadBalancerOutput, error)

+ DeleteLoadBalancerListeners func(*elb.DeleteLoadBalancerListenersInput) (*elb.DeleteLoadBalancerListenersOutput, error)

+ DeregisterInstancesFromLoadBalancer func(*elb.DeregisterInstancesFromLoadBalancerInput) (*elb.DeregisterInstancesFromLoadBalancerOutput, error)

+ DescribeLoadBalancerAttributes func(*elb.DescribeLoadBalancerAttributesInput) (*elb.DescribeLoadBalancerAttributesOutput, error)

+ DescribeLoadBalancerPolicies func(input *elb.DescribeLoadBalancerPoliciesInput) (*elb.DescribeLoadBalancerPoliciesOutput, error)

+ DescribeLoadBalancers func(*elb.DescribeLoadBalancersInput) (*elb.DescribeLoadBalancersOutput, error)

+ DetachLoadBalancerFromSubnets func(*elb.DetachLoadBalancerFromSubnetsInput) (*elb.DetachLoadBalancerFromSubnetsOutput, error)

+ ModifyLoadBalancerAttributes func(*elb.ModifyLoadBalancerAttributesInput) (*elb.ModifyLoadBalancerAttributesOutput, error)

+ RegisterInstancesWithLoadBalancer func(*elb.RegisterInstancesWithLoadBalancerInput) (*elb.RegisterInstancesWithLoadBalancerOutput, error)

+ SetLoadBalancerPoliciesForBackendServer func(*elb.SetLoadBalancerPoliciesForBackendServerInput) (*elb.SetLoadBalancerPoliciesForBackendServerOutput, error)

+ SetLoadBalancerPoliciesOfListener func(input *elb.SetLoadBalancerPoliciesOfListenerInput) (*elb.SetLoadBalancerPoliciesOfListenerOutput, error)

+ type Metadata struct

+ AvailabilityZone string

+ Client EC2Metadata

+ InstanceID string

+ InstanceType string

+ IsAvailable bool

+ Region string

+ func (m *Metadata) Available() bool

+ func (m *Metadata) GetAvailabilityZone() string

+ func (m *Metadata) GetInstanceID() string

+ func (m *Metadata) GetInstanceIdentityDocument() (ec2metadata.EC2InstanceIdentityDocument, error)

+ func (m *Metadata) GetInstanceType() string

+ func (m *Metadata) GetMetadata(path string) (string, error)

+ func (m *Metadata) GetRegion() string

+ type MetadataService interface

+ GetAvailabilityZone func() string

+ GetInstanceID func() string

+ GetInstanceType func() string

+ GetRegion func() string

+ func NewMetadata() (MetadataService, error)

+ func NewMetadataService(svc EC2Metadata) (MetadataService, error)

+ type ResourceLifecycle string

+ type Services interface

+ Compute func(region string) (Compute, error)

+ LoadBalancing func(region string) (LoadBalancer, error)

+ Metadata func() (EC2Metadata, error)

+ type VM struct

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