server

Documentation

Index

• Constants
• Variables
• func AuthEnabled() bool
• func MatchGRPCError(code interface{}, err interface{}) types.GomegaMatcher
• func NewApplicationsServer(cfg *ApplicationsConfig, setters ...ApplicationsOption) pb.ApplicationsServer
• func NewHandlers(ctx context.Context, cfg *Config) (http.Handler, error)
• func NewProfilesServer(config ProfilesConfig) pb.ProfilesServer
• type ApplicationsConfig
  • func DefaultApplicationsConfig() (*ApplicationsConfig, error)
• type ApplicationsOption
  • func WithClientGetter(clientGetter ClientGetter) ApplicationsOption
• type ApplicationsOptions
• type ClientGetter
• type ClusterConfig
• type Config
• type ConfigGetter
• type DefaultClientGetter
  • func (g *DefaultClientGetter) Client(ctx context.Context) (client.Client, error)
• type DefaultFetcherFactory
  • func (f *DefaultFetcherFactory) Create(client client.Client) applicationv2.Fetcher
• type FetcherFactory
  • func NewDefaultFetcherFactory() FetcherFactory
• type ImpersonatingConfigGetter
  • func NewImpersonatingConfigGetter(cfg *rest.Config, insecure bool) *ImpersonatingConfigGetter
  • func (r *ImpersonatingConfigGetter) Config(ctx context.Context) *rest.Config
• type ProfilesConfig
  • func NewProfilesConfig(kubeClient client.Client, helmCache cache.Cache, ...) ProfilesConfig
• type ProfilesServer
  • func (s *ProfilesServer) GetProfileValues(ctx context.Context, msg *pb.GetProfileValuesRequest) (*httpbody.HttpBody, error)
  • func (s *ProfilesServer) GetProfiles(ctx context.Context, msg *pb.GetProfilesRequest) (*pb.GetProfilesResponse, error)

Constants

const (
	OctetStreamType = "application/octet-stream"
	JsonType        = "application/json"
)

const (
	AuthEnabledFeatureFlag = "WEAVE_GITOPS_AUTH_ENABLED"
)

const DefaultPort = "9001"

Variables

var (
	ErrEmptyAccessToken = errors.New("access token is empty")
	ErrBadProvider      = errors.New("wrong provider name")
)

var (
	KustomizeNameKey      = fmt.Sprintf("%s/name", kustomizev2.GroupVersion.Group)
	KustomizeNamespaceKey = fmt.Sprintf("%s/namespace", kustomizev2.GroupVersion.Group)
	HelmNameKey           = fmt.Sprintf("%s/name", helmv2.GroupVersion.Group)
	HelmNamespaceKey      = fmt.Sprintf("%s/namespace", helmv2.GroupVersion.Group)
)

Flux owner labels

Functions

func AuthEnabled

func AuthEnabled() bool

func MatchGRPCError

func MatchGRPCError(code interface{}, err interface{}) types.GomegaMatcher

func NewApplicationsServer

func NewApplicationsServer(cfg *ApplicationsConfig, setters ...ApplicationsOption) pb.ApplicationsServer

NewApplicationsServer creates a grpc Applications server

func NewHandlers

func NewHandlers(ctx context.Context, cfg *Config) (http.Handler, error)

func NewProfilesServer

func NewProfilesServer(config ProfilesConfig) pb.ProfilesServer

Types

type ApplicationsConfig

type ApplicationsConfig struct {
	Logger           logr.Logger
	Factory          services.Factory
	JwtClient        auth.JWTClient
	GithubAuthClient auth.GithubAuthClient
	FetcherFactory   FetcherFactory
	GitlabAuthClient auth.GitlabAuthClient
	ClusterConfig    ClusterConfig
}

An ApplicationsConfig allows for the customization of an ApplicationsServer. Use the DefaultConfig() to use the default dependencies.

func DefaultApplicationsConfig

func DefaultApplicationsConfig() (*ApplicationsConfig, error)

DefaultApplicationsConfig creates a populated config with the dependencies for a Server

type ApplicationsOption

type ApplicationsOption func(*ApplicationsOptions)

ApplicationsOption defines the signature of a function that can be used to set an option for an ApplicationsServer.

func WithClientGetter

func WithClientGetter(clientGetter ClientGetter) ApplicationsOption

WithClientGetter allows for setting a ClientGetter.

type ApplicationsOptions

type ApplicationsOptions struct {
	ClientGetter ClientGetter
}

ApplicationsOptions includes all the options that can be set for an ApplicationsServer.

type ClientGetter

type ClientGetter interface {
	Client(ctx context.Context) (client.Client, error)
}

ClientGetter implementations should create a Kubernetes client from a context.

type ClusterConfig

type ClusterConfig struct {
	DefaultConfig *rest.Config
	ClusterName   string
}

ClusterConfig is used to hold the default *rest.Config and the cluster name.

type Config

type Config struct {
	AppConfig      *ApplicationsConfig
	AppOptions     []ApplicationsOption
	ProfilesConfig ProfilesConfig
	AuthServer     *auth.AuthServer
}

type ConfigGetter

type ConfigGetter interface {
	Config(ctx context.Context) *rest.Config
}

ConfigGetter implementations should extract the details from a context and create a *rest.Config for use in clients.

type DefaultClientGetter

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

DefaultClientGetter implements the ClientGetter interface and uses a ConfigGetter to get a *rest.Config and create a Kubernetes client.

func (*DefaultClientGetter) Client

func (g *DefaultClientGetter) Client(ctx context.Context) (client.Client, error)

Client creates a new Kubernetes client using the *rest.Config returned from its ConfigGetter.

type DefaultFetcherFactory

type DefaultFetcherFactory struct {
}

DefaultFetcherFactory creates applicationv2.Fetcher objects from a Kubernetes client

func (*DefaultFetcherFactory) Create

func (f *DefaultFetcherFactory) Create(client client.Client) applicationv2.Fetcher

Create uses a Kubernetes client to create an applicationv2.Fetcher object.

type FetcherFactory

type FetcherFactory interface {
	Create(client client.Client) applicationv2.Fetcher
}

FetcherFactory implementations should create applicationv2.Fetcher objects from a Kubernetes client.

func NewDefaultFetcherFactory

func NewDefaultFetcherFactory() FetcherFactory

NewDefaultFetcherFactory returns a new DefaultFetcherFactory

type ImpersonatingConfigGetter

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

ImpersonatingConfigGetter is an implementation of the ConfigGetter interface that returns configs based on a base one. It inspects the context for a principal and if it finds one, it configures the *rest.Config to impersonate that principal. Otherwise it returns a copy of the base config.

func NewImpersonatingConfigGetter

func NewImpersonatingConfigGetter(cfg *rest.Config, insecure bool) *ImpersonatingConfigGetter

NewImpersonatingConfigGetter creates and returns a ConfigGetter with a known config.

func (*ImpersonatingConfigGetter) Config

func (r *ImpersonatingConfigGetter) Config(ctx context.Context) *rest.Config

Config returns a *rest.Config configured to impersonate a user or use the default service account credentials.

type ProfilesConfig

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

func NewProfilesConfig

func NewProfilesConfig(kubeClient client.Client, helmCache cache.Cache, helmRepoNamespace, helmRepoName string) ProfilesConfig

type ProfilesServer

type ProfilesServer struct {
	pb.UnimplementedProfilesServer

	KubeClient        client.Client
	Log               logr.Logger
	HelmRepoName      string
	HelmRepoNamespace string
	HelmCache         cache.Cache
}

func (*ProfilesServer) GetProfileValues

func (s *ProfilesServer) GetProfileValues(ctx context.Context, msg *pb.GetProfileValuesRequest) (*httpbody.HttpBody, error)

func (*ProfilesServer) GetProfiles

func (s *ProfilesServer) GetProfiles(ctx context.Context, msg *pb.GetProfilesRequest) (*pb.GetProfilesResponse, error)