eks

Documentation

Index

• Variables
• func Kubeconfig(awsCluster *AwsCluster, envName string) (*clientcmdapi.Config, error)
• func KubeconfigFromCluster(ctx context.Context, s *Session, clusterName string) (*clientcmdapi.Config, error)
• func PrepareClusterInfo(ctx context.Context, s *Session) (*fneks.EKSCluster, error)
• func Register()
• func RegisterGraphHandlers()
• func SetupAutopush(eksCluster *fneks.EKSCluster, iamRole string, roleArn string) ([]defs.MakeDefinition, error)
• type AwsCluster
  • func DescribeCluster(ctx context.Context, s *Session, name string) (*AwsCluster, error)
• type OpEnsureAwsAuth
  • func (*OpEnsureAwsAuth) Descriptor() ([]byte, []int)
  • func (x *OpEnsureAwsAuth) GetGroup() []string
  • func (x *OpEnsureAwsAuth) GetRolearn() string
  • func (x *OpEnsureAwsAuth) GetUsername() string
  • func (*OpEnsureAwsAuth) ProtoMessage()
  • func (x *OpEnsureAwsAuth) ProtoReflect() protoreflect.Message
  • func (x *OpEnsureAwsAuth) Reset()
  • func (x *OpEnsureAwsAuth) String() string
• type Session
  • func NewOptionalSession(ctx context.Context, cfg cfg.Configuration) (*Session, error)
  • func NewSession(ctx context.Context, cfg cfg.Configuration) (*Session, error)
• type Token
  • func ComputeBearerToken(ctx context.Context, s *Session, clusterName string) (Token, error)

Variables

var File_internal_providers_aws_eks_op_proto protoreflect.FileDescriptor

Functions

func Kubeconfig

func Kubeconfig(awsCluster *AwsCluster, envName string) (*clientcmdapi.Config, error)

func KubeconfigFromCluster

func KubeconfigFromCluster(ctx context.Context, s *Session, clusterName string) (*clientcmdapi.Config, error)

func PrepareClusterInfo

func PrepareClusterInfo(ctx context.Context, s *Session) (*fneks.EKSCluster, error)

func Register

func Register()

func RegisterGraphHandlers

func RegisterGraphHandlers()

func SetupAutopush

func SetupAutopush(eksCluster *fneks.EKSCluster, iamRole string, roleArn string) ([]defs.MakeDefinition, error)

Types

type AwsCluster

type AwsCluster struct {
	Cluster         *types.Cluster
	HasOidcProvider bool
}

func DescribeCluster

func DescribeCluster(ctx context.Context, s *Session, name string) (*AwsCluster, error)

type OpEnsureAwsAuth

type OpEnsureAwsAuth struct {
	Username string   `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Rolearn  string   `protobuf:"bytes,2,opt,name=rolearn,proto3" json:"rolearn,omitempty"`
	Group    []string `protobuf:"bytes,3,rep,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*OpEnsureAwsAuth) Descriptor

func (*OpEnsureAwsAuth) Descriptor() ([]byte, []int)

Deprecated: Use OpEnsureAwsAuth.ProtoReflect.Descriptor instead.

func (*OpEnsureAwsAuth) GetGroup

func (x *OpEnsureAwsAuth) GetGroup() []string

func (*OpEnsureAwsAuth) GetRolearn

func (x *OpEnsureAwsAuth) GetRolearn() string

func (*OpEnsureAwsAuth) GetUsername

func (x *OpEnsureAwsAuth) GetUsername() string

func (*OpEnsureAwsAuth) ProtoMessage

func (*OpEnsureAwsAuth) ProtoMessage()

func (*OpEnsureAwsAuth) ProtoReflect

func (x *OpEnsureAwsAuth) ProtoReflect() protoreflect.Message

func (*OpEnsureAwsAuth) Reset

func (x *OpEnsureAwsAuth) Reset()

func (*OpEnsureAwsAuth) String

func (x *OpEnsureAwsAuth) String() string

type Session

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

func NewOptionalSession

func NewOptionalSession(ctx context.Context, cfg cfg.Configuration) (*Session, error)

func NewSession

func NewSession(ctx context.Context, cfg cfg.Configuration) (*Session, error)

type Token

type Token struct {
	Token      string
	Expiration time.Time
}

Token is generated and used by Kubernetes client-go to authenticate with a Kubernetes cluster.

func ComputeBearerToken

func ComputeBearerToken(ctx context.Context, s *Session, clusterName string) (Token, error)