plugins

package

v0.0.1 Latest Latest Go to latest Published: Sep 10, 2020 License: Apache-2.0 Imports: 24 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cloud-native-application/rudrx

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func GetCapabilitiesFromCluster(ctx context.Context, namespace string, c client.Client, syncDir string, ...) ([]types.Capability, error)
func GetInstalledCapabilityWithCapAlias(capT types.CapType, capAlias string) (types.Capability, error)
func GetSubDir(dir string, capT types.CapType) string
func GetTraitsFromCluster(ctx context.Context, namespace string, c client.Client, syncDir string, ...) ([]types.Capability, error)
func GetWorkloadsFromCluster(ctx context.Context, namespace string, c client.Client, syncDir string, ...) ([]types.Capability, error)
func HandleDefinition(name, syncDir, crdName string, extention *runtime.RawExtension, ...) (types.Capability, error)
func HandleTemplate(in *runtime.RawExtension, name, syncDir string) (types.Capability, error)
func LoadAllInstalledCapability() ([]types.Capability, error)
func LoadCapabilityByName(name string) (types.Capability, error)
func LoadCapabilityFromSyncedCenter(dir string) ([]types.Capability, error)
func LoadInstalledCapabilityWithType(capT types.CapType) ([]types.Capability, error)
func ParseAndSyncCapability(data []byte, syncDir string) (types.Capability, error)
func SinkTemp2Local(templates []types.Capability, dir string) int
func StoreRepos(repos []CapCenterConfig) error
type CapCenterConfig
- func LoadRepos() ([]CapCenterConfig, error)
type CenterClient
- func NewCenterClient(ctx context.Context, name, address, token string) (CenterClient, error)
type GithubCenter
- func NewGithubCenter(ctx context.Context, token, centerName string, r *GithubContent) (*GithubCenter, error)
- func (g *GithubCenter) SyncCapabilityFromCenter() error
type GithubContent
- func Parse(addr string) (string, *GithubContent, error)
type RemoteCapabilities
type RemoteCapability

Constants ¶

View Source

const TypeGithub = "github"

View Source

const TypeUnknown = "unknown"

Variables ¶

This section is empty.

Functions ¶

func GetCapabilitiesFromCluster ¶

func GetCapabilitiesFromCluster(ctx context.Context, namespace string, c client.Client, syncDir string, selector labels.Selector) ([]types.Capability, error)

func GetInstalledCapabilityWithCapAlias ¶

func GetInstalledCapabilityWithCapAlias(capT types.CapType, capAlias string) (types.Capability, error)

func GetSubDir ¶

func GetSubDir(dir string, capT types.CapType) string

func GetTraitsFromCluster ¶

func GetTraitsFromCluster(ctx context.Context, namespace string, c client.Client, syncDir string, selector labels.Selector) ([]types.Capability, error)

func GetWorkloadsFromCluster ¶

func GetWorkloadsFromCluster(ctx context.Context, namespace string, c client.Client, syncDir string, selector labels.Selector) ([]types.Capability, error)

func HandleDefinition ¶

func HandleDefinition(name, syncDir, crdName string, extention *runtime.RawExtension, tp types.CapType, applyTo []string) (types.Capability, error)

func HandleTemplate ¶

func HandleTemplate(in *runtime.RawExtension, name, syncDir string) (types.Capability, error)

func LoadAllInstalledCapability ¶

func LoadAllInstalledCapability() ([]types.Capability, error)

func LoadCapabilityByName ¶

func LoadCapabilityByName(name string) (types.Capability, error)

func LoadCapabilityFromSyncedCenter ¶

func LoadCapabilityFromSyncedCenter(dir string) ([]types.Capability, error)

func LoadInstalledCapabilityWithType ¶

func LoadInstalledCapabilityWithType(capT types.CapType) ([]types.Capability, error)

func ParseAndSyncCapability ¶

func ParseAndSyncCapability(data []byte, syncDir string) (types.Capability, error)

func SinkTemp2Local ¶

func SinkTemp2Local(templates []types.Capability, dir string) int

func StoreRepos ¶

func StoreRepos(repos []CapCenterConfig) error

Types ¶

type CapCenterConfig ¶

type CapCenterConfig struct {
	Name    string `json:"name"`
	Address string `json:"address"`
	Token   string `json:"token"`
}

CapCenterConfig is used to store cap center config in file

func LoadRepos ¶

func LoadRepos() ([]CapCenterConfig, error)

TODO(wonderflow): we can make default(built-in) repo configurable, then we should make default inside the answer

type CenterClient ¶

type CenterClient interface {
	SyncCapabilityFromCenter() error
}

func NewCenterClient ¶

func NewCenterClient(ctx context.Context, name, address, token string) (CenterClient, error)

type GithubCenter ¶

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

func NewGithubCenter ¶

func NewGithubCenter(ctx context.Context, token, centerName string, r *GithubContent) (*GithubCenter, error)

func (*GithubCenter) SyncCapabilityFromCenter ¶

func (g *GithubCenter) SyncCapabilityFromCenter() error

TODO(wonderflow): currently we only sync by create, we also need to delete which not exist remotely.

type GithubContent ¶

type GithubContent struct {
	Owner string `json:"owner"`
	Repo  string `json:"repo"`
	Path  string `json:"path"`
	Ref   string `json:"ref"`
}

func Parse ¶

func Parse(addr string) (string, *GithubContent, error)

type RemoteCapabilities ¶

type RemoteCapabilities []RemoteCapability

type RemoteCapability ¶

type RemoteCapability struct {
	// Name MUST be xxx.yaml
	Name string `json:"name"`
	URL  string `json:"download_url"`
	Sha  string `json:"sha"`
	// Type MUST be file
	Type string `json:"type"`
}

Source Files ¶

View all Source files

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