broker

package

Go to main page

Versions in this module

v0

v0.2.4

Oct 20, 2023

Changes in this version

+ func BrokerProxyError(w http.ResponseWriter, logger logr.Logger, err error, message string, ...)

+ func NewHttpClient(Certificate string) *http.Client

type ClientOption

+ func WithHttpsClient(Certificate string) ClientOption

+ type ErrorProxyResponse struct

+ Error ErrorRedfish

+ type ErrorRedfish struct

+ Code string

+ Message string

type RequestEditorFn

+ func AddBasicAuth(username string, password string) RequestEditorFn

v0.2.3

Sep 15, 2023

Changes in this version

+ const KanodServerNamelabel

+ func GetSwagger() (swagger *openapi3.T, err error)

+ func Handler(si ServerInterface) http.Handler

+ func HandlerFromMux(si ServerInterface, r *mux.Router) http.Handler

+ func HandlerFromMuxWithBaseURL(si ServerInterface, r *mux.Router, baseURL string) http.Handler

+ func HandlerWithOptions(si ServerInterface, options GorillaServerOptions) http.Handler

+ func NewCreatePoolRequest(server string, body CreatePoolJSONRequestBody) (*http.Request, error)

+ func NewCreatePoolRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)

+ func NewCreateServerRequest(server string, poolid string, body CreateServerJSONRequestBody) (*http.Request, error)

+ func NewCreateServerRequestWithBody(server string, poolid string, contentType string, body io.Reader) (*http.Request, error)

+ func NewDumpRequest(server string) (*http.Request, error)

+ func NewGetAllServersRequest(server string, poolid string) (*http.Request, error)

+ func NewGetPoolRequest(server string, poolid string) (*http.Request, error)

+ func NewGetPooluserPasswordRequest(server string, pooluserid string) (*http.Request, error)

+ func NewGetServerByIDRequest(server string, poolid string, serverid string) (*http.Request, error)

+ func NewRemovePoolRequest(server string, poolid string) (*http.Request, error)

+ func NewRemoveServerRequest(server string, poolid string, serverid string) (*http.Request, error)

+ func NewSignChallengeRequest(server string, poolid string, body SignChallengeJSONRequestBody) (*http.Request, error)

+ func NewSignChallengeRequestWithBody(server string, poolid string, contentType string, body io.Reader) (*http.Request, error)

+ func NewTestVerifySignatureRequest(server string, body TestVerifySignatureJSONRequestBody) (*http.Request, error)

+ func NewTestVerifySignatureRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)

+ func NewVerifySignatureRequest(server string, body VerifySignatureJSONRequestBody) (*http.Request, error)

+ func NewVerifySignatureRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)

+ func PathToRawSpec(pathToFile string) map[string]func() ([]byte, error)

+ type AuthScope string

+ const PoolBasicAuthScopes

type Broker

+ func (b *Broker) AddServerInPoolStore(poolname string, serverdata *ServerData)

+ func (b *Broker) AddUserInUserStore(user *User)

+ func (b *Broker) BookOneServer(pool *brokerv1.PoolDef) (bool, error)

+ func (b *Broker) CreateNewPoolInPoolStore(pool Pool)

+ func (b *Broker) CreateServer(w http.ResponseWriter, r *http.Request, poolId string)

+ func (b *Broker) DeletePoolInPoolStore(poolId string)

+ func (b *Broker) DeleteUserInPoolStore(userId string, logger logr.Logger)

+ func (b *Broker) DisassociateServerFromPool(serverId string, poolId string)

+ func (b *Broker) Dump(w http.ResponseWriter, r *http.Request)

+ func (b *Broker) GetAllServers(w http.ResponseWriter, r *http.Request, poolId string)

+ func (b *Broker) GetPool(w http.ResponseWriter, r *http.Request, poolId string)

+ func (b *Broker) GetPoolUser(poolUserName string) (*brokerv1.PoolUser, error)

+ func (b *Broker) GetPooluserPassword(w http.ResponseWriter, r *http.Request, poolUserId string)

+ func (b *Broker) GetSecret(secretName string) (*corev1.Secret, error)

+ func (b *Broker) GetServerByID(w http.ResponseWriter, r *http.Request, poolId string, serverId string)

+ func (b *Broker) ReleaseOneServer(pool *brokerv1.PoolDef) error

+ func (b *Broker) RemovePool(w http.ResponseWriter, r *http.Request, poolId string)

+ func (b *Broker) RemoveServer(w http.ResponseWriter, r *http.Request, poolId string, serverId string)

+ func (b *Broker) SignChallenge(w http.ResponseWriter, r *http.Request, poolId string)

+ func (b *Broker) TestVerifySignature(w http.ResponseWriter, r *http.Request)

+ func (b *Broker) UpdatePoolValuesInPoolStore(name string, poolValues Pool)

+ func (b *Broker) UpdateUserUsage(userId string, namespace string) error

+ type Client struct

+ Client HttpRequestDoer

+ RequestEditors []RequestEditorFn

+ Server string

+ func NewClient(server string, opts ...ClientOption) (*Client, error)

+ func (c *Client) CreatePool(ctx context.Context, body CreatePoolJSONRequestBody, ...) (*http.Response, error)

+ func (c *Client) CreatePoolWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ func (c *Client) CreateServer(ctx context.Context, poolid string, body CreateServerJSONRequestBody, ...) (*http.Response, error)

+ func (c *Client) CreateServerWithBody(ctx context.Context, poolid string, contentType string, body io.Reader, ...) (*http.Response, error)

+ func (c *Client) Dump(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) GetAllServers(ctx context.Context, poolid string, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) GetPool(ctx context.Context, poolid string, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) GetPooluserPassword(ctx context.Context, pooluserid string, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) GetServerByID(ctx context.Context, poolid string, serverid string, ...) (*http.Response, error)

+ func (c *Client) RemovePool(ctx context.Context, poolid string, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) RemoveServer(ctx context.Context, poolid string, serverid string, ...) (*http.Response, error)

+ func (c *Client) SignChallenge(ctx context.Context, poolid string, body SignChallengeJSONRequestBody, ...) (*http.Response, error)

+ func (c *Client) SignChallengeWithBody(ctx context.Context, poolid string, contentType string, body io.Reader, ...) (*http.Response, error)

+ func (c *Client) TestVerifySignature(ctx context.Context, body TestVerifySignatureJSONRequestBody, ...) (*http.Response, error)

+ func (c *Client) TestVerifySignatureWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ func (c *Client) VerifySignature(ctx context.Context, body VerifySignatureJSONRequestBody, ...) (*http.Response, error)

+ func (c *Client) VerifySignatureWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ type ClientInterface interface

+ CreatePool func(ctx context.Context, body CreatePoolJSONRequestBody, ...) (*http.Response, error)

+ CreatePoolWithBody func(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ CreateServer func(ctx context.Context, poolid string, body CreateServerJSONRequestBody, ...) (*http.Response, error)

+ CreateServerWithBody func(ctx context.Context, poolid string, contentType string, body io.Reader, ...) (*http.Response, error)

+ Dump func(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

+ GetAllServers func(ctx context.Context, poolid string, reqEditors ...RequestEditorFn) (*http.Response, error)

+ GetPool func(ctx context.Context, poolid string, reqEditors ...RequestEditorFn) (*http.Response, error)

+ GetPooluserPassword func(ctx context.Context, pooluserid string, reqEditors ...RequestEditorFn) (*http.Response, error)

+ GetServerByID func(ctx context.Context, poolid string, serverid string, ...) (*http.Response, error)

+ RemovePool func(ctx context.Context, poolid string, reqEditors ...RequestEditorFn) (*http.Response, error)

+ RemoveServer func(ctx context.Context, poolid string, serverid string, ...) (*http.Response, error)

+ SignChallenge func(ctx context.Context, poolid string, body SignChallengeJSONRequestBody, ...) (*http.Response, error)

+ SignChallengeWithBody func(ctx context.Context, poolid string, contentType string, body io.Reader, ...) (*http.Response, error)

+ TestVerifySignature func(ctx context.Context, body TestVerifySignatureJSONRequestBody, ...) (*http.Response, error)

+ TestVerifySignatureWithBody func(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ VerifySignature func(ctx context.Context, body VerifySignatureJSONRequestBody, ...) (*http.Response, error)

+ VerifySignatureWithBody func(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ type ClientOption func(*Client) error

+ func WithBaseURL(baseURL string) ClientOption

+ func WithHTTPClient(doer HttpRequestDoer) ClientOption

+ func WithRequestEditorFn(fn RequestEditorFn) ClientOption

+ type ClientWithResponses struct

+ func NewClientWithResponses(server string, opts ...ClientOption) (*ClientWithResponses, error)

+ func (c *ClientWithResponses) CreatePoolWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*CreatePoolResponse, error)

+ func (c *ClientWithResponses) CreatePoolWithResponse(ctx context.Context, body CreatePoolJSONRequestBody, ...) (*CreatePoolResponse, error)

+ func (c *ClientWithResponses) CreateServerWithBodyWithResponse(ctx context.Context, poolid string, contentType string, body io.Reader, ...) (*CreateServerResponse, error)

+ func (c *ClientWithResponses) CreateServerWithResponse(ctx context.Context, poolid string, body CreateServerJSONRequestBody, ...) (*CreateServerResponse, error)

+ func (c *ClientWithResponses) DumpWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*DumpResponse, error)

+ func (c *ClientWithResponses) GetAllServersWithResponse(ctx context.Context, poolid string, reqEditors ...RequestEditorFn) (*GetAllServersResponse, error)

+ func (c *ClientWithResponses) GetPoolWithResponse(ctx context.Context, poolid string, reqEditors ...RequestEditorFn) (*GetPoolResponse, error)

+ func (c *ClientWithResponses) GetPooluserPasswordWithResponse(ctx context.Context, pooluserid string, reqEditors ...RequestEditorFn) (*GetPooluserPasswordResponse, error)

+ func (c *ClientWithResponses) GetServerByIDWithResponse(ctx context.Context, poolid string, serverid string, ...) (*GetServerByIDResponse, error)

+ func (c *ClientWithResponses) RemovePoolWithResponse(ctx context.Context, poolid string, reqEditors ...RequestEditorFn) (*RemovePoolResponse, error)

+ func (c *ClientWithResponses) RemoveServerWithResponse(ctx context.Context, poolid string, serverid string, ...) (*RemoveServerResponse, error)

+ func (c *ClientWithResponses) SignChallengeWithBodyWithResponse(ctx context.Context, poolid string, contentType string, body io.Reader, ...) (*SignChallengeResponse, error)

+ func (c *ClientWithResponses) SignChallengeWithResponse(ctx context.Context, poolid string, body SignChallengeJSONRequestBody, ...) (*SignChallengeResponse, error)

+ func (c *ClientWithResponses) TestVerifySignatureWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*TestVerifySignatureResponse, error)

+ func (c *ClientWithResponses) TestVerifySignatureWithResponse(ctx context.Context, body TestVerifySignatureJSONRequestBody, ...) (*TestVerifySignatureResponse, error)

+ func (c *ClientWithResponses) VerifySignatureWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*VerifySignatureResponse, error)

+ func (c *ClientWithResponses) VerifySignatureWithResponse(ctx context.Context, body VerifySignatureJSONRequestBody, ...) (*VerifySignatureResponse, error)

+ type ClientWithResponsesInterface interface

+ CreatePoolWithBodyWithResponse func(ctx context.Context, contentType string, body io.Reader, ...) (*CreatePoolResponse, error)

+ CreatePoolWithResponse func(ctx context.Context, body CreatePoolJSONRequestBody, ...) (*CreatePoolResponse, error)

+ CreateServerWithBodyWithResponse func(ctx context.Context, poolid string, contentType string, body io.Reader, ...) (*CreateServerResponse, error)

+ CreateServerWithResponse func(ctx context.Context, poolid string, body CreateServerJSONRequestBody, ...) (*CreateServerResponse, error)

+ DumpWithResponse func(ctx context.Context, reqEditors ...RequestEditorFn) (*DumpResponse, error)

+ GetAllServersWithResponse func(ctx context.Context, poolid string, reqEditors ...RequestEditorFn) (*GetAllServersResponse, error)

+ GetPoolWithResponse func(ctx context.Context, poolid string, reqEditors ...RequestEditorFn) (*GetPoolResponse, error)

+ GetPooluserPasswordWithResponse func(ctx context.Context, pooluserid string, reqEditors ...RequestEditorFn) (*GetPooluserPasswordResponse, error)

+ GetServerByIDWithResponse func(ctx context.Context, poolid string, serverid string, ...) (*GetServerByIDResponse, error)

+ RemovePoolWithResponse func(ctx context.Context, poolid string, reqEditors ...RequestEditorFn) (*RemovePoolResponse, error)

+ RemoveServerWithResponse func(ctx context.Context, poolid string, serverid string, ...) (*RemoveServerResponse, error)

+ SignChallengeWithBodyWithResponse func(ctx context.Context, poolid string, contentType string, body io.Reader, ...) (*SignChallengeResponse, error)

+ SignChallengeWithResponse func(ctx context.Context, poolid string, body SignChallengeJSONRequestBody, ...) (*SignChallengeResponse, error)

+ TestVerifySignatureWithBodyWithResponse func(ctx context.Context, contentType string, body io.Reader, ...) (*TestVerifySignatureResponse, error)

+ TestVerifySignatureWithResponse func(ctx context.Context, body TestVerifySignatureJSONRequestBody, ...) (*TestVerifySignatureResponse, error)

+ VerifySignatureWithBodyWithResponse func(ctx context.Context, contentType string, body io.Reader, ...) (*VerifySignatureResponse, error)

+ VerifySignatureWithResponse func(ctx context.Context, body VerifySignatureJSONRequestBody, ...) (*VerifySignatureResponse, error)

+ type CreatePoolJSONRequestBody = PoolRequest

+ type CreatePoolResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON201 *PoolResponse

+ JSONDefault *Error

+ func ParseCreatePoolResponse(rsp *http.Response) (*CreatePoolResponse, error)

+ func (r CreatePoolResponse) Status() string

+ func (r CreatePoolResponse) StatusCode() int

+ type CreateServerJSONRequestBody = ServerRequest

+ type CreateServerResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON201 *ServerResponse

+ JSONDefault *Error

+ func ParseCreateServerResponse(rsp *http.Response) (*CreateServerResponse, error)

+ func (r CreateServerResponse) Status() string

+ func (r CreateServerResponse) StatusCode() int

+ type DumpResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSONDefault *Error

+ func ParseDumpResponse(rsp *http.Response) (*DumpResponse, error)

+ func (r DumpResponse) Status() string

+ func (r DumpResponse) StatusCode() int

+ type Error struct

+ Message string

+ type GetAllServersResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *[]ServerResponse

+ JSONDefault *Error

+ func ParseGetAllServersResponse(rsp *http.Response) (*GetAllServersResponse, error)

+ func (r GetAllServersResponse) Status() string

+ func (r GetAllServersResponse) StatusCode() int

+ type GetPoolResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *PoolResponse

+ JSONDefault *Error

+ func ParseGetPoolResponse(rsp *http.Response) (*GetPoolResponse, error)

+ func (r GetPoolResponse) Status() string

+ func (r GetPoolResponse) StatusCode() int

+ type GetPooluserPasswordResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *PasswordData

+ JSONDefault *Error

+ func ParseGetPooluserPasswordResponse(rsp *http.Response) (*GetPooluserPasswordResponse, error)

+ func (r GetPooluserPasswordResponse) Status() string

+ func (r GetPooluserPasswordResponse) StatusCode() int

+ type GetServerByIDResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *ServerResponse

+ JSONDefault *Error

+ func ParseGetServerByIDResponse(rsp *http.Response) (*GetServerByIDResponse, error)

+ func (r GetServerByIDResponse) Status() string

+ func (r GetServerByIDResponse) StatusCode() int

+ type GorillaServerOptions struct

+ BaseRouter *mux.Router

+ BaseURL string

+ ErrorHandlerFunc func(w http.ResponseWriter, r *http.Request, err error)

+ Middlewares []MiddlewareFunc

+ type HttpRequestDoer interface

+ Do func(req *http.Request) (*http.Response, error)

+ type InternalStore struct

+ PoolStore map[string]*Pool

+ Userstore map[string]*User

+ type InvalidParamFormatError struct

+ Err error

+ ParamName string

+ func (e *InvalidParamFormatError) Error() string

+ func (e *InvalidParamFormatError) Unwrap() error

+ type MiddlewareFunc func(http.Handler) http.Handler

+ type RemovePoolResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSONDefault *Error

+ func ParseRemovePoolResponse(rsp *http.Response) (*RemovePoolResponse, error)

+ func (r RemovePoolResponse) Status() string

+ func (r RemovePoolResponse) StatusCode() int

+ type RemoveServerResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSONDefault *Error

+ func ParseRemoveServerResponse(rsp *http.Response) (*RemoveServerResponse, error)

+ func (r RemoveServerResponse) Status() string

+ func (r RemoveServerResponse) StatusCode() int

+ type RequestEditorFn func(ctx context.Context, req *http.Request) error

+ type RequiredHeaderError struct

+ Err error

+ ParamName string

+ func (e *RequiredHeaderError) Error() string

+ func (e *RequiredHeaderError) Unwrap() error

+ type RequiredParamError struct

+ ParamName string

+ func (e *RequiredParamError) Error() string

+ type ServerInterface interface

+ CreatePool func(w http.ResponseWriter, r *http.Request)

+ CreateServer func(w http.ResponseWriter, r *http.Request, poolid string)

+ Dump func(w http.ResponseWriter, r *http.Request)

+ GetAllServers func(w http.ResponseWriter, r *http.Request, poolid string)

+ GetPool func(w http.ResponseWriter, r *http.Request, poolid string)

+ GetPooluserPassword func(w http.ResponseWriter, r *http.Request, pooluserid string)

+ GetServerByID func(w http.ResponseWriter, r *http.Request, poolid string, serverid string)

+ RemovePool func(w http.ResponseWriter, r *http.Request, poolid string)

+ RemoveServer func(w http.ResponseWriter, r *http.Request, poolid string, serverid string)

+ SignChallenge func(w http.ResponseWriter, r *http.Request, poolid string)

+ TestVerifySignature func(w http.ResponseWriter, r *http.Request)

+ VerifySignature func(w http.ResponseWriter, r *http.Request)

+ type ServerInterfaceWrapper struct

+ ErrorHandlerFunc func(w http.ResponseWriter, r *http.Request, err error)

+ Handler ServerInterface

+ HandlerMiddlewares []MiddlewareFunc

+ func (siw *ServerInterfaceWrapper) CreatePool(w http.ResponseWriter, r *http.Request)

+ func (siw *ServerInterfaceWrapper) CreateServer(w http.ResponseWriter, r *http.Request)

+ func (siw *ServerInterfaceWrapper) Dump(w http.ResponseWriter, r *http.Request)

+ func (siw *ServerInterfaceWrapper) GetAllServers(w http.ResponseWriter, r *http.Request)

+ func (siw *ServerInterfaceWrapper) GetPool(w http.ResponseWriter, r *http.Request)

+ func (siw *ServerInterfaceWrapper) GetPooluserPassword(w http.ResponseWriter, r *http.Request)

+ func (siw *ServerInterfaceWrapper) GetServerByID(w http.ResponseWriter, r *http.Request)

+ func (siw *ServerInterfaceWrapper) RemovePool(w http.ResponseWriter, r *http.Request)

+ func (siw *ServerInterfaceWrapper) RemoveServer(w http.ResponseWriter, r *http.Request)

+ func (siw *ServerInterfaceWrapper) SignChallenge(w http.ResponseWriter, r *http.Request)

+ func (siw *ServerInterfaceWrapper) TestVerifySignature(w http.ResponseWriter, r *http.Request)

+ func (siw *ServerInterfaceWrapper) VerifySignature(w http.ResponseWriter, r *http.Request)

+ type SignChallengeJSONRequestBody = ChallengeRequest

+ type SignChallengeResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *ChallengeResponse

+ JSONDefault *Error

+ func ParseSignChallengeResponse(rsp *http.Response) (*SignChallengeResponse, error)

+ func (r SignChallengeResponse) Status() string

+ func (r SignChallengeResponse) StatusCode() int

+ type TestVerifySignatureJSONRequestBody = SignatureRequest

+ type TestVerifySignatureResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON201 *SignatureResponse

+ JSONDefault *Error

+ func ParseTestVerifySignatureResponse(rsp *http.Response) (*TestVerifySignatureResponse, error)

+ func (r TestVerifySignatureResponse) Status() string

+ func (r TestVerifySignatureResponse) StatusCode() int

+ type TooManyValuesForParamError struct

+ Count int

+ ParamName string

+ func (e *TooManyValuesForParamError) Error() string

+ type UnescapedCookieParamError struct

+ Err error

+ ParamName string

+ func (e *UnescapedCookieParamError) Error() string

+ func (e *UnescapedCookieParamError) Unwrap() error

+ type UnmarshalingParamError struct

+ Err error

+ ParamName string

+ func (e *UnmarshalingParamError) Error() string

+ func (e *UnmarshalingParamError) Unwrap() error

+ type VerifySignatureJSONRequestBody = SignatureRequest

+ type VerifySignatureResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON201 *SignatureResponse

+ JSONDefault *Error

+ func ParseVerifySignatureResponse(rsp *http.Response) (*VerifySignatureResponse, error)

+ func (r VerifySignatureResponse) Status() string

+ func (r VerifySignatureResponse) StatusCode() int

v0.2.2

Aug 30, 2023

Changes in this version

+ const KanodPoolNamelabel

+ func BrokerDefError(w http.ResponseWriter, logger logr.Logger, err error, message string, ...)

type Broker

+ func (b *Broker) AddLabelsAndAnnotations(baremetalId string, namespace string, poolId string, serverId string, ...) error

+ func (b *Broker) AssociateServerToPool(poolId string, serverId string, bareMetalDef brokerv1.BareMetalDef, ...) error

type ServerData

+ BmcPassword string

+ BmcUsername string

+ Url string

v0.2.1

Jul 12, 2023

v0.2.0

Jun 26, 2023

Changes in this version

+ type BareMetal struct

+ DisableCertificateVerification bool

+ Id string

+ K8sAnnotations map[string]string

+ K8sLabels map[string]string

+ MacAddress string

+ Password string

+ RootDeviceHints *bmh.RootDeviceHints

+ Url string

+ Username string

type Broker

+ BareMetals map[string]*BareMetal

+ func (b *Broker) BareMetalFound(name string) bool

+ func (b *Broker) DeleteBareMetal(name string)

+ func (b *Broker) GetBareMetal(name string) *BareMetal

+ func (b *Broker) RetrieveAllBareMetals() []BareMetal

type BrokerData

+ BareMetals map[string]*BareMetal

type ServerData

+ BareMetal string

type ServerResponse

+ BareMetal string

v0.1.19

Jun 23, 2023

v0.1.18

Jun 15, 2023

v0.1.17

Jun 14, 2023

v0.1.16

May 5, 2023

Changes in this version

+ const BmhPausedAnnotation

+ const BmhPausedAnnotationValue

+ const KanodBmdefNetworkAnnotation

v0.1.15

Apr 11, 2023

Changes in this version

type Pool

+ NetDefMap map[string]string

type PoolResponse

+ NetDefMap map[string]string

v0.1.14

Mar 30, 2023

v0.1.13

Mar 22, 2023

Changes in this version

+ const KanodPoolnameAnnotation

+ const KanodRedfishSchemaAnnotation

+ const KanodServernameAnnotation

type Pool

+ NetDefList []string

type PoolResponse

+ NetDefList []string

v0.1.12

Feb 14, 2023

Changes in this version

type BrokerProxy

+ RedfishDomain string

v0.1.11

Dec 9, 2022

Changes in this version

+ type PasswordData struct

+ Password string

v0.1.10

Dec 7, 2022

Changes in this version

+ const ACCOUNTS_PATH

+ type Account struct

+ Enabled bool

+ Id string

+ Locked bool

+ Name string

+ Password string

+ RoleId string

+ UserName string

+ type Broker struct

+ Baremetals map[string]*Baremetal

+ BrokerImplem BrokerImplem

+ Client client.Client

+ Log logr.Logger

+ Mutex sync.Mutex

+ Namespace string

+ Pools map[string]*Pool

+ Scheme *runtime.Scheme

+ Users map[string]*User

+ func NewBroker(client client.Client, logr logr.Logger, scheme *runtime.Scheme, ...) *Broker

+ func (b *Broker) AddAnnotation(baremetalId string, namespace string, poolId string, serverId string, ...) error

+ func (b *Broker) BaremetalFound(name string) bool

+ func (b *Broker) BookOne(pool *Pool) bool

+ func (b *Broker) CountUsage(user *User)

+ func (b *Broker) CreateNewPool(pool Pool)

+ func (b *Broker) CreateNewServer(poolId string, serverId string, baremetalName string, schema string)

+ func (b *Broker) CreatePool(w http.ResponseWriter, r *http.Request)

+ func (b *Broker) DeleteBaremetal(name string)

+ func (b *Broker) DeletePool(poolId string, logger logr.Logger)

+ func (b *Broker) DeleteServer(serverId string, poolId string)

+ func (b *Broker) DeleteUser(userId string, logger logr.Logger)

+ func (b *Broker) GetBaremetal(name string) *Baremetal

+ func (b *Broker) GetPoolResponse(poolId string) *PoolResponse

+ func (b *Broker) GetServerResponse(name string, poolid string) *ServerResponse

+ func (b *Broker) HandleBrokerApiRequests()

+ func (b *Broker) InitBrokerData(setupLog logr.Logger) error

+ func (b *Broker) IsBrokerDataEmpty() bool

+ func (b *Broker) PoolFound(name string) bool

+ func (b *Broker) ReleaseOne(pool *Pool)

+ func (b *Broker) RetrieveAllBaremetals() []Baremetal

+ func (b *Broker) RetrieveAllPools() []PoolResponse

+ func (b *Broker) RetrieveAllServers(poolId string) []ServerResponse

+ func (b *Broker) ServerFound(name string, poolid string) bool

+ func (b *Broker) UpdatePoolValues(name string, poolValues Pool)

+ func (b *Broker) VerifyPoolAuthent(username string, password string, poolId string) bool

+ func (b *Broker) VerifySignature(w http.ResponseWriter, r *http.Request)

+ func (b *Broker) VerifyUserAuthent(username string, password string) bool

+ type BrokerAuth struct

+ Broker *Broker

+ func (ba *BrokerAuth) CreateAccount(bmh *Baremetal, username string, password string) error

+ func (ba *BrokerAuth) FindAccount(redfishClient *RedfishClient, username string) (string, error)

+ func (ba *BrokerAuth) GetComponents(client *RedfishClient, target string) ([]string, error)

+ func (ba *BrokerAuth) GetRedfishClient(bmh *Baremetal) (*RedfishClient, error)

+ func (ba *BrokerAuth) RemoveAccount(bmh *Baremetal, username string) error

+ func (bp *BrokerAuth) BookServer(pool *Pool, server *Baremetal) error

+ func (bp *BrokerAuth) Init(b *Broker, r *mux.Router)

+ func (bp *BrokerAuth) ReleaseServer(pool *Pool, server *Baremetal) error

+ func (bp *BrokerAuth) ServerResponse(name string, poolid string) *ServerResponse

+ type BrokerImplem interface

+ BookServer func(pool *Pool, server *Baremetal) error

+ Init func(b *Broker, r *mux.Router)

+ ReleaseServer func(pool *Pool, server *Baremetal) error

+ ServerResponse func(serverId string, poolid string) *ServerResponse

+ type BrokerProxy struct

+ Broker *Broker

+ func (bp *BrokerProxy) BookServer(pool *Pool, server *Baremetal) error

+ func (bp *BrokerProxy) Init(b *Broker, r *mux.Router)

+ func (bp *BrokerProxy) ReleaseServer(pool *Pool, server *Baremetal) error

+ func (bp *BrokerProxy) ServerResponse(name string, poolid string) *ServerResponse

+ type Member struct

+ ODataId string

+ type PoolLimit struct

+ Current int

+ Label string

+ Max int

+ Value string

+ func InitializeLimits(limits []brokerv1.PoolLimit) []PoolLimit

+ type PoolRequest struct

+ Id string

+ LabelSelector map[string]string

+ MaxServers int

+ type RedfishClient struct

+ func (c *RedfishClient) DoRequest(method string, path string, body io.Reader) (*http.Response, error)

+ type RedfishCollection struct

+ Members []Member

+ Name string

+ type User struct

+ CurrentServers int

+ Limits []PoolLimit

+ MaxServers int

+ Password string

+ Username string

v0.1.9

Nov 25, 2022

Changes in this version

type Baremetal

+ RootDeviceHints *bmh.RootDeviceHints

type ServerResponse

+ RootDeviceHints *bmh.RootDeviceHints

v0.1.8

Nov 25, 2022

v0.1.7

Nov 4, 2022

v0.1.6

Oct 11, 2022

v0.1.5

Oct 4, 2022

Changes in this version

+ func Sign(challenge string, logger logr.Logger) (result string, err error)

+ func Verify(challenge string, signature string, logger logr.Logger) (err error)

+ func VerifySignature(w http.ResponseWriter, r *http.Request, logger logr.Logger)

+ type ChallengeRequest struct

+ Challenge string

+ type ChallengeResponse struct

+ Challenge string

+ SignedChallenge string

+ type ErrorCode int

+ const CHECK_CERTIFICATE_ERROR

+ const NO_ERROR

+ const OTHER_ERROR

+ type ErrorResponseNetdef struct

+ Code ErrorCode

+ Message string

+ type SignatureRequest struct

+ Challenge string

+ Signature string

+ type SignatureResponse struct

+ SignatureVerified string

v0.1.4

Sep 8, 2022

Changes in this version

+ func AddAnnotation(baremetalId string, namespace string, poolId string, serverId string, ...) error

+ func BaremetalFound(name string) bool

+ func CreateNewBaremetal(bm Baremetal)

+ func CreateNewPool(pool Pool)

+ func CreateNewServer(poolId string, serverId string, baremetalName string, schema string)

+ func DeleteBaremetal(name string)

+ func DeletePool(poolId string, logger logr.Logger)

+ func DeleteServer(serverId string, poolId string)

+ func GetBrokerClient(kubeconfig *rest.Config) (*rest.RESTClient, error)

+ func GetK8SClient(kubeconfig *rest.Config) (*kubernetes.Clientset, error)

+ func HandleBrokerApiRequests(setupLog logr.Logger)

+ func InitBrokerData(setupLog logr.Logger) error

+ func IsBrokerDataEmpty() bool

+ func PoolFound(name string) bool

+ func ServerFound(name string, poolid string) bool

+ func UpdateBaremetal(bm Baremetal)

+ func UpdatePoolValues(name string, poolValues Pool)

+ func ValidateBaremetalDataRequest(baremetalValues Baremetal) error

+ func ValidatePoolDataRequest(poolValues Pool) error

+ func ValidateServerDataRequest(serverValues ServerRequest) error

+ func VerifyPoolAuthent(username string, password string) bool

+ type AuthRequest struct

+ Password string

+ UserName string

+ type Baremetal struct

+ DeviceName string

+ DisableCertificateVerification bool

+ Id string

+ K8sAnnotations map[string]string

+ K8sLabels map[string]string

+ MacAddress string

+ Password string

+ Url string

+ Username string

+ func GetBaremetal(name string) *Baremetal

+ func RetrieveAllBaremetals() []Baremetal

+ type BrokerData struct

+ Baremetals map[string]Baremetal

+ Pools map[string]Pool

+ var BROKERDATA BrokerData = BrokerData{ ... }

+ var Mutex sync.Mutex

+ type ErrorResponse struct

+ Message string

+ type PatchSpec struct

+ Op string

+ Path string

+ Value string

+ type Pool struct

+ Id string

+ LabelSelector map[string]string

+ MaxServers int

+ Password string

+ Servers map[string]ServerData

+ Username string

+ type PoolResponse struct

+ Id string

+ LabelSelector map[string]string

+ MaxServers int

+ Password string

+ Username string

+ func GetPool(poolId string) *PoolResponse

+ func RetrieveAllPools() []PoolResponse

+ type ServerData struct

+ Baremetal string

+ Id string

+ Schema string

+ type ServerRequest struct

+ Id string

+ Schema string

+ type ServerResponse struct

+ Baremetal string

+ DeviceName string

+ DisableCertificateVerification bool

+ Id string

+ K8sAnnotations map[string]string

+ K8sLabels map[string]string

+ MacAddress string

+ Url string

+ func RetrieveAllServers(poolId string) []ServerResponse

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL