storage

Documentation

Index

• func ValidateExportObjectAndTenantID(ctx context.Context, store *registry.Store, name string, ...) (runtime.Object, error)
• func ValidateGetObjectAndTenantID(ctx context.Context, store *registry.Store, name string, ...) (runtime.Object, error)
• type FileContentProxy
  • func (p *FileContentProxy) GetReaderCloser() (io.ReadCloser, error)
• type FileContentREST
  • func (r *FileContentREST) Create(ctx context.Context, obj runtime.Object, ...) (runtime.Object, error)
  • func (r *FileContentREST) New() runtime.Object
• type FileNodeProxy
  • func (p *FileNodeProxy) GetReaderCloser() (io.ReadCloser, error)
• type FileNodeREST
  • func (r *FileNodeREST) Create(ctx context.Context, obj runtime.Object, ...) (runtime.Object, error)
  • func (r *FileNodeREST) New() runtime.Object
• type FileNodeRequest
• type LogagentProxyREST
  • func (r *LogagentProxyREST) Connect(ctx context.Context, clusterName string, opts runtime.Object, ...) (http.Handler, error)
  • func (r *LogagentProxyREST) ConnectMethods() []string
  • func (r *LogagentProxyREST) New() runtime.Object
  • func (r *LogagentProxyREST) NewConnectOptions() (runtime.Object, bool, string)
• type LogfileProxyREST
  • func (r *LogfileProxyREST) Connect(ctx context.Context, clusterName string, opts runtime.Object, ...) (http.Handler, error)
  • func (r *LogfileProxyREST) ConnectMethods() []string
  • func (r *LogfileProxyREST) New() runtime.Object
  • func (r *LogfileProxyREST) NewConnectOptions() (runtime.Object, bool, string)
• type REST
  • func (r *REST) Create(ctx context.Context, obj runtime.Object, ...) (runtime.Object, error)
  • func (r *REST) Delete(ctx context.Context, name string, deleteValidation rest.ValidateObjectFunc, ...) (runtime.Object, bool, error)
  • func (r *REST) DeleteCollection(ctx context.Context, deleteValidation rest.ValidateObjectFunc, ...) (runtime.Object, error)
  • func (r *REST) Export(ctx context.Context, name string, options metav1.ExportOptions) (runtime.Object, error)
  • func (r *REST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error)
  • func (r *REST) List(ctx context.Context, options *metainternal.ListOptions) (runtime.Object, error)
  • func (r *REST) ShortNames() []string
  • func (r *REST) Update(ctx context.Context, name string, objInfo rest.UpdatedObjectInfo, ...) (runtime.Object, bool, error)
• type StatusREST
  • func (r *StatusREST) Export(ctx context.Context, name string, options metav1.ExportOptions) (runtime.Object, error)
  • func (r *StatusREST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error)
  • func (r *StatusREST) New() runtime.Object
  • func (r *StatusREST) Update(ctx context.Context, name string, objInfo rest.UpdatedObjectInfo, ...) (runtime.Object, bool, error)
• type Storage
  • func NewStorage(optsGetter genericregistry.RESTOptionsGetter, privilegedUsername string, ...) *Storage

Functions

func ValidateExportObjectAndTenantID

func ValidateExportObjectAndTenantID(ctx context.Context, store *registry.Store, name string, options metav1.ExportOptions) (runtime.Object, error)

ValidateExportObjectAndTenantID validate name and tenantID, if success return LogCollector

func ValidateGetObjectAndTenantID

func ValidateGetObjectAndTenantID(ctx context.Context, store *registry.Store, name string, options *metav1.GetOptions) (runtime.Object, error)

ValidateGetObjectAndTenantID validate name and tenantID, if success return LogCollector

Types

type FileContentProxy

type FileContentProxy struct {
	Req  logagent.LogFileContentSpec
	IP   string
	Port string
}

func (*FileContentProxy) GetReaderCloser

func (p *FileContentProxy) GetReaderCloser() (io.ReadCloser, error)

type FileContentREST

type FileContentREST struct {
	PlatformClient platformversionedclient.PlatformV1Interface
	// contains filtered or unexported fields
}

TokenREST implements the REST endpoint.

func (*FileContentREST) Create

func (r *FileContentREST) Create(ctx context.Context, obj runtime.Object, createValidation rest.ValidateObjectFunc, options *metav1.CreateOptions) (runtime.Object, error)

func (*FileContentREST) New

func (r *FileContentREST) New() runtime.Object

type FileNodeProxy

type FileNodeProxy struct {
	Req  logagent.LogFileTreeSpec
	IP   string
	Port string
}

func (*FileNodeProxy) GetReaderCloser

func (p *FileNodeProxy) GetReaderCloser() (io.ReadCloser, error)

type FileNodeREST

type FileNodeREST struct {
	PlatformClient platformversionedclient.PlatformV1Interface
	// contains filtered or unexported fields
}

TokenREST implements the REST endpoint.

func (*FileNodeREST) Create

func (r *FileNodeREST) Create(ctx context.Context, obj runtime.Object, createValidation rest.ValidateObjectFunc, options *metav1.CreateOptions) (runtime.Object, error)

func (*FileNodeREST) New

func (r *FileNodeREST) New() runtime.Object

New returns an empty object that can be used with Create after request data has been put into it.

type FileNodeRequest

type FileNodeRequest struct {
	PodName   string `json:"podName"`
	Namespace string `json:"namespace"`
	Container string `json:"container"`
}

type LogagentProxyREST

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

TokenREST implements the REST endpoint.

func (*LogagentProxyREST) Connect

func (r *LogagentProxyREST) Connect(ctx context.Context, clusterName string, opts runtime.Object, responder rest.Responder) (http.Handler, error)

Connect returns a handler for the kube-apiserver proxy

func (*LogagentProxyREST) ConnectMethods

func (r *LogagentProxyREST) ConnectMethods() []string

ConnectMethods returns the list of HTTP methods that can be proxied

func (*LogagentProxyREST) New

func (r *LogagentProxyREST) New() runtime.Object

New creates a new LogCollector proxy options object

func (*LogagentProxyREST) NewConnectOptions

func (r *LogagentProxyREST) NewConnectOptions() (runtime.Object, bool, string)

NewConnectOptions returns versioned resource that represents proxy parameters

type LogfileProxyREST

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

LogfileProxyREST implements the REST endpoint.

func (*LogfileProxyREST) Connect

func (r *LogfileProxyREST) Connect(ctx context.Context, clusterName string, opts runtime.Object, responder rest.Responder) (http.Handler, error)

Connect returns a handler for the kube-apiserver proxy

func (*LogfileProxyREST) ConnectMethods

func (r *LogfileProxyREST) ConnectMethods() []string

ConnectMethods returns the list of HTTP methods that can be proxied

func (*LogfileProxyREST) New

func (r *LogfileProxyREST) New() runtime.Object

New creates a new LogCollector proxy options object

func (*LogfileProxyREST) NewConnectOptions

func (r *LogfileProxyREST) NewConnectOptions() (runtime.Object, bool, string)

NewConnectOptions returns versioned resource that represents proxy parameters

type REST

type REST struct {
	*registry.Store
	// contains filtered or unexported fields
}

REST implements a RESTStorage for channels against etcd.

func (*REST) Create

func (r *REST) Create(ctx context.Context, obj runtime.Object, createValidation rest.ValidateObjectFunc, options *metav1.CreateOptions) (runtime.Object, error)

No need to implement TODO: remove this function

func (*REST) Delete

func (r *REST) Delete(ctx context.Context, name string, deleteValidation rest.ValidateObjectFunc, options *metav1.DeleteOptions) (runtime.Object, bool, error)

Delete enforces life-cycle rules for cluster termination

func (*REST) DeleteCollection

func (r *REST) DeleteCollection(ctx context.Context, deleteValidation rest.ValidateObjectFunc, options *metav1.DeleteOptions, listOptions *metainternal.ListOptions) (runtime.Object, error)

DeleteCollection selects all resources in the storage matching given 'listOptions' and deletes them.

func (*REST) Export

func (r *REST) Export(ctx context.Context, name string, options metav1.ExportOptions) (runtime.Object, error)

Export an object. Fields that are not user specified are stripped out Returns the stripped object.

func (*REST) Get

func (r *REST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error)

Get finds a resource in the storage by name and returns it.

func (*REST) List

func (r *REST) List(ctx context.Context, options *metainternal.ListOptions) (runtime.Object, error)

List selects resources in the storage which match to the selector. 'options' can be nil.

func (*REST) ShortNames

func (r *REST) ShortNames() []string

ShortNames implements the ShortNamesProvider interface. Returns a list of short names for a resource.

func (*REST) Update

func (r *REST) Update(ctx context.Context, name string, objInfo rest.UpdatedObjectInfo, createValidation rest.ValidateObjectFunc, updateValidation rest.ValidateObjectUpdateFunc, forceAllowCreate bool, options *metav1.UpdateOptions) (runtime.Object, bool, error)

Update finds a resource in the storage and updates it.

type StatusREST

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

StatusREST implements the REST endpoint for changing the status of a LogAgent.

func (*StatusREST) Export

func (r *StatusREST) Export(ctx context.Context, name string, options metav1.ExportOptions) (runtime.Object, error)

Export an object. Fields that are not user specified are stripped out Returns the stripped object.

func (*StatusREST) Get

func (r *StatusREST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error)

Get retrieves the object from the storage. It is required to support Patch.

func (*StatusREST) New

func (r *StatusREST) New() runtime.Object

New returns an empty object that can be used with Create and Update after request data has been put into it.

func (*StatusREST) Update

func (r *StatusREST) Update(ctx context.Context, name string, objInfo rest.UpdatedObjectInfo, createValidation rest.ValidateObjectFunc, updateValidation rest.ValidateObjectUpdateFunc, forceAllowCreate bool, options *metav1.UpdateOptions) (runtime.Object, bool, error)

Update alters the status subset of an object.

type Storage

type Storage struct {
	LogAgent       *REST
	LogFileTree    *FileNodeREST
	LogFileContent *FileContentREST
	LogagentProxy  *LogagentProxyREST
	LogfileProxy   *LogfileProxyREST
	Status         *StatusREST
}

func NewStorage

func NewStorage(optsGetter genericregistry.RESTOptionsGetter, privilegedUsername string, platformClient platformversionedclient.PlatformV1Interface) *Storage

NewStorage returns a Storage object that will work against channels.