metaserver

Documentation

Index

• Constants
• func IndexCheck(length int, indexes ...*int)
• func KeyFunc(obj runtime.Object) string
• func KeyFuncObj(obj runtime.Object) (string, error)
• func KeyFuncReq(ctx context.Context, _ string) (string, error)
• func KeyRootFunc(ctx context.Context) string
• func MsgToApplications(msg model.Message) (map[string]Application, error)
• func ParseKey(key string) (gvr schema.GroupVersionResource, namespace string, name string)
• func ToBytes(i interface{}) (bytes []byte)
• type Application
  • func MsgToApplication(msg model.Message) (*Application, error)
  • func NewApplication(ctx context.Context, key string, verb ApplicationVerb, ...) (*Application, error)
  • func (a *Application) Add()
  • func (a *Application) Cancel()
  • func (a *Application) Close()
  • func (a *Application) GVR() schema.GroupVersionResource
  • func (a *Application) GetStatus() ApplicationStatus
  • func (a *Application) Identifier() string
  • func (a *Application) LastCloseTime() time.Time
  • func (a *Application) Namespace() string
  • func (a *Application) OptionTo(i interface{}) error
  • func (a *Application) ReqBodyTo(i interface{}) error
  • func (a *Application) ReqContent() interface{}
  • func (a *Application) Reset()
  • func (a *Application) RespBodyTo(i interface{}) error
  • func (a *Application) RespContent() interface{}
  • func (a *Application) String() string
  • func (a *Application) Wait()
• type ApplicationStatus
• type ApplicationVerb
• type PatchInfo

Constants

const (
	MetaServerSource    = "metaserver"
	ApplicationResource = "Application"
	ApplicationResp     = "applicationResponse"
	Ignore              = "ignore"
)

used to set Message.Route

const WatchAppSync = "watchapp/sync"

Functions

func IndexCheck

func IndexCheck(length int, indexes ...*int)

force set index to 0 if out of range

func KeyFunc

func KeyFunc(obj runtime.Object) string

func KeyFuncObj

func KeyFuncObj(obj runtime.Object) (string, error)

KeyFuncObj generated key from obj

func KeyFuncReq

func KeyFuncReq(ctx context.Context, _ string) (string, error)

KeyFuncReq generate key from req context

func KeyRootFunc

func KeyRootFunc(ctx context.Context) string

func MsgToApplications

func MsgToApplications(msg model.Message) (map[string]Application, error)

MsgToApplications extract applications in message's Content

func ParseKey

func ParseKey(key string) (gvr schema.GroupVersionResource, namespace string, name string)

ParseKey parse key to group/version/resource, namespace, name Now key format is like below: 0/1 /2 /3 /4 /5

/core/v1/pods/{namespaces}/{name}

0/1 /2/3

/app/v1/deployments

0/1 /2 /3

/core/v1/endpoints

Remember that ParseKey is not responsible for verifying the validity of the content, for example, gvr in key /app/v1111/endpoint will be parsed as {Group:"app", Version:"v1111", Resource:"endpoint"}

func ToBytes

func ToBytes(i interface{}) (bytes []byte)

Types

type Application

type Application struct {
	// ID is the SHA256 checksum generated from request information
	ID string

	// The following field defines the Application request information
	// Key format: group version resource namespaces name
	Key         string
	Verb        ApplicationVerb
	Nodename    string
	Option      []byte
	ReqBody     []byte
	Subresource string

	// The following field defines the Application response result
	RespBody []byte
	Status   ApplicationStatus
	Reason   string // why in this status
	Error    apierrors.StatusError

	// Timestamp record the last closing time of application, only make sense when count == 0
	Timestamp time.Time
	// contains filtered or unexported fields
}

Application record the resources that are in applying for requesting to be transferred down from the cloud, please: 0.use Agent.Generate to generate application 1.use Agent.Apply to apply application( generate msg and send it to cloud dynamiccontroller)

func MsgToApplication

func MsgToApplication(msg model.Message) (*Application, error)

extract application in message's Content

func NewApplication

func NewApplication(ctx context.Context, key string, verb ApplicationVerb, nodename, subresource string, option interface{}, reqBody interface{}) (*Application, error)

func (*Application) Add

func (a *Application) Add()

func (*Application) Cancel

func (a *Application) Cancel()

func (*Application) Close

func (a *Application) Close()

Close must be called when applicant no longer using application

func (*Application) GVR

func (a *Application) GVR() schema.GroupVersionResource

func (*Application) GetStatus

func (a *Application) GetStatus() ApplicationStatus

func (*Application) Identifier

func (a *Application) Identifier() string

func (*Application) LastCloseTime

func (a *Application) LastCloseTime() time.Time

func (*Application) Namespace

func (a *Application) Namespace() string

func (*Application) OptionTo

func (a *Application) OptionTo(i interface{}) error

OptionTo convert application option. Remember `i` must be a pointer to the initialized variable

func (*Application) ReqBodyTo

func (a *Application) ReqBodyTo(i interface{}) error

func (*Application) ReqContent

func (a *Application) ReqContent() interface{}

func (*Application) Reset

func (a *Application) Reset()

func (*Application) RespBodyTo

func (a *Application) RespBodyTo(i interface{}) error

func (*Application) RespContent

func (a *Application) RespContent() interface{}

func (*Application) String

func (a *Application) String() string

func (*Application) Wait

func (a *Application) Wait()

Wait the result of application after it is applied by application agent

type ApplicationStatus

type ApplicationStatus string

const (
	// set by agent
	PreApplying ApplicationStatus = "PreApplying" // application is waiting to be sent to cloud
	InApplying  ApplicationStatus = "InApplying"  // application is sending to cloud

	// set by center
	InProcessing ApplicationStatus = "InProcessing" // application is in processing by cloud
	Approved     ApplicationStatus = "Approved"     // application is approved by cloud
	Rejected     ApplicationStatus = "Rejected"     // application is rejected by cloud

	// both
	Failed    ApplicationStatus = "Failed"    // failed to get application resp from cloud
	Completed ApplicationStatus = "Completed" // application is completed and waiting to be recycled
)

type ApplicationVerb

type ApplicationVerb string

const (
	Get          ApplicationVerb = "get"
	List         ApplicationVerb = "list"
	Watch        ApplicationVerb = "watch"
	Create       ApplicationVerb = "create"
	Delete       ApplicationVerb = "delete"
	Update       ApplicationVerb = "update"
	UpdateStatus ApplicationVerb = "updatestatus"
	Patch        ApplicationVerb = "patch"
)

type PatchInfo

type PatchInfo struct {
	Name         string
	PatchType    types.PatchType
	Data         []byte
	Options      v1.PatchOptions
	Subresources []string
}