server

Documentation

Index

• Constants
• Variables
• func AuthEnabled() bool
• func NewApplicationsServer(cfg *ApplicationsConfig, setters ...ApplicationsOption) pb.ApplicationsServer
• func NewHandlers(ctx context.Context, log logr.Logger, cfg *Config) (http.Handler, error)
• func NewProfilesServer(log logr.Logger, config ProfilesConfig) pb.ProfilesServer
• type ApplicationsConfig
  • func DefaultApplicationsConfig(log logr.Logger) (*ApplicationsConfig, error)
• type ApplicationsOption
  • func WithClientGetter(clientGetter kube.ClientGetter) ApplicationsOption
  • func WithKubeGetter(kubeGetter kube.KubeGetter) ApplicationsOption
• type ApplicationsOptions
• type Config
• type ProfilesConfig
  • func NewProfilesConfig(clusterConfig kube.ClusterConfig, 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 DefaultHost = "0.0.0.0"

const DefaultPort = "9001"

Variables

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

var (
	PublicRoutes = []string{
		"/v1/featureflags",
	}
)

Functions

func AuthEnabled

func AuthEnabled() bool

func NewApplicationsServer

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

NewApplicationsServer creates a grpc Applications server

func NewHandlers

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

func NewProfilesServer

func NewProfilesServer(log logr.Logger, config ProfilesConfig) pb.ProfilesServer

Types

type ApplicationsConfig

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

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

func DefaultApplicationsConfig

func DefaultApplicationsConfig(log logr.Logger) (*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 kube.ClientGetter) ApplicationsOption

WithClientGetter allows for setting a ClientGetter.

func WithKubeGetter

func WithKubeGetter(kubeGetter kube.KubeGetter) ApplicationsOption

WithKubeGetter allows for setting a KubeGetter.

type ApplicationsOptions

type ApplicationsOptions struct {
	ClientGetter kube.ClientGetter
	KubeGetter   kube.KubeGetter
}

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

type Config

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

type ProfilesConfig

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

func NewProfilesConfig

func NewProfilesConfig(clusterConfig kube.ClusterConfig, helmCache cache.Cache, helmRepoNamespace, helmRepoName string) ProfilesConfig

type ProfilesServer

type ProfilesServer struct {
	pb.UnimplementedProfilesServer

	Log               logr.Logger
	HelmRepoName      string
	HelmRepoNamespace string
	HelmCache         cache.Cache
	ClientGetter      kube.ClientGetter
}

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)