package io.axoniq.axonserver.grpc.admin

optional EventProcessorIdentifier identifier = 1
the identifier of the event processor
string mode = 2
the event processor mode (subscribing, tracking, pooled)
bool isStreaming = 3
true if the event processor is streaming, false otherwise
repeated EventProcessorInstance client_instance = 4
client instances that subscribed the event processor
string load_balancing_strategy_name = 5
current load balancing strategy name for the event processor

Used as request type in: EventProcessorAdminService.MergeEventProcessor, EventProcessorAdminService.PauseEventProcessor, EventProcessorAdminService.SplitEventProcessor, EventProcessorAdminService.StartEventProcessor

Used as field type in: EventProcessor, LoadBalanceRequest, MoveSegment

string processor_name = 1
the name of the processor
string token_store_identifier = 2
the identifier of the token store this event processor is using
string context_name = 3
optional parameter to pass in the context name to indicate where the processor is located

Used in: EventProcessor

string client_id = 1
the client identifier
bool isRunning = 2
true if the client instance of the event processor is running, false otherwise
int32 max_capacity = 3
the max number of segments that this client can claim
repeated EventProcessorSegment claimed_segment = 4
status of all segments claimed by the client

Used in: EventProcessorInstance

int32 id = 1
the identifier of the segment
int32 one_part_of = 2
the fractional unit representing the size of the segment
string claimed_by = 3
the id of the client that claimed the segment
bool is_caughtUp = 4
true if the segment has ever reached the head of the stream since it was started, false otherwise
bool is_replaying = 5
true if the segment is replaying, false otherwise
int64 token_position = 6
the approximate position of the token
bool is_in_error = 7
true if the segment is in an error loop, false otherwise
string error = 8
the error description, if the segment is in error

Used as request type in: EventProcessorAdminService.LoadBalanceProcessor, EventProcessorAdminService.SetAutoLoadBalanceStrategy

optional EventProcessorIdentifier processor = 1
string strategy = 2

Used in: ClientApplication

string request = 1
repeated string responseTypes = 2

message ReplicationGroupContext

admin.proto:143

string replication_group_name = 1
string context_name = 2
map<string, string> meta_data = 3

Used in: CreateReplicationGroupRequest, ReplicationGroupOverview

string node_name = 1
string host = 2
int32 port = 3
Role role = 4
bool pendingDelete = 5

Used as response type in: ReplicationGroupAdminService.GetReplicationGroup, ReplicationGroupAdminService.GetReplicationGroups

Used as field type in: ContextOverview

string name = 1
repeated ReplicationGroupMember members = 2
int64 pendingSince = 3
bool changePending = 4
repeated string contexts = 5

Used in: AdminActionResult

SUCCESS = 0
The handler confirmed that the action was executed successfully
ACCEPTED = 1
The handler has accepted the result, no result will be returned

Used in: JoinReplicationGroup, ReplicationGroupMember

ROLE_PRIMARY = 0
ROLE_ACTIVE_BACKUP = 2
ROLE_PASSIVE_BACKUP = 3
ROLE_MESSAGING_ONLY = 4
ROLE_SECONDARY = 5
ROLE_ANALYTICS = 6

Used as request type in: AuthenticationService.AuthenticateToken

Used as response type in: ApplicationAdminService.CreateOrUpdateApplication, ApplicationAdminService.RefreshToken

string token = 1

Used in: UserOverview

string role = 1
string context = 2

Used in: CreateOrUpdateUserRequest

string role = 1
string context = 2

package io.axoniq.axonserver.grpc.admin

service ApplicationAdminService

rpc CreateOrUpdateApplication (ApplicationRequest, Token)

message ApplicationRequest

string applicationName = 1

string description = 2

string token = 3

repeated ApplicationContextRole rolesPerContext = 4

map<string, string> meta_data = 5

rpc DeleteApplication (ApplicationId, stream google.protobuf.Empty)

rpc GetApplication (ApplicationId, ApplicationOverview)

rpc GetApplications (google.protobuf.Empty, stream ApplicationOverview)

rpc GetConnectedApplicationsByContext (ContextId, ConnectedApplicationOverview)

message ContextId

string contextName = 1

message ConnectedApplicationOverview

repeated string nodes = 1

repeated ClientApplication applications = 2

rpc RefreshToken (ApplicationId, Token)

service AuthenticationService

rpc AuthenticateToken (Token, ApplicationRoles)

message ApplicationRoles

string applicationName = 1

repeated ContextRole applicationRole = 2

rpc AuthenticateUser (AuthenticateUserRequest, UserRoles)

message AuthenticateUserRequest

string userName = 1

string password = 2

message UserRoles

string userName = 1

repeated ContextRole userRoles = 3

service ContextAdminService

rpc CreateContext (CreateContextRequest, stream google.protobuf.Empty)

message CreateContextRequest

string name = 1

string replicationGroupName = 2

map<string, string> meta_data = 3

bool dcbContext = 4

rpc DeleteContext (DeleteContextRequest, stream google.protobuf.Empty)

message DeleteContextRequest

string name = 1

bool preserveEventStore = 2

rpc GetContext (GetContextRequest, ContextOverview)

message GetContextRequest

string name = 1

rpc GetContexts (google.protobuf.Empty, stream ContextOverview)

rpc SubscribeContextUpdates (google.protobuf.Empty, stream ContextUpdate)

message ContextUpdate

string context = 1

ContextUpdateType type = 2

rpc UpdateContextProperties (UpdateContextPropertiesRequest, stream google.protobuf.Empty)

message UpdateContextPropertiesRequest

string name = 1

map<string, string> meta_data = 3

service EventProcessorAdminService

rpc GetAllEventProcessors (google.protobuf.Empty, stream EventProcessor)

rpc GetBalancingStrategies (google.protobuf.Empty, stream LoadBalancingStrategy)

message LoadBalancingStrategy

string strategy = 1

string label = 2

rpc GetEventProcessorsByComponent (Component, stream EventProcessor)

rpc LoadBalanceProcessor (LoadBalanceRequest, stream google.protobuf.Empty)

rpc MergeEventProcessor (EventProcessorIdentifier, AdminActionResult)

rpc MoveEventProcessorSegment (MoveSegment, AdminActionResult)

message MoveSegment

optional EventProcessorIdentifier event_processor = 1

int32 segment = 2

string target_client_id = 3

rpc PauseEventProcessor (EventProcessorIdentifier, AdminActionResult)

rpc SetAutoLoadBalanceStrategy (LoadBalanceRequest, stream google.protobuf.Empty)

rpc SplitEventProcessor (EventProcessorIdentifier, AdminActionResult)

rpc StartEventProcessor (EventProcessorIdentifier, AdminActionResult)

service ReplicationGroupAdminService

rpc AddNodeToReplicationGroup (JoinReplicationGroup, stream google.protobuf.Empty)

message JoinReplicationGroup

string replication_group_name = 1

string node_name = 2

Role role = 3

rpc CreateReplicationGroup (CreateReplicationGroupRequest, stream google.protobuf.Empty)

message CreateReplicationGroupRequest