v1

type Event struct {

	// Unique event identifier (generated by the system).
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Type of event that occurred.
	Type EventType `protobuf:"varint,2,opt,name=type,proto3,enum=agntcy.dir.events.v1.EventType" json:"type,omitempty"`
	// When the event occurred.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Resource identifier (CID for records, sync_id for syncs, etc.).
	ResourceId string `protobuf:"bytes,4,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// Optional labels associated with the record (for record events).
	Labels []string `protobuf:"bytes,5,rep,name=labels,proto3" json:"labels,omitempty"`
	// Optional metadata for additional context.
	// Used for flexible event-specific data that doesn't fit standard fields.
	Metadata map[string]string `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

type EventServiceClient interface {
	// Listen establishes a streaming connection to receive events.
	// Events are only delivered while the stream is active.
	// On disconnect, missed events are not recoverable.
	Listen(ctx context.Context, in *ListenRequest, opts ...grpc.CallOption) (EventService_ListenClient, error)
}

type EventServiceServer interface {
	// Listen establishes a streaming connection to receive events.
	// Events are only delivered while the stream is active.
	// On disconnect, missed events are not recoverable.
	Listen(*ListenRequest, EventService_ListenServer) error
}

type EventService_ListenClient interface {
	Recv() (*ListenResponse, error)
	grpc.ClientStream
}

type EventService_ListenServer interface {
	Send(*ListenResponse) error
	grpc.ServerStream
}

type EventType int32

type ListenRequest struct {

	// Event types to subscribe to.
	// If empty, subscribes to all event types.
	EventTypes []EventType `` /* 135-byte string literal not displayed */
	// Optional label filters (e.g., "/skills/AI", "/domains/research").
	// Only events for records matching these labels are delivered.
	// Uses substring matching.
	LabelFilters []string `protobuf:"bytes,2,rep,name=label_filters,json=labelFilters,proto3" json:"label_filters,omitempty"`
	// Optional CID filters.
	// Only events for specific CIDs are delivered.
	CidFilters []string `protobuf:"bytes,3,rep,name=cid_filters,json=cidFilters,proto3" json:"cid_filters,omitempty"`
	// contains filtered or unexported fields
}

type ListenResponse struct {

	// The event that occurred.
	Event *Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedEventServiceServer struct{}

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