daemonapi

package
v0.0.0-...-63b02d4 Latest Latest
Warning

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

 Go to latest Published: Apr 18, 2024 License: Apache-2.0 Imports: 64 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AuthMiddleware 

func AuthMiddleware(parent context.Context) echo.MiddlewareFunc

func GetClusterIPs 

func GetClusterIPs() clusterip.L

func GetLogger 

func GetLogger(c echo.Context) *plog.Logger

func JSONForbiddenMissingGrant 

func JSONForbiddenMissingGrant(ctx echo.Context, missing ...rbac.Grant) error

func JSONForbiddenMissingRole 

func JSONForbiddenMissingRole(ctx echo.Context, missing ...rbac.Role) error

func JSONProblem 

func JSONProblem(ctx echo.Context, code int, title, detail string) error

func JSONProblemf 

func JSONProblemf(ctx echo.Context, code int, title, detail string, argv ...any) error

func LogHandler 

func LogHandler(c echo.Context, name string) *plog.Logger

func LogMiddleware 

func LogMiddleware(parent context.Context) echo.MiddlewareFunc

func LogRequestMiddleWare 

func LogRequestMiddleWare(parent context.Context) echo.MiddlewareFunc

func LogUserMiddleware 

func LogUserMiddleware(parent context.Context) echo.MiddlewareFunc

func UIMiddleware 

func UIMiddleware(_ context.Context) echo.MiddlewareFunc

Types

type DaemonAPI 

type DaemonAPI struct {
	Daemondata *daemondata.T
	EventBus   *pubsub.Bus
	JWTcreator JWTCreater

	LabelNode pubsub.Label
	// contains filtered or unexported fields
}

func New 

func New(ctx context.Context) *DaemonAPI

func (*DaemonAPI) GetAuthInfo 

func (a *DaemonAPI) GetAuthInfo(ctx echo.Context) error

func (*DaemonAPI) GetDNSDump 

func (a *DaemonAPI) GetDNSDump(ctx echo.Context) error

GetDNSDump returns the DNS zone content.

func (*DaemonAPI) GetDaemonEvents 

func (a *DaemonAPI) GetDaemonEvents(ctx echo.Context, nodename string, params api.GetDaemonEventsParams) error

GetDaemonEvents feeds node daemon event publications in rss format.

func (*DaemonAPI) GetDaemonStatus 

func (a *DaemonAPI) GetDaemonStatus(ctx echo.Context, params api.GetDaemonStatusParams) error

GetDaemonStatus returns daemon data status

Serve 2s cached data.

func (*DaemonAPI) GetInstance 

func (a *DaemonAPI) GetInstance(ctx echo.Context, nodename string, namespace string, kind naming.Kind, name string) error

func (*DaemonAPI) GetInstanceLogs 

func (a *DaemonAPI) GetInstanceLogs(ctx echo.Context, nodename string, namespace string, kind naming.Kind, name string, params api.GetInstanceLogsParams) error

func (*DaemonAPI) GetInstances 

func (a *DaemonAPI) GetInstances(ctx echo.Context, params api.GetInstancesParams) error

func (*DaemonAPI) GetLocalNodeConfig 

func (a *DaemonAPI) GetLocalNodeConfig(ctx echo.Context, nodename string, params api.GetNodeConfigParams) error

func (*DaemonAPI) GetNetworkIP 

func (a *DaemonAPI) GetNetworkIP(ctx echo.Context, params api.GetNetworkIPParams) error

GetNetworkIP returns network status list.

func (*DaemonAPI) GetNetworks 

func (a *DaemonAPI) GetNetworks(ctx echo.Context, params api.GetNetworksParams) error

GetNetworks returns network status list.

func (*DaemonAPI) GetNodeCapabilities 

func (a *DaemonAPI) GetNodeCapabilities(ctx echo.Context, nodename string) error

func (*DaemonAPI) GetNodeConfig 

func (a *DaemonAPI) GetNodeConfig(ctx echo.Context, nodename string, params api.GetNodeConfigParams) error

func (*DaemonAPI) GetNodeConfigGet 

func (a *DaemonAPI) GetNodeConfigGet(ctx echo.Context, nodename string, params api.GetNodeConfigGetParams) error

func (*DaemonAPI) GetNodeDRBDAllocation 

func (a *DaemonAPI) GetNodeDRBDAllocation(ctx echo.Context, nodename string) error

func (*DaemonAPI) GetNodeDRBDConfig 

func (a *DaemonAPI) GetNodeDRBDConfig(ctx echo.Context, nodename string, params api.GetNodeDRBDConfigParams) error

func (*DaemonAPI) GetNodeDriver 

func (a *DaemonAPI) GetNodeDriver(ctx echo.Context, nodename api.InPathNodeName) error

func (*DaemonAPI) GetNodeLogs 

func (a *DaemonAPI) GetNodeLogs(ctx echo.Context, nodename string, params api.GetNodeLogsParams) error

GetNodeLogs feeds publications in rss format.

func (*DaemonAPI) GetNodePing 

func (a *DaemonAPI) GetNodePing(ctx echo.Context, nodename api.InPathNodeName) error

func (*DaemonAPI) GetNodeSchedule 

func (a *DaemonAPI) GetNodeSchedule(ctx echo.Context, nodename string) error

func (*DaemonAPI) GetNodeSystemDisk 

func (a *DaemonAPI) GetNodeSystemDisk(ctx echo.Context, nodename api.InPathNodeName) error

func (*DaemonAPI) GetNodeSystemGroup 

func (a *DaemonAPI) GetNodeSystemGroup(ctx echo.Context, nodename api.InPathNodeName) error

func (*DaemonAPI) GetNodeSystemHardware 

func (a *DaemonAPI) GetNodeSystemHardware(ctx echo.Context, nodename api.InPathNodeName) error

func (*DaemonAPI) GetNodeSystemIPAddress 

func (a *DaemonAPI) GetNodeSystemIPAddress(ctx echo.Context, nodename api.InPathNodeName) error

func (*DaemonAPI) GetNodeSystemPackage 

func (a *DaemonAPI) GetNodeSystemPackage(ctx echo.Context, nodename api.InPathNodeName) error

func (*DaemonAPI) GetNodeSystemPatch 

func (a *DaemonAPI) GetNodeSystemPatch(ctx echo.Context, nodename api.InPathNodeName) error

func (*DaemonAPI) GetNodeSystemProperty 

func (a *DaemonAPI) GetNodeSystemProperty(ctx echo.Context, nodename api.InPathNodeName) error

func (*DaemonAPI) GetNodeSystemSANInitiator 

func (a *DaemonAPI) GetNodeSystemSANInitiator(ctx echo.Context, nodename api.InPathNodeName) error

func (*DaemonAPI) GetNodeSystemSANPath 

func (a *DaemonAPI) GetNodeSystemSANPath(ctx echo.Context, nodename api.InPathNodeName) error

func (*DaemonAPI) GetNodeSystemUser 

func (a *DaemonAPI) GetNodeSystemUser(ctx echo.Context, nodename api.InPathNodeName) error

func (*DaemonAPI) GetNodes 

func (a *DaemonAPI) GetNodes(ctx echo.Context, params api.GetNodesParams) error

func (*DaemonAPI) GetNodesInfo 

func (a *DaemonAPI) GetNodesInfo(ctx echo.Context) error

func (*DaemonAPI) GetObject 

func (a *DaemonAPI) GetObject(ctx echo.Context, namespace string, kind naming.Kind, name string) error

func (*DaemonAPI) GetObjectConfig 

func (a *DaemonAPI) GetObjectConfig(ctx echo.Context, namespace string, kind naming.Kind, name string, params api.GetObjectConfigParams) error

func (*DaemonAPI) GetObjectConfigFile 

func (a *DaemonAPI) GetObjectConfigFile(ctx echo.Context, namespace string, kind naming.Kind, name string) error

func (*DaemonAPI) GetObjectConfigGet 

func (a *DaemonAPI) GetObjectConfigGet(ctx echo.Context, namespace string, kind naming.Kind, name string, params api.GetObjectConfigGetParams) error

func (*DaemonAPI) GetObjectPaths 

func (a *DaemonAPI) GetObjectPaths(ctx echo.Context, params api.GetObjectPathsParams) error

func (*DaemonAPI) GetObjectSchedule 

func (a *DaemonAPI) GetObjectSchedule(ctx echo.Context, nodename, namespace string, kind naming.Kind, name string) error

func (*DaemonAPI) GetObjects 

func (a *DaemonAPI) GetObjects(ctx echo.Context, params api.GetObjectsParams) error

func (*DaemonAPI) GetPoolVolumes 

func (a *DaemonAPI) GetPoolVolumes(ctx echo.Context, params api.GetPoolVolumesParams) error

func (*DaemonAPI) GetPools 

func (a *DaemonAPI) GetPools(ctx echo.Context, params api.GetPoolsParams) error

func (*DaemonAPI) GetRelayMessage 

func (a *DaemonAPI) GetRelayMessage(ctx echo.Context, params api.GetRelayMessageParams) error

func (*DaemonAPI) GetResources 

func (a *DaemonAPI) GetResources(ctx echo.Context, params api.GetResourcesParams) error

func (*DaemonAPI) GetSwagger 

func (a *DaemonAPI) GetSwagger(ctx echo.Context) error

func (*DaemonAPI) Getwhoami 

func (a *DaemonAPI) Getwhoami(ctx echo.Context) error

func (*DaemonAPI) PostAuthToken 

func (a *DaemonAPI) PostAuthToken(ctx echo.Context, params api.PostAuthTokenParams) error

PostAuthToken create a new token for a user

When role parameter exists a new user is created with grants from role and extra claims may be added to token

func (*DaemonAPI) PostClusterAction 

func (a *DaemonAPI) PostClusterAction(ctx echo.Context, globalExpect node.MonitorGlobalExpect) error

func (*DaemonAPI) PostClusterActionAbort 

func (a *DaemonAPI) PostClusterActionAbort(ctx echo.Context) error

func (*DaemonAPI) PostClusterActionFreeze 

func (a *DaemonAPI) PostClusterActionFreeze(ctx echo.Context) error

func (*DaemonAPI) PostClusterActionUnfreeze 

func (a *DaemonAPI) PostClusterActionUnfreeze(ctx echo.Context) error

func (*DaemonAPI) PostDaemonJoin 

func (a *DaemonAPI) PostDaemonJoin(ctx echo.Context, params api.PostDaemonJoinParams) error

PostDaemonJoin publishes msgbus.JoinRequest{Node: node} with label node=<apinode>. It requires non empty params.Node

func (*DaemonAPI) PostDaemonLeave 

func (a *DaemonAPI) PostDaemonLeave(ctx echo.Context, params api.PostDaemonLeaveParams) error

PostDaemonLeave publishes msgbus.LeaveRequest{Node: node} with label node=<apinode>. It requires non empty params.Node

func (*DaemonAPI) PostDaemonLogsControl 

func (a *DaemonAPI) PostDaemonLogsControl(ctx echo.Context) error

func (*DaemonAPI) PostDaemonRestart 

func (a *DaemonAPI) PostDaemonRestart(ctx echo.Context, nodename string) error

func (*DaemonAPI) PostDaemonShutdown 

func (a *DaemonAPI) PostDaemonShutdown(ctx echo.Context, nodename string, params api.PostDaemonShutdownParams) error

func (*DaemonAPI) PostDaemonStop 

func (a *DaemonAPI) PostDaemonStop(ctx echo.Context, nodename string) error

func (*DaemonAPI) PostDaemonSubAction 

func (a *DaemonAPI) PostDaemonSubAction(ctx echo.Context) error

func (*DaemonAPI) PostInstanceActionBoot 

func (a *DaemonAPI) PostInstanceActionBoot(ctx echo.Context, nodename, namespace string, kind naming.Kind, name string, params api.PostInstanceActionBootParams) error

func (*DaemonAPI) PostInstanceActionDelete 

func (a *DaemonAPI) PostInstanceActionDelete(ctx echo.Context, nodename, namespace string, kind naming.Kind, name string, params api.PostInstanceActionDeleteParams) error

func (*DaemonAPI) PostInstanceActionFreeze 

func (a *DaemonAPI) PostInstanceActionFreeze(ctx echo.Context, nodename, namespace string, kind naming.Kind, name string, params api.PostInstanceActionFreezeParams) error

func (*DaemonAPI) PostInstanceActionPRStart 

func (a *DaemonAPI) PostInstanceActionPRStart(ctx echo.Context, nodename, namespace string, kind naming.Kind, name string, params api.PostInstanceActionPRStartParams) error

func (*DaemonAPI) PostInstanceActionPRStop 

func (a *DaemonAPI) PostInstanceActionPRStop(ctx echo.Context, nodename, namespace string, kind naming.Kind, name string, params api.PostInstanceActionPRStopParams) error

func (*DaemonAPI) PostInstanceActionProvision 

func (a *DaemonAPI) PostInstanceActionProvision(ctx echo.Context, nodename, namespace string, kind naming.Kind, name string, params api.PostInstanceActionProvisionParams) error

func (*DaemonAPI) PostInstanceActionShutdown 

func (a *DaemonAPI) PostInstanceActionShutdown(ctx echo.Context, nodename, namespace string, kind naming.Kind, name string, params api.PostInstanceActionShutdownParams) error

func (*DaemonAPI) PostInstanceActionStart 

func (a *DaemonAPI) PostInstanceActionStart(ctx echo.Context, nodename, namespace string, kind naming.Kind, name string, params api.PostInstanceActionStartParams) error

func (*DaemonAPI) PostInstanceActionStartStandby 

func (a *DaemonAPI) PostInstanceActionStartStandby(ctx echo.Context, nodename, namespace string, kind naming.Kind, name string, params api.PostInstanceActionStartStandbyParams) error

func (*DaemonAPI) PostInstanceActionStop 

func (a *DaemonAPI) PostInstanceActionStop(ctx echo.Context, nodename, namespace string, kind naming.Kind, name string, params api.PostInstanceActionStopParams) error

func (*DaemonAPI) PostInstanceActionUnfreeze 

func (a *DaemonAPI) PostInstanceActionUnfreeze(ctx echo.Context, nodename, namespace string, kind naming.Kind, name string, params api.PostInstanceActionUnfreezeParams) error

func (*DaemonAPI) PostInstanceActionUnprovision 

func (a *DaemonAPI) PostInstanceActionUnprovision(ctx echo.Context, nodename, namespace string, kind naming.Kind, name string, params api.PostInstanceActionUnprovisionParams) error

func (*DaemonAPI) PostInstanceClear 

func (a *DaemonAPI) PostInstanceClear(ctx echo.Context, nodename, namespace string, kind naming.Kind, name string) error

func (*DaemonAPI) PostInstanceProgress 

func (a *DaemonAPI) PostInstanceProgress(ctx echo.Context, namespace string, kind naming.Kind, name string) error

func (DaemonAPI) PostInstanceStateFile 

func (a DaemonAPI) PostInstanceStateFile(ctx echo.Context, nodename, namespace string, kind naming.Kind, name string) error

func (*DaemonAPI) PostInstanceStatus 

func (a *DaemonAPI) PostInstanceStatus(ctx echo.Context, namespace string, kind naming.Kind, name string) error

func (*DaemonAPI) PostNodeActionPushAsset 

func (a *DaemonAPI) PostNodeActionPushAsset(ctx echo.Context, nodename string, params api.PostNodeActionPushAssetParams) error

func (*DaemonAPI) PostNodeActionPushDisk 

func (a *DaemonAPI) PostNodeActionPushDisk(ctx echo.Context, nodename string, params api.PostNodeActionPushDiskParams) error

func (*DaemonAPI) PostNodeActionPushPatch 

func (a *DaemonAPI) PostNodeActionPushPatch(ctx echo.Context, nodename string, params api.PostNodeActionPushPatchParams) error

func (*DaemonAPI) PostNodeActionPushPkg 

func (a *DaemonAPI) PostNodeActionPushPkg(ctx echo.Context, nodename string, params api.PostNodeActionPushPkgParams) error

func (*DaemonAPI) PostNodeActionScanCapabilities 

func (a *DaemonAPI) PostNodeActionScanCapabilities(ctx echo.Context, nodename string, params api.PostNodeActionScanCapabilitiesParams) error

func (*DaemonAPI) PostNodeActionSysreport 

func (a *DaemonAPI) PostNodeActionSysreport(ctx echo.Context, nodename string, params api.PostNodeActionSysreportParams) error

func (*DaemonAPI) PostNodeClear 

func (a *DaemonAPI) PostNodeClear(ctx echo.Context) error

func (*DaemonAPI) PostNodeConfigUpdate 

func (a *DaemonAPI) PostNodeConfigUpdate(ctx echo.Context, nodename string, params api.PostNodeConfigUpdateParams) error

func (*DaemonAPI) PostNodeDRBDConfig 

func (a *DaemonAPI) PostNodeDRBDConfig(ctx echo.Context, nodename string, params api.PostNodeDRBDConfigParams) error

func (*DaemonAPI) PostObjectActionAbort 

func (a *DaemonAPI) PostObjectActionAbort(ctx echo.Context, namespace string, kind naming.Kind, name string) error

func (*DaemonAPI) PostObjectActionDelete 

func (a *DaemonAPI) PostObjectActionDelete(ctx echo.Context, namespace string, kind naming.Kind, name string) error

func (*DaemonAPI) PostObjectActionFreeze 

func (a *DaemonAPI) PostObjectActionFreeze(ctx echo.Context, namespace string, kind naming.Kind, name string) error

func (*DaemonAPI) PostObjectActionGiveback 

func (a *DaemonAPI) PostObjectActionGiveback(ctx echo.Context, namespace string, kind naming.Kind, name string) error

func (*DaemonAPI) PostObjectActionProvision 

func (a *DaemonAPI) PostObjectActionProvision(ctx echo.Context, namespace string, kind naming.Kind, name string) error

func (*DaemonAPI) PostObjectActionPurge 

func (a *DaemonAPI) PostObjectActionPurge(ctx echo.Context, namespace string, kind naming.Kind, name string) error

func (*DaemonAPI) PostObjectActionStart 

func (a *DaemonAPI) PostObjectActionStart(ctx echo.Context, namespace string, kind naming.Kind, name string) error

func (*DaemonAPI) PostObjectActionStop 

func (a *DaemonAPI) PostObjectActionStop(ctx echo.Context, namespace string, kind naming.Kind, name string) error

func (*DaemonAPI) PostObjectActionSwitch 

func (a *DaemonAPI) PostObjectActionSwitch(ctx echo.Context, namespace string, kind naming.Kind, name string) error

func (*DaemonAPI) PostObjectActionUnfreeze 

func (a *DaemonAPI) PostObjectActionUnfreeze(ctx echo.Context, namespace string, kind naming.Kind, name string) error

func (*DaemonAPI) PostObjectActionUnprovision 

func (a *DaemonAPI) PostObjectActionUnprovision(ctx echo.Context, namespace string, kind naming.Kind, name string) error

func (DaemonAPI) PostObjectConfigFile 

func (a DaemonAPI) PostObjectConfigFile(ctx echo.Context, namespace string, kind naming.Kind, name string) error

func (*DaemonAPI) PostObjectConfigUpdate 

func (a *DaemonAPI) PostObjectConfigUpdate(ctx echo.Context, namespace string, kind naming.Kind, name string, params api.PostObjectConfigUpdateParams) error

func (*DaemonAPI) PostPeerActionAbort 

func (a *DaemonAPI) PostPeerActionAbort(ctx echo.Context, nodename string) error

func (*DaemonAPI) PostPeerActionDrain 

func (a *DaemonAPI) PostPeerActionDrain(ctx echo.Context, nodename string) error

func (*DaemonAPI) PostPeerActionFreeze 

func (a *DaemonAPI) PostPeerActionFreeze(ctx echo.Context, nodename string, params api.PostPeerActionFreezeParams) error

func (*DaemonAPI) PostPeerActionUnfreeze 

func (a *DaemonAPI) PostPeerActionUnfreeze(ctx echo.Context, nodename string, params api.PostPeerActionUnfreezeParams) error

func (*DaemonAPI) PostRelayMessage 

func (a *DaemonAPI) PostRelayMessage(ctx echo.Context) error

func (*DaemonAPI) PostSvcDisable 

func (a *DaemonAPI) PostSvcDisable(ctx echo.Context, namespace string, name string, params api.PostSvcDisableParams) error

func (*DaemonAPI) PostSvcEnable 

func (a *DaemonAPI) PostSvcEnable(ctx echo.Context, namespace string, name string, params api.PostSvcEnableParams) error

func (DaemonAPI) PutObjectConfigFile 

func (a DaemonAPI) PutObjectConfigFile(ctx echo.Context, namespace string, kind naming.Kind, name string) error

type Filter 

type Filter struct {
	Kind   any
	Labels []pubsub.Label
}

type JWTCreater 

type JWTCreater interface {
	CreateUserToken(userInfo auth.Info, duration time.Duration, xClaims map[string]interface{}) (tk string, expiredAt time.Time, err error)
}

type Meta 

type Meta struct {
	Context echo.Context
	Path    *string
	Node    *string
	// contains filtered or unexported fields
}

func (*Meta) Expand 

func (m *Meta) Expand() error

func (*Meta) Grants 

func (m *Meta) Grants() rbac.Grants

func (*Meta) HasNode 

func (m *Meta) HasNode(s string) bool

func (*Meta) HasPath 

func (m *Meta) HasPath(s string) bool

func (*Meta) Nodes 

func (m *Meta) Nodes() []string

func (*Meta) Paths 

func (m *Meta) Paths() naming.Paths

type Strategier 

type Strategier interface {
	AuthenticateRequest(r *http.Request) (auth.Strategy, auth.Info, error)
}

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.