rpc

package
v0.0.0-...-8d2fcc7 Latest Latest
Warning

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

 Go to latest Published: Mar 2, 2023 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Aggregator 

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

Aggregator struct helps to register service

func GetAggregator 

func GetAggregator() *Aggregator

GetAggregator intializes all the required connection functions for the aggregation execution

func (*Aggregator) AddAggregationSource 

func (a *Aggregator) AddAggregationSource(ctx context.Context, req *aggregatorproto.AggregatorRequest) (
	*aggregatorproto.AggregatorResponse, error)

AddAggregationSource function is for handling the RPC communication for AddAggregationSource

func (*Aggregator) AddElementsToAggregate 

func (a *Aggregator) AddElementsToAggregate(ctx context.Context, req *aggregatorproto.AggregatorRequest) (
	*aggregatorproto.AggregatorResponse, error)

AddElementsToAggregate defines the operations which handles the RPC request response for the AddElementsToAggregate service of aggregation micro service. The functionality retrives the request and return backs the response to RPC according to the protoc file defined in the util-lib package. The function also checks for the session time out of the token which is present in the request.

func (*Aggregator) CreateAggregate 

func (a *Aggregator) CreateAggregate(ctx context.Context, req *aggregatorproto.AggregatorRequest) (
	*aggregatorproto.AggregatorResponse, error)

CreateAggregate defines the operations which handles the RPC request response for the CreateAggregate service of aggregation micro service. The functionality retrives the request and return backs the response to RPC according to the protoc file defined in the util-lib package. The function also checks for the session time out of the token which is present in the request.

func (*Aggregator) DeleteAggregate 

func (a *Aggregator) DeleteAggregate(ctx context.Context, req *aggregatorproto.AggregatorRequest) (
	*aggregatorproto.AggregatorResponse, error)

DeleteAggregate defines the operations which handles the RPC request response for the DeleteAggregate service of aggregation micro service. The functionality retrives the request and return backs the response to RPC according to the protoc file defined in the util-lib package. The function also checks for the session time out of the token which is present in the request.

func (*Aggregator) DeleteAggregationSource 

func (a *Aggregator) DeleteAggregationSource(ctx context.Context, req *aggregatorproto.AggregatorRequest) (
	*aggregatorproto.AggregatorResponse, error)

DeleteAggregationSource defines the operations which handles the RPC request response for the UpdateAggregationSource service of aggregation micro service. The functionality retrives the request and return backs the response to RPC according to the protoc file defined in the util-lib package. The function also checks for the session time out of the token which is present in the request.

func (*Aggregator) GetAggregate 

func (a *Aggregator) GetAggregate(ctx context.Context, req *aggregatorproto.AggregatorRequest) (
	*aggregatorproto.AggregatorResponse, error)

GetAggregate defines the operations which handles the RPC request response for the GetAggregate service of aggregation micro service. The functionality retrives the request and return backs the response to RPC according to the protoc file defined in the util-lib package. The function also checks for the session time out of the token which is present in the request.

func (*Aggregator) GetAggregationService 

func (a *Aggregator) GetAggregationService(ctx context.Context, req *aggregatorproto.AggregatorRequest) (
	*aggregatorproto.AggregatorResponse, error)

GetAggregationService is an rpc handler, it gets invoked during GET on AggregationService API (/redfis/v1/AggregationService/)

func (*Aggregator) GetAggregationSource 

func (a *Aggregator) GetAggregationSource(ctx context.Context, req *aggregatorproto.AggregatorRequest) (
	*aggregatorproto.AggregatorResponse, error)

GetAggregationSource defines the operations which handles the RPC request response for the GetAggregationSource service of aggregation micro service. The functionality retrives the request and return backs the response to RPC according to the protoc file defined in the util-lib package. The function also checks for the session time out of the token which is present in the request.

func (*Aggregator) GetAllAggregates 

func (a *Aggregator) GetAllAggregates(ctx context.Context, req *aggregatorproto.AggregatorRequest) (
	*aggregatorproto.AggregatorResponse, error)

GetAllAggregates defines the operations which handles the RPC request response for the GetAllAggregates service of aggregation micro service. The functionality retrives the request and return backs the response to RPC according to the protoc file defined in the util-lib package. The function also checks for the session time out of the token which is present in the request.

func (*Aggregator) GetAllAggregationSource 

func (a *Aggregator) GetAllAggregationSource(ctx context.Context, req *aggregatorproto.AggregatorRequest) (
	*aggregatorproto.AggregatorResponse, error)

GetAllAggregationSource defines the operations which handles the RPC request response for the GetAllAggregationSource service of aggregation micro service. The functionality retrives the request and return backs the response to RPC according to the protoc file defined in the util-lib package. The function also checks for the session time out of the token which is present in the request.

func (*Aggregator) GetAllConnectionMethods 

func (a *Aggregator) GetAllConnectionMethods(ctx context.Context, req *aggregatorproto.AggregatorRequest) (
	*aggregatorproto.AggregatorResponse, error)

GetAllConnectionMethods defines the operations which handles the RPC request response for the GetAllConnectionMethods service of systems micro service. The functionality retrives the request and return backs the response to RPC according to the protoc file defined in the lib-utilities package. The function also checks for the session time out of the token which is present in the request.

func (*Aggregator) GetConnectionMethod 

func (a *Aggregator) GetConnectionMethod(ctx context.Context, req *aggregatorproto.AggregatorRequest) (
	*aggregatorproto.AggregatorResponse, error)

GetConnectionMethod defines the operations which handles the RPC request response for the GetConnectionMethod service of systems micro service. The functionality retrives the request and return backs the response to RPC according to the protoc file defined in the lib-utilities package. The function also checks for the session time out of the token which is present in the request.

func (*Aggregator) GetResetActionInfoService 

func (a *Aggregator) GetResetActionInfoService(ctx context.Context, req *aggregatorproto.AggregatorRequest) (
	*aggregatorproto.AggregatorResponse, error)

GetResetActionInfoService is an rpc handler, it gets invoked during GET on AggregationService API (/redfis/v1/AggregationService/)

func (*Aggregator) GetSetDefaultBootOrderActionInfo 

func (a *Aggregator) GetSetDefaultBootOrderActionInfo(ctx context.Context, req *aggregatorproto.AggregatorRequest) (
	*aggregatorproto.AggregatorResponse, error)

GetSetDefaultBootOrderActionInfo is an rpc handler, it gets invoked during GET on AggregationService API (/redfis/v1/AggregationService/)

func (*Aggregator) RediscoverSystemInventory 

func (a *Aggregator) RediscoverSystemInventory(ctx context.Context, req *aggregatorproto.RediscoverSystemInventoryRequest) (
	*aggregatorproto.RediscoverSystemInventoryResponse, error)

RediscoverSystemInventory defines the operations which handles the RPC request response for the RediscoverSystemInventory service of aggregator micro service. The functionality retrives the request and return backs the response to RPC according to the protoc file defined in the lib-utilities package.

func (*Aggregator) RemoveElementsFromAggregate 

func (a *Aggregator) RemoveElementsFromAggregate(ctx context.Context, req *aggregatorproto.AggregatorRequest) (
	*aggregatorproto.AggregatorResponse, error)

RemoveElementsFromAggregate defines the operations which handles the RPC request response for the RemoveElementsFromAggregate service of aggregation micro service. The functionality retrives the request and return backs the response to RPC according to the protoc file defined in the util-lib package. The function also checks for the session time out of the token which is present in the request.

func (*Aggregator) Reset 

func (a *Aggregator) Reset(ctx context.Context, req *aggregatorproto.AggregatorRequest) (
	*aggregatorproto.AggregatorResponse, error)

Reset function is for handling the RPC communication for Reset Action

func (*Aggregator) ResetElementsOfAggregate 

func (a *Aggregator) ResetElementsOfAggregate(ctx context.Context, req *aggregatorproto.AggregatorRequest) (
	*aggregatorproto.AggregatorResponse, error)

ResetElementsOfAggregate defines the operations which handles the RPC request response for the ResetElementsOfAggregate service of aggregation micro service. The functionality retrives the request and return backs the response to RPC according to the protoc file defined in the util-lib package. The function also checks for the session time out of the token which is present in the request.

func (*Aggregator) SendStartUpData 

func (a *Aggregator) SendStartUpData(ctx context.Context, req *aggregatorproto.SendStartUpDataRequest) (
	resp *aggregatorproto.SendStartUpDataResponse, err error)

SendStartUpData defines the operations which handles the RPC request response for the SendStartUpData call to aggregator micro service. The functionality retrives the request and return backs the response to RPC according to the protoc file defined in the lib-utilities package. The function is used for sending plugin start up data to the plugin which has restarted.

func (*Aggregator) SetDefaultBootOrder 

func (a *Aggregator) SetDefaultBootOrder(ctx context.Context, req *aggregatorproto.AggregatorRequest) (
	*aggregatorproto.AggregatorResponse, error)

SetDefaultBootOrder defines the operations which handles the RPC request response for the create account service of aggregator micro service. The functionality retrives the request and return backs the response to RPC according to the protoc file defined in the lib-utilities package. The function also checks for the session time out of the token which is present in the request.

func (*Aggregator) SetDefaultBootOrderElementsOfAggregate 

func (a *Aggregator) SetDefaultBootOrderElementsOfAggregate(ctx context.Context, req *aggregatorproto.AggregatorRequest) (
	*aggregatorproto.AggregatorResponse, error)

SetDefaultBootOrderElementsOfAggregate defines the operations which handles the RPC request response for the SetDefaultBootOrderElementsOfAggregate service of aggregation micro service. The functionality retrives the request and return backs the response to RPC according to the protoc file defined in the util-lib package. The function also checks for the session time out of the token which is present in the request.

func (*Aggregator) UpdateAggregationSource 

func (a *Aggregator) UpdateAggregationSource(ctx context.Context, req *aggregatorproto.AggregatorRequest) (
	*aggregatorproto.AggregatorResponse, error)

UpdateAggregationSource defines the operations which handles the RPC request response for the UpdateAggregationSource service of aggregation micro service. The functionality retrives the request and return backs the response to RPC according to the protoc file defined in the util-lib package. The function also checks for the session time out of the token which is present in the request.

func (*Aggregator) UpdateSystemState 

func (a *Aggregator) UpdateSystemState(ctx context.Context, req *aggregatorproto.UpdateSystemStateRequest) (
	*aggregatorproto.UpdateSystemStateResponse, error)

UpdateSystemState defines the operations which handles the RPC request response for the UpdateSystemState call to aggregator micro service. The functionality retrives the request and return backs the response to RPC according to the protoc file defined in the lib-utilities package.

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.