plugin_events

type EventMessage struct {

	// id is the unique event identifier (UUID)
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// topic is the logical topic name
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// origin is the node/plugin that created the event
	Origin string `protobuf:"bytes,3,opt,name=origin,proto3" json:"origin,omitempty"`
	// direction indicates the original routing direction (informational)
	// When received via Subscribe, events are always effectively "local"
	Direction int32 `protobuf:"varint,4,opt,name=direction,proto3" json:"direction,omitempty"`
	// payload is the JSON-encoded event payload
	Payload []byte `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type PluginEventServiceClient interface {
	// Publish sends an event to the host's event bus.
	// The event will be routed based on the direction:
	// - DirLocal (0): stays on local bus only
	// - DirUp (1): forwarded from edge to control
	// - DirDown (2): forwarded from control to edge(s)
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)
	// Subscribe creates a subscription and streams events back to the plugin.
	// The stream remains open until the client disconnects or calls Unsubscribe.
	// Events matching the subscription criteria are sent as they occur.
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[EventMessage], error)
	// Unsubscribe removes a subscription by ID.
	// This is optional - subscriptions are automatically cleaned up when the
	// Subscribe stream is closed.
	Unsubscribe(ctx context.Context, in *UnsubscribeRequest, opts ...grpc.CallOption) (*UnsubscribeResponse, error)
}

type PluginEventServiceServer interface {
	// Publish sends an event to the host's event bus.
	// The event will be routed based on the direction:
	// - DirLocal (0): stays on local bus only
	// - DirUp (1): forwarded from edge to control
	// - DirDown (2): forwarded from control to edge(s)
	Publish(context.Context, *PublishRequest) (*PublishResponse, error)
	// Subscribe creates a subscription and streams events back to the plugin.
	// The stream remains open until the client disconnects or calls Unsubscribe.
	// Events matching the subscription criteria are sent as they occur.
	Subscribe(*SubscribeRequest, grpc.ServerStreamingServer[EventMessage]) error
	// Unsubscribe removes a subscription by ID.
	// This is optional - subscriptions are automatically cleaned up when the
	// Subscribe stream is closed.
	Unsubscribe(context.Context, *UnsubscribeRequest) (*UnsubscribeResponse, error)
	// contains filtered or unexported methods
}

type PluginEventService_SubscribeClient = grpc.ServerStreamingClient[EventMessage]

type PluginEventService_SubscribeServer = grpc.ServerStreamingServer[EventMessage]

type PublishRequest struct {

	// topic is the logical topic name (e.g., "cache.hit", "config.reload")
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// payload is the JSON-encoded event payload
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// direction controls event routing:
	// 0 = DirLocal (stays on local bus)
	// 1 = DirUp (edge to control)
	// 2 = DirDown (control to edge)
	Direction int32 `protobuf:"varint,3,opt,name=direction,proto3" json:"direction,omitempty"`
	// plugin_id identifies the plugin publishing the event (for origin tracking)
	PluginId string `protobuf:"bytes,4,opt,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"`
	// contains filtered or unexported fields
}

type PublishResponse struct {

	// success indicates whether the event was published successfully
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// error_message contains the error description if success is false
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// event_id is the generated UUID for the published event
	EventId string `protobuf:"bytes,3,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	// contains filtered or unexported fields
}

type SubscribeRequest struct {

	// topic is the topic to subscribe to. If empty and subscribe_all is false,
	// no events will be received.
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// subscribe_all subscribes to all events regardless of topic
	SubscribeAll bool `protobuf:"varint,2,opt,name=subscribe_all,json=subscribeAll,proto3" json:"subscribe_all,omitempty"`
	// plugin_id identifies the subscribing plugin (for tracking/logging)
	PluginId string `protobuf:"bytes,3,opt,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedPluginEventServiceServer struct{}

type UnsafePluginEventServiceServer interface {
	// contains filtered or unexported methods
}

type UnsubscribeRequest struct {

	// subscription_id is the ID returned from Subscribe (client-generated)
	SubscriptionId string `protobuf:"bytes,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	// contains filtered or unexported fields
}

type UnsubscribeResponse struct {

	// success indicates whether the unsubscribe was successful
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// error_message contains the error description if success is false
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}