rpc

package

v0.0.0-...-81c02da Latest Latest Go to latest Published: Sep 1, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ODIM-Project/ODIM

Documentation ¶

Overview ¶

Package rpc have the functionality of rpc caller functions

Index ¶

Variables
type Events
- func GetPluginContactInitializer() *Events

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	//JSONMarshal ...
	JSONMarshal = json.Marshal
)

Functions ¶

This section is empty.

Types ¶

type Events ¶

type Events struct {
	Connector *events.ExternalInterfaces
}

Events struct helps to register service

func GetPluginContactInitializer ¶

func GetPluginContactInitializer() *Events

GetPluginContactInitializer initializes all the required connection functions for the events execution

func (*Events) CreateDefaultEventSubscription ¶

func (e *Events) CreateDefaultEventSubscription(ctx context.Context, req *eventsproto.DefaultEventSubRequest) (*eventsproto.DefaultEventSubResponse, error)

CreateDefaultEventSubscription defines the operations which handles the RPC request response after computer system restarts ,This will triggered from aggregation service whenever a computer system is added

func (*Events) CreateEventSubscription ¶

func (e *Events) CreateEventSubscription(ctx context.Context, req *eventsproto.EventSubRequest) (*eventsproto.EventSubResponse, error)

CreateEventSubscription defines the operations which handles the RPC request response for the Create event subscription RPC call to events micro service. The functionality is to create the subscription with Resource provided in origin resources.

func (*Events) DeleteAggregateSubscriptionsRPC ¶

func (e *Events) DeleteAggregateSubscriptionsRPC(ctx context.Context, req *eventsproto.EventUpdateRequest) (*eventsproto.SubscribeEMBResponse, error)

DeleteAggregateSubscriptionsRPC defines the operations which handles the RPC request response it remove subscription details

func (*Events) DeleteEventSubscription ¶

func (e *Events) DeleteEventSubscription(ctx context.Context, req *eventsproto.EventRequest) (*eventsproto.EventSubResponse, error)

DeleteEventSubscription defines the operations which handles the RPC request response for the delete event subscription RPC call to events micro service. The functionality is to delete the subscription details.

func (*Events) GetEventService ¶

func (e *Events) GetEventService(ctx context.Context, req *eventsproto.EventSubRequest) (*eventsproto.EventSubResponse, error)

GetEventService handles the RPC to get EventService details.

func (*Events) GetEventSubscription ¶

func (e *Events) GetEventSubscription(ctx context.Context, req *eventsproto.EventRequest) (*eventsproto.EventSubResponse, error)

GetEventSubscription defines the operations which handles the RPC request response for the get event subscription RPC call to events micro service. The functionality is to get the subscription details.

func (*Events) GetEventSubscriptionsCollection ¶

func (e *Events) GetEventSubscriptionsCollection(ctx context.Context, req *eventsproto.EventRequest) (*eventsproto.EventSubResponse, error)

GetEventSubscriptionsCollection defines the operations which handles the RPC request response for the get event subscriptions collection RPC call to events micro service. The functionality is to get the collection of subscription details.

func (*Events) IsAggregateHaveSubscription ¶

func (e *Events) IsAggregateHaveSubscription(ctx context.Context, req *eventsproto.EventUpdateRequest) (*eventsproto.SubscribeEMBResponse, error)

IsAggregateHaveSubscription defines the operations which handles the RPC request response

func (*Events) RemoveEventSubscriptionsRPC ¶

func (e *Events) RemoveEventSubscriptionsRPC(ctx context.Context, req *eventsproto.EventUpdateRequest) (*eventsproto.SubscribeEMBResponse, error)

RemoveEventSubscriptionsRPC defines the operations which handles the RPC request response it subscribe to the given event message bus queues

func (*Events) SubmitTestEvent ¶

func (e *Events) SubmitTestEvent(ctx context.Context, req *eventsproto.EventSubRequest) (*eventsproto.EventSubResponse, error)

SubmitTestEvent defines the operations which handles the RPC request response for the SubmitTestEvent RPC call to events micro service. The functionality is to submit a test event.

func (*Events) SubscribeEMB ¶

func (e *Events) SubscribeEMB(ctx context.Context, req *eventsproto.SubscribeEMBRequest) (*eventsproto.SubscribeEMBResponse, error)

SubscribeEMB defines the operations which handles the RPC request response it subscribe to the given event message bus queues

func (*Events) UpdateEventSubscriptionsRPC ¶

func (e *Events) UpdateEventSubscriptionsRPC(ctx context.Context, req *eventsproto.EventUpdateRequest) (*eventsproto.SubscribeEMBResponse, error)

UpdateEventSubscriptionsRPC defines the operations which handles the RPC request response it subscribe to the given event message bus queues

func (*Events) UpdateSubscriptionLocationRPC ¶

func (e *Events) UpdateSubscriptionLocationRPC(ctx context.Context, in *eventsproto.UpdateSubscriptionLocation) (*eventsproto.SubscribeEMBResponse, error)

UpdateSubscriptionLocationRPC defines the operations which handles the RPC request response it updates subscription location

Source Files ¶

View all Source files

events.go

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