GRPC API

GRPC API

Event processor administration

Service name: EventProcessorAdminService

Operation	Purpose	Method
List all even processor	Provide a list of all event processors defined by the connected applications.	rpc GetAllEventProcessors(google.protobuf.Empty) returns (stream EventProcessor)
List event processo by component	Provide a list of all event processors defined by the specified component.	rpc GetEventProcessorsByComponent(Component) returns (stream EventProcessor)
Start event processor	Start a distributed event processor, propagating the start request to all EP instances connected to AS *	rpc StartEventProcessor(EventProcessorIdentifier) returns (AdminActionResult)
Pause event processor	Pause a distributed event processor, propagating the pause request to all EP instances connected to AS *	rpc PauseEventProcessor(EventProcessorIdentifier) returns (AdminActionResult)
Split event processor segment	Split the largest known segment of the distributed event processor into two segments.	rpc SplitEventProcessor(EventProcessorIdentifier) returns (AdminActionResult)
Merge event processor segments	Merge the smallest known two segments of the distributed event processor into one. **	rpc MergeEventProcessor(EventProcessorIdentifier) returns (AdminActionResult)
List load balance strategies	Provide a list of all load balancing strategies.	GetBalancingStrategies(google.protobuf.Empty) returns (stream LoadBalancingStrategy)
Load balance event processor	Balance the load across several instances of an event processor, accordingly to the selected strategy.	rpc LoadBalanceProcessor(LoadBalanceRequest) returns (stream google.protobuf.Empty)
Set auto load balance strategy	Define the load balancing strategy to use for automatic load balancing.	SetAutoLoadBalanceStrategy(LoadBalanceRequest) returns (stream google.protobuf.Empty)

* Clients need to be already running and connected to AS before the operation is executed. ** It may not work if the two smallest segments are not claimed by applications connected to AS.

Context administration

Service name: ContextAdminService

Operation	Purpose	Method
Context details	Provide all details about a context.	rpc GetContext(GetContextRequest) returns (ContextOverview)
List contexts	Provide a stream of all contexts with details.	rpc GetContexts(google.protobuf.Empty) returns (stream ContextOverview)
Create context	Create a new context.	rpc CreateContext(CreateContextRequest) returns (stream google.protobuf.Empty)
Delete context	Delete an existing context.	rpc DeleteContext(DeleteContextRequest) returns (stream google.protobuf.Empty)
Update context properties	Update specified properties of a context.	rpc UpdateContextProperties(UpdateContextPropertiesRequest) returns (stream google.protobuf.Empty)
Subscribe to contexts' updates	Provide a stream of all changes in cluster configuration related to context (creations, deletions, updates).	rpc SubscribeContextUpdates(google.protobuf.Empty) returns (stream ContextUpdate)

Replication group administration

Service name: ReplicationGroupAdminService

Operation	Purpose	Method
Replication group details	Provide all details about a replication group.	rpc GetReplicationGroup(GetReplicationGroupRequest) returns (ReplicationGroupOverview)
List replication groups	Provide a stream of all replication groups with details.	pc GetReplicationGroups(google.protobuf.Empty) returns (stream ReplicationGroupOverview)
List nodes	Provide a stream of all nodes in the cluster with details.	rpc GetNodes (google.protobuf.Empty) returns (stream NodeOverview)
Create replication group	Create a new replication group.	rpc CreateReplicationGroup(CreateReplicationGroupRequest) returns (stream google.protobuf.Empty)
Delete replication group	Delete an existing replication group.	rpc DeleteReplicationGroup(DeleteReplicationGroupRequest) returns (stream google.protobuf.Empty)
Add node	Add a node to a replication group with the specified role.	rpc AddNodeToReplicationGroup(JoinReplicationGroup) returns (stream google.protobuf.Empty)
Remove node	Remove a node from a replication group.	rpc RemoveNodeFromReplicationGroup(LeaveReplicationGroup) returns (stream google.protobuf.Empty)