server

package
v0.0.0-...-5973960 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 14, 2024 License: Apache-2.0 Imports: 46 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ServerName       = "tko-data-server"
	ComponentName    = "tko"
	ComponentVersion = "0.1"
	OpenAPITitle     = "TKO"
	OpenAPIVersion   = "0.1"
)
View Source 
const (
	Category           = "tko"
	ParallelBufferSize = 1000
	ParallelWorkers    = 10
	RetryAfterSeconds  = 5
)

Variables

View Source 
var APIVersion = krm.SchemeGroupVersion.Identifier()
View Source 
var Codecs = serializer.NewCodecFactory(Scheme)
View Source 
var Scheme = runtime.NewScheme()

Functions

func DeploymentFromKRM 

func DeploymentFromKRM(object runtime.Object) (*backendpkg.Deployment, error)

func DeploymentInfoToKRM 

func DeploymentInfoToKRM(deploymentInfo *backendpkg.DeploymentInfo) (*krm.Deployment, error)

func DeploymentToKRM 

func DeploymentToKRM(deployment *backendpkg.Deployment) (*krm.Deployment, error)

func FromResourceVersion 

func FromResourceVersion(resourceVersion string) (time.Time, error)

func IDFromListOptions 

func IDFromListOptions(options *internalversion.ListOptions) (*string, error)

func IDPatternsFromListOptions 

func IDPatternsFromListOptions(options *internalversion.ListOptions) ([]string, error)

func MetadataPatternsFromListOptions 

func MetadataPatternsFromListOptions(options *internalversion.ListOptions) (map[string]string, error)

func NewAPIGroupInfo 

func NewAPIGroupInfo(restOptions generic.RESTOptionsGetter, backend backend.Backend, log commonlog.Logger) *serverpkg.APIGroupInfo

func NewConfig 

func NewConfig(port int) (*server.CompletedConfig, error)

func NewRecommendedConfig 

func NewRecommendedConfig(port int) (*server.RecommendedConfig, error)

func NewRecommendedOptions 

func NewRecommendedOptions(port int) (*options.RecommendedOptions, error)

func PackageFromKRM 

func PackageFromKRM(krmPackage *krm.Package) tkoutil.Package

func PackageToKRM 

func PackageToKRM(package_ tkoutil.Package) *krm.Package

func PluginFromKRM 

func PluginFromKRM(object runtime.Object) (*backendpkg.Plugin, error)

func PluginToKRM 

func PluginToKRM(plugin *backendpkg.Plugin) (*krm.Plugin, error)

func ResourceVersionsEqual 

func ResourceVersionsEqual(a time.Time, b time.Time) bool

func SiteFromKRM 

func SiteFromKRM(object runtime.Object) (*backendpkg.Site, error)

func SiteInfoToKRM 

func SiteInfoToKRM(siteInfo *backendpkg.SiteInfo) (*krm.Site, error)

func SiteToKRM 

func SiteToKRM(site *backendpkg.Site) (*krm.Site, error)

func TemplateFromKRM 

func TemplateFromKRM(object runtime.Object) (*backendpkg.Template, error)

func TemplateInfoToKRM 

func TemplateInfoToKRM(templateInfo *backendpkg.TemplateInfo) (*krm.Template, error)

func TemplateToKRM 

func TemplateToKRM(template *backendpkg.Template) (*krm.Template, error)

func ToDeploymentsKRM 

func ToDeploymentsKRM(object runtime.Object) ([]krm.Deployment, error)

func ToPluginsKRM 

func ToPluginsKRM(object runtime.Object) ([]krm.Plugin, error)

func ToResourceVersion 

func ToResourceVersion(updated time.Time) string

func ToSitesKRM 

func ToSitesKRM(object runtime.Object) ([]krm.Site, error)

func ToTemplatesKRM 

func ToTemplatesKRM(object runtime.Object) ([]krm.Template, error)

func ToUID 

func ToUID(segments ...string) types.UID

Types

type Server 

type Server struct {
	Backend backend.Backend
	Port    int
	Log     commonlog.Logger
	// contains filtered or unexported fields
}

func NewServer 

func NewServer(backend backend.Backend, port int, log commonlog.Logger) *Server

func (*Server) Start 

func (self *Server) Start() error

func (*Server) Stop 

func (self *Server) Stop()

type Store 

type Store struct {
	Backend backendpkg.Backend
	Log     commonlog.Logger

	TypeKind          string
	TypeListKind      string
	TypeSingular      string
	TypePlural        string
	TypeShortNames    []string
	CanCreateOnUpdate bool

	NewObjectFunc     func() runtime.Object
	NewListObjectFunc func() runtime.Object
	GetFieldsFunc     func(object runtime.Object) (fields.Set, error)

	// These can return backend errors
	CreateFunc func(context contextpkg.Context, store *Store, object runtime.Object) (runtime.Object, error)
	UpdateFunc func(context contextpkg.Context, store *Store, updatedObject runtime.Object) (runtime.Object, error) // optional
	DeleteFunc func(context contextpkg.Context, store *Store, id string) error
	PurgeFunc  func(context contextpkg.Context, store *Store) error
	GetFunc    func(context contextpkg.Context, store *Store, id string) (runtime.Object, error)
	ListFunc   func(context contextpkg.Context, store *Store, options *internalversion.ListOptions, offset uint, maxCount uint) (runtime.Object, error)
	TableFunc  func(context contextpkg.Context, store *Store, object runtime.Object, withHeaders bool, withObject bool) (*meta.Table, error)
	// contains filtered or unexported fields
}

func NewDeploymentStore 

func NewDeploymentStore(backend backend.Backend, log commonlog.Logger) *Store

func NewPluginStore 

func NewPluginStore(backend backend.Backend, log commonlog.Logger) *Store

func NewSiteStore 

func NewSiteStore(backend backend.Backend, log commonlog.Logger) *Store

func NewTemplateStore 

func NewTemplateStore(backend backendpkg.Backend, log commonlog.Logger) *Store

func (*Store) AcceptsGroupVersion 

func (self *Store) AcceptsGroupVersion(gv schema.GroupVersion) bool

(rest.GroupVersionAcceptor interface)

func (*Store) AllowCreateOnUpdate 

func (self *Store) AllowCreateOnUpdate() bool

(rest.RESTUpdateStrategy interface) (rest.RESTCreateUpdateStrategy interface) (rest.CreateUpdateResetFieldsStrategy interface) (rest.UpdateResetFieldsStrategy interface)

func (*Store) AllowUnconditionalUpdate 

func (self *Store) AllowUnconditionalUpdate() bool

(rest.RESTUpdateStrategy interface) (rest.RESTCreateUpdateStrategy interface) (rest.CreateUpdateResetFieldsStrategy interface) (rest.UpdateResetFieldsStrategy interface)

func (*Store) Canonicalize 

func (self *Store) Canonicalize(object runtime.Object)

(rest.RESTUpdateStrategy interface) (rest.RESTCreateStrategy interface) (rest.RESTCreateUpdateStrategy interface) (rest.CreateUpdateResetFieldsStrategy interface) (rest.UpdateResetFieldsStrategy interface)

func (*Store) Categories 

func (self *Store) Categories() []string

(rest.SingularNameProvider interface)

func (*Store) ConvertToTable 

func (self *Store) ConvertToTable(context contextpkg.Context, object runtime.Object, options runtime.Object) (*meta.Table, error)

(rest.TableConvertor interface) (rest.Lister interface) (rest.StandardStorage interface)

func (*Store) Create 

func (self *Store) Create(context contextpkg.Context, object runtime.Object, createValidation rest.ValidateObjectFunc, options *meta.CreateOptions) (runtime.Object, error)

(rest.Creater interface) (rest.CreaterUpdater interface) (rest.StandardStorage interface)

func (*Store) Delete 

func (self *Store) Delete(context contextpkg.Context, name string, deleteValidation rest.ValidateObjectFunc, options *meta.DeleteOptions) (runtime.Object, bool, error)

(rest.GracefulDeleter interface) (rest.StandardStorage interface)

func (*Store) DeleteCollection 

func (self *Store) DeleteCollection(context contextpkg.Context, deleteValidation rest.ValidateObjectFunc, options *meta.DeleteOptions, listOptions *internalversion.ListOptions) (runtime.Object, error)

(rest.CollectionDeleter interface) (rest.StandardStorage interface)

func (*Store) DeleteReturnsDeletedObject 

func (self *Store) DeleteReturnsDeletedObject() bool

(rest.MayReturnFullObjectDeleter interface)

func (*Store) Destroy 

func (self *Store) Destroy()

(rest.Storage interface) (rest.StandardStorage interface)

func (*Store) GenerateName 

func (self *Store) GenerateName(base string) string

([names.NameGenerator] interface) (rest.RESTCreateStrategy interface) (rest.RESTUpdateStrategy interface) (rest.RESTCreateUpdateStrategy interface) (rest.CreateUpdateResetFieldsStrategy interface) (rest.UpdateResetFieldsStrategy interface)

func (*Store) Get 

func (self *Store) Get(context contextpkg.Context, name string, options *meta.GetOptions) (runtime.Object, error)

(rest.Getter interface) (rest.Patcher interface) (rest.StandardStorage interface)

func (*Store) GetResetFields 

func (self *Store) GetResetFields() map[fieldpath.APIVersion]*fieldpath.Set

(rest.ResetFieldsStrategy interface) (rest.CreateUpdateResetFieldsStrategy interface) (rest.UpdateResetFieldsStrategy interface)

func (*Store) GetSingularName 

func (self *Store) GetSingularName() string

(rest.CategoriesProvider interface)

func (*Store) GroupVersionKind 

func (self *Store) GroupVersionKind(containingGv schema.GroupVersion) schema.GroupVersionKind

(rest.GroupVersionKindProvider interface)

func (*Store) Init 

func (self *Store) Init()

func (*Store) Kind 

func (self *Store) Kind() string

(rest.KindProvider interface)

func (*Store) List 

func (self *Store) List(context contextpkg.Context, options *internalversion.ListOptions) (runtime.Object, error)

(rest.Lister interface) (rest.StandardStorage interface)

func (*Store) NamespaceScoped 

func (self *Store) NamespaceScoped() bool

(rest.Scoper interface) (rest.RESTUpdateStrategy interface) (rest.RESTCreateStrategy interface) (rest.CreateUpdateResetFieldsStrategy interface) (rest.UpdateResetFieldsStrategy interface)

func (*Store) New 

func (self *Store) New() runtime.Object

(rest.Storage interface) (rest.Creater interface) (rest.NamedCreater interface)

func (*Store) NewList 

func (self *Store) NewList() runtime.Object

(rest.Lister interface) (rest.StandardStorage interface)

func (*Store) NewSelectionPredicate 

func (self *Store) NewSelectionPredicate(options *internalversion.ListOptions) storage.SelectionPredicate

Unused

func (*Store) ObjectKinds 

func (self *Store) ObjectKinds(object runtime.Object) ([]schema.GroupVersionKind, bool, error)

(runtime.ObjectTyper interface) (rest.RESTCreateStrategy interface) (rest.RESTUpdateStrategy interface) (rest.RESTCreateUpdateStrategy interface) (rest.CreateUpdateResetFieldsStrategy interface) (rest.UpdateResetFieldsStrategy interface)

func (*Store) PrepareForCreate 

func (self *Store) PrepareForCreate(context contextpkg.Context, object runtime.Object)

(rest.RESTCreateStrategy interface) (rest.RESTCreateUpdateStrategy interface) (rest.CreateUpdateResetFieldsStrategy interface)

func (*Store) PrepareForUpdate 

func (self *Store) PrepareForUpdate(context contextpkg.Context, object runtime.Object, oldObject runtime.Object)

(rest.RESTUpdateStrategy interface) (rest.RESTCreateUpdateStrategy interface) (rest.CreateUpdateResetFieldsStrategy interface) (rest.UpdateResetFieldsStrategy interface)

func (*Store) PreserveRequestObjectMetaSystemFieldsOnSubresourceCreate 

func (self *Store) PreserveRequestObjectMetaSystemFieldsOnSubresourceCreate() bool

(rest.SubresourceObjectMetaPreserver interface)

func (*Store) Recognizes 

func (self *Store) Recognizes(gvk schema.GroupVersionKind) bool

(runtime.ObjectTyper interface) (rest.RESTCreateStrategy interface) (rest.RESTUpdateStrategy interface) (rest.RESTCreateUpdateStrategy interface) (rest.CreateUpdateResetFieldsStrategy interface) (rest.UpdateResetFieldsStrategy interface)

func (*Store) ShortNames 

func (self *Store) ShortNames() []string

(rest.ShortNamesProvider interface)

func (*Store) Update 

func (self *Store) Update(context contextpkg.Context, name string, objectInfo rest.UpdatedObjectInfo, createValidation rest.ValidateObjectFunc, updateValidation rest.ValidateObjectUpdateFunc, forceAllowCreate bool, options *meta.UpdateOptions) (runtime.Object, bool, error)

(rest.Updater interface) (rest.CreaterUpdater interface) (rest.Patcher interface) (rest.StandardStorage interface)

func (*Store) Validate 

func (self *Store) Validate(context contextpkg.Context, object runtime.Object) field.ErrorList

(rest.RESTCreateStrategy interface) (rest.RESTCreateUpdateStrategy interface) (rest.CreateUpdateResetFieldsStrategy interface)

func (*Store) ValidateUpdate 

func (self *Store) ValidateUpdate(context contextpkg.Context, object runtime.Object, oldObject runtime.Object) field.ErrorList

(rest.RESTUpdateStrategy interface) (rest.RESTCreateUpdateStrategy interface) (rest.CreateUpdateResetFieldsStrategy interface) (rest.UpdateResetFieldsStrategy interface)

func (*Store) WarningsOnCreate 

func (self *Store) WarningsOnCreate(context contextpkg.Context, object runtime.Object) []string

(rest.RESTCreateStrategy interface) (rest.RESTCreateUpdateStrategy interface) (rest.CreateUpdateResetFieldsStrategy interface)

func (*Store) WarningsOnUpdate 

func (self *Store) WarningsOnUpdate(context contextpkg.Context, object runtime.Object, oldObject runtime.Object) []string

(rest.RESTUpdateStrategy interface) (rest.RESTCreateUpdateStrategy interface) (rest.CreateUpdateResetFieldsStrategy interface) (rest.UpdateResetFieldsStrategy interface)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.