daemonapi

package
v3.0.0-beta11 Latest Latest
Warning

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

 Go to latest Published: Dec 12, 2025 License: Apache-2.0 Imports: 80 Imported by: 0

Documentation ¶

Index ¶

Constants ¶

This section is empty.

Variables ¶

View Source 
var (
	LogLevel = zerolog.InfoLevel
)

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 JSONForbiddenStrategy ¶ 

func JSONForbiddenStrategy(ctx echo.Context, strategy string, expected ...string) error

func JSONFromSetInstanceMonitorError ¶ 

func JSONFromSetInstanceMonitorError(eCtx echo.Context, value *instance.MonitorUpdate, err error) error

JSONFromSetInstanceMonitorError sends a JSON response where status code depends on SetMonitorUpdate error value.

  • StatusOK: expectation value accepted
  • StatusRequestTimeout: request context DeadlineExceeded or timeout reached
  • StatusConflict: expectation value refused

func JSONFromSetNodeMonitorError ¶ 

func JSONFromSetNodeMonitorError(eCtx echo.Context, value *node.MonitorUpdate, err error) error

JSONFromSetNodeMonitorError sends a JSON response where status code depends on SetNodeMonitor error value.

  • StatusOK: expectation value accepted
  • StatusRequestTimeout: request context DeadlineExceeded or timeout reached
  • StatusConflict: expectation value refused

func JSONProblem ¶ 

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

func JSONProblemf ¶ 

func JSONProblemf(ctx echo.Context, code int, title, format string, a ...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 SubQS ¶ 

func SubQS(ctx context.Context) pubsub.QueueSizer

SubQS function returns api pubsub.QueueSizer from context

func UIMiddleware ¶ 

func UIMiddleware(_ context.Context, prefix string, specURL string) echo.MiddlewareFunc

func WithSubQS ¶ 

func WithSubQS(parent context.Context, subQS pubsub.QueueSizer) context.Context

WithSubQS function returns copy of parent with api pubsub.QueueSizer.

Types ¶

type DaemonAPI ¶ 

type DaemonAPI struct {
	Daemondata *daemondata.T
	SubFactory pubsub.Subscriber
	Publisher  pubsub.Publisher
	JWTcreator JWTCreater

	LabelLocalhost pubsub.Label

	SubQS pubsub.QueueSizer
	// contains filtered or unexported fields
}

func New ¶ 

func New(ctx context.Context) *DaemonAPI

func (*DaemonAPI) CheckDataSize ¶ 

func (a *DaemonAPI) CheckDataSize(ctx echo.Context) (bool, error)

func (*DaemonAPI) DeleteObjectDataKey ¶ 

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

func (*DaemonAPI) GetAuthInfo ¶ 

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

func (*DaemonAPI) GetAuthWhoAmI ¶ 

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

func (*DaemonAPI) GetClusterConfig ¶ 

func (a *DaemonAPI) GetClusterConfig(ctx echo.Context, params api.GetClusterConfigParams) error

func (*DaemonAPI) GetClusterConfigFile ¶ 

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

func (*DaemonAPI) GetClusterConfigKeywords ¶ 

func (a *DaemonAPI) GetClusterConfigKeywords(ctx echo.Context, params api.GetClusterConfigKeywordsParams) error

func (*DaemonAPI) GetClusterStatus ¶ 

func (a *DaemonAPI) GetClusterStatus(ctx echo.Context, params api.GetClusterStatusParams) error

GetDaemonStatus returns daemon data status

Serve 2s cached data.

func (*DaemonAPI) GetDaemonDNSDump ¶ 

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

GetDaemonDNSDump 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) GetInstance ¶ 

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

func (*DaemonAPI) GetInstanceConfigFile ¶ 

func (a *DaemonAPI) GetInstanceConfigFile(ctx echo.Context, nodename, 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) GetInstanceResourceFile ¶ 

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

func (*DaemonAPI) GetInstanceResourceInfo ¶ 

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

func (*DaemonAPI) GetInstanceSchedule ¶ 

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

func (*DaemonAPI) GetInstances ¶ 

func (a *DaemonAPI) GetInstances(ctx echo.Context, params api.GetInstancesParams) 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) GetNodeConfigFile ¶ 

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

func (*DaemonAPI) GetNodeConfigKeywords ¶ 

func (a *DaemonAPI) GetNodeConfigKeywords(ctx echo.Context, nodename string, params api.GetNodeConfigKeywordsParams) 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) GetNodeSSHHostkeys ¶ 

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

func (*DaemonAPI) GetNodeSSHKey ¶ 

func (a *DaemonAPI) GetNodeSSHKey(ctx echo.Context, nodename string) 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) GetObjectConfigKeywords ¶ 

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

func (*DaemonAPI) GetObjectData ¶ 

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

func (*DaemonAPI) GetObjectDataKey ¶ 

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

func (*DaemonAPI) GetObjectDataKeys ¶ 

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

func (*DaemonAPI) GetObjectPaths ¶ 

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

func (*DaemonAPI) GetObjectResourceInfo ¶ 

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

func (*DaemonAPI) GetObjectSchedule ¶ 

func (a *DaemonAPI) GetObjectSchedule(ctx echo.Context, 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) GetRelayStatus ¶ 

func (a *DaemonAPI) GetRelayStatus(ctx echo.Context, params api.GetRelayStatusParams) 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) PatchClusterConfig ¶ 

func (a *DaemonAPI) PatchClusterConfig(ctx echo.Context, params api.PatchClusterConfigParams) error

func (*DaemonAPI) PatchNodeConfig ¶ 

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

func (*DaemonAPI) PatchObjectConfig ¶ 

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

func (*DaemonAPI) PatchObjectData ¶ 

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

func (*DaemonAPI) PostAuthRefresh ¶ 

func (a *DaemonAPI) PostAuthRefresh(ctx echo.Context, params api.PostAuthRefreshParams) error

PostAuthRefresh create a new token for the refresh token user

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(eCtx 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) PostClusterHeartbeatRotate ¶ 

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

func (*DaemonAPI) PostClusterJoin ¶ 

func (a *DaemonAPI) PostClusterJoin(ctx echo.Context, params api.PostClusterJoinParams) error

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

func (*DaemonAPI) PostClusterLeave ¶ 

func (a *DaemonAPI) PostClusterLeave(ctx echo.Context, params api.PostClusterLeaveParams) error

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

func (*DaemonAPI) PostDaemonHeartbeatRestart ¶ 

func (a *DaemonAPI) PostDaemonHeartbeatRestart(ctx echo.Context, nodename api.InPathNodeName, name api.InPathHeartbeatName) error

func (*DaemonAPI) PostDaemonHeartbeatSign ¶ 

func (a *DaemonAPI) PostDaemonHeartbeatSign(ctx echo.Context, nodename api.InPathNodeName, name api.InPathHeartbeatName) error

func (*DaemonAPI) PostDaemonHeartbeatStart ¶ 

func (a *DaemonAPI) PostDaemonHeartbeatStart(ctx echo.Context, nodename api.InPathNodeName, name api.InPathHeartbeatName) error

func (*DaemonAPI) PostDaemonHeartbeatStop ¶ 

func (a *DaemonAPI) PostDaemonHeartbeatStop(ctx echo.Context, nodename api.InPathNodeName, name api.InPathHeartbeatName) error

func (*DaemonAPI) PostDaemonHeartbeatWipe ¶ 

func (a *DaemonAPI) PostDaemonHeartbeatWipe(ctx echo.Context, nodename api.InPathNodeName, name api.InPathHeartbeatName) error

func (*DaemonAPI) PostDaemonListenerLogControl ¶ 

func (a *DaemonAPI) PostDaemonListenerLogControl(ctx echo.Context, nodename api.InPathNodeName, name api.InPathListenerName) error

func (*DaemonAPI) PostDaemonListenerRestart ¶ 

func (a *DaemonAPI) PostDaemonListenerRestart(ctx echo.Context, nodename api.InPathNodeName, name api.InPathListenerName) error

func (*DaemonAPI) PostDaemonListenerStart ¶ 

func (a *DaemonAPI) PostDaemonListenerStart(ctx echo.Context, nodename api.InPathNodeName, name api.InPathListenerName) error

func (*DaemonAPI) PostDaemonListenerStop ¶ 

func (a *DaemonAPI) PostDaemonListenerStop(ctx echo.Context, nodename api.InPathNodeName, name api.InPathListenerName) error

func (*DaemonAPI) PostDaemonLogControl ¶ 

func (a *DaemonAPI) PostDaemonLogControl(ctx echo.Context, nodename string) 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) 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) PostInstanceActionPushResourceInfo ¶ 

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

func (*DaemonAPI) PostInstanceActionRestart ¶ 

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

func (*DaemonAPI) PostInstanceActionRun ¶ 

func (a *DaemonAPI) PostInstanceActionRun(ctx echo.Context, nodename, namespace string, kind naming.Kind, name string, params api.PostInstanceActionRunParams) 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) PostInstanceActionStatus ¶ 

func (a *DaemonAPI) PostInstanceActionStatus(ctx echo.Context, nodename, namespace string, kind naming.Kind, name string, params api.PostInstanceActionStatusParams) 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) PostInstanceActionSyncIngest ¶ 

func (a *DaemonAPI) PostInstanceActionSyncIngest(ctx echo.Context, nodename, namespace string, kind naming.Kind, name string, params api.PostInstanceActionSyncIngestParams) 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) PostInstanceResourceConsole ¶ 

func (a *DaemonAPI) PostInstanceResourceConsole(ctx echo.Context, nodename, namespace string, kind naming.Kind, name string, params api.PostInstanceResourceConsoleParams) 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) PostNodeActionClear ¶ 

func (a *DaemonAPI) PostNodeActionClear(ctx echo.Context, nodename 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) PostNodeDRBDConfig ¶ 

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

func (*DaemonAPI) PostNodeDRBDConnect ¶ 

func (a *DaemonAPI) PostNodeDRBDConnect(ctx echo.Context, nodename api.InPathNodeName, params api.PostNodeDRBDConnectParams) error

func (*DaemonAPI) PostNodeDRBDPrimary ¶ 

func (a *DaemonAPI) PostNodeDRBDPrimary(ctx echo.Context, nodename api.InPathNodeName, params api.PostNodeDRBDPrimaryParams) error

func (*DaemonAPI) PostNodeDRBDSecondary ¶ 

func (a *DaemonAPI) PostNodeDRBDSecondary(ctx echo.Context, nodename api.InPathNodeName, params api.PostNodeDRBDSecondaryParams) 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) PostObjectActionRestart ¶ 

func (a *DaemonAPI) PostObjectActionRestart(eCtx 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(eCtx 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) PostObjectDataKey ¶ 

func (a *DaemonAPI) PostObjectDataKey(ctx echo.Context, namespace string, kind naming.Kind, name string, params api.PostObjectDataKeyParams) 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) PutClusterConfigFile ¶ 

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

func (*DaemonAPI) PutNodeConfigFile ¶ 

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

func (*DaemonAPI) PutNodeSSHTrust ¶ 

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

func (*DaemonAPI) PutObjectConfigFile ¶ 

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

func (*DaemonAPI) PutObjectDataKey ¶ 

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

type DataFilter ¶ 

type DataFilter struct {
	Key   string
	Value string
	Op    string
}

DataFilter represents a filtering data condition based on a key, value, and an operator.

type DataFilters ¶ 

type DataFilters []DataFilter

DataFilters is a slice of DataFilter used to define a collection of filtering data conditions.

type Filter ¶ 

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

	// DataFilters is a slice of DataFilter used to define filtering data conditions
	// based on key, value, and operator.
	DataFilters DataFilters
}

func (Filter) IsZero ¶ 

func (f Filter) IsZero() bool

type JWTCreater ¶ 

type JWTCreater interface {
	CreateToken(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.