v1

type CreatePublicationResponse struct {

	// Unique identifier of the publication operation.
	PublicationId string `protobuf:"bytes,1,opt,name=publication_id,json=publicationId,proto3" json:"publication_id,omitempty"`
	// contains filtered or unexported fields
}

type GetPublicationRequest struct {

	// Unique identifier of the publication operation to query.
	PublicationId string `protobuf:"bytes,1,opt,name=publication_id,json=publicationId,proto3" json:"publication_id,omitempty"`
	// contains filtered or unexported fields
}

type GetPublicationResponse struct {

	// Unique identifier of the publication operation.
	PublicationId string `protobuf:"bytes,1,opt,name=publication_id,json=publicationId,proto3" json:"publication_id,omitempty"`
	// Current status of the publication operation.
	Status PublicationStatus `protobuf:"varint,2,opt,name=status,proto3,enum=agntcy.dir.routing.v1.PublicationStatus" json:"status,omitempty"`
	// Timestamp when the publication operation was created in the RFC3339 format.
	// Specs: https://www.rfc-editor.org/rfc/rfc3339.html
	CreatedTime string `protobuf:"bytes,3,opt,name=created_time,json=createdTime,proto3" json:"created_time,omitempty"`
	// Timestamp of the most recent status update for this publication in the RFC3339 format.
	LastUpdateTime string `protobuf:"bytes,4,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`
	// contains filtered or unexported fields
}

type ListPublicationsItem struct {

	// Unique identifier of the publication operation.
	PublicationId string `protobuf:"bytes,1,opt,name=publication_id,json=publicationId,proto3" json:"publication_id,omitempty"`
	// Current status of the publication operation.
	Status PublicationStatus `protobuf:"varint,2,opt,name=status,proto3,enum=agntcy.dir.routing.v1.PublicationStatus" json:"status,omitempty"`
	// Timestamp when the publication operation was created in the RFC3339 format.
	// Specs: https://www.rfc-editor.org/rfc/rfc3339.html
	CreatedTime string `protobuf:"bytes,3,opt,name=created_time,json=createdTime,proto3" json:"created_time,omitempty"`
	// Timestamp of the most recent status update for this publication in the RFC3339 format.
	LastUpdateTime string `protobuf:"bytes,4,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`
	// contains filtered or unexported fields
}

type ListPublicationsRequest struct {

	// Optional limit on the number of results to return.
	Limit *uint32 `protobuf:"varint,2,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// Optional offset for pagination of results.
	Offset *uint32 `protobuf:"varint,3,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

type ListRequest struct {

	// List of queries to match against the records.
	// If set, all queries must match for the record to be returned.
	Queries []*RecordQuery `protobuf:"bytes,1,rep,name=queries,proto3" json:"queries,omitempty"`
	// Limit the number of results returned.
	// If not set, it will return all records that this peer is providing.
	Limit *uint32 `protobuf:"varint,2,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

type ListResponse struct {

	// The record that matches the list queries.
	RecordRef *v1.RecordRef `protobuf:"bytes,1,opt,name=record_ref,json=recordRef,proto3" json:"record_ref,omitempty"`
	// Labels associated with this record (skills, domains, modules)
	// Derived from the record content for CLI display purposes
	Labels []string `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

type Peer struct {

	// ID of a given peer, typically described by a protocol.
	// For example:
	//   - SPIFFE:   "spiffe://example.org/service/foo"
	//   - JWT:      "jwt:sub=alice,iss=https://issuer.example.com"
	//   - Tor:      "onion:abcdefghijklmno.onion"
	//   - DID:      "did:example:123456789abcdefghi"
	//   - IPFS:     "ipfs:QmYwAPJzv5CZsnAzt8auVZRn2E6sD1c4x8pN5o6d5cW4D5"
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Multiaddrs for a given peer.
	// For example:
	// - "/ip4/127.0.0.1/tcp/4001"
	// - "/ip6/::1/tcp/4001"
	// - "/dns4/example.com/tcp/443/https"
	Addrs []string `protobuf:"bytes,2,rep,name=addrs,proto3" json:"addrs,omitempty"`
	// Additional metadata about the peer.
	Annotations map[string]string `` /* 149-byte string literal not displayed */
	// Used to signal the sender's connection capabilities to the peer.
	Connection PeerConnectionType `protobuf:"varint,4,opt,name=connection,proto3,enum=agntcy.dir.routing.v1.PeerConnectionType" json:"connection,omitempty"`
	// contains filtered or unexported fields
}

type PeerConnectionType int32

type PublicationServiceClient interface {
	// CreatePublication creates a new publication request that will be processed by the PublicationWorker.
	// The publication request can specify either a query, a list of specific CIDs, or all records to be announced to the DHT.
	CreatePublication(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*CreatePublicationResponse, error)
	// ListPublications returns a stream of all publication requests in the system.
	// This allows monitoring of pending, processing, and completed publication requests.
	ListPublications(ctx context.Context, in *ListPublicationsRequest, opts ...grpc.CallOption) (PublicationService_ListPublicationsClient, error)
	// GetPublication retrieves details of a specific publication request by its identifier.
	// This includes the current status and any associated metadata.
	GetPublication(ctx context.Context, in *GetPublicationRequest, opts ...grpc.CallOption) (*GetPublicationResponse, error)
}

type PublicationServiceServer interface {
	// CreatePublication creates a new publication request that will be processed by the PublicationWorker.
	// The publication request can specify either a query, a list of specific CIDs, or all records to be announced to the DHT.
	CreatePublication(context.Context, *PublishRequest) (*CreatePublicationResponse, error)
	// ListPublications returns a stream of all publication requests in the system.
	// This allows monitoring of pending, processing, and completed publication requests.
	ListPublications(*ListPublicationsRequest, PublicationService_ListPublicationsServer) error
	// GetPublication retrieves details of a specific publication request by its identifier.
	// This includes the current status and any associated metadata.
	GetPublication(context.Context, *GetPublicationRequest) (*GetPublicationResponse, error)
}

type PublicationService_ListPublicationsClient interface {
	Recv() (*ListPublicationsItem, error)
	grpc.ClientStream
}

type PublicationService_ListPublicationsServer interface {
	Send(*ListPublicationsItem) error
	grpc.ServerStream
}

type PublicationStatus int32

type PublishRequest struct {

	// Types that are valid to be assigned to Request:
	//
	//	*PublishRequest_RecordRefs
	//	*PublishRequest_Queries
	Request isPublishRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

type PublishRequest_Queries struct {
	// Queries to match against the records to be published.
	Queries *RecordQueries `protobuf:"bytes,2,opt,name=queries,proto3,oneof"`
}

type PublishRequest_RecordRefs struct {
	// References to the records to be published.
	RecordRefs *RecordRefs `protobuf:"bytes,1,opt,name=record_refs,json=recordRefs,proto3,oneof"`
}

type RecordQueries struct {
	Queries []*v11.RecordQuery `protobuf:"bytes,1,rep,name=queries,proto3" json:"queries,omitempty"`
	// contains filtered or unexported fields
}

type RecordQuery struct {

	// The type of the query to match against.
	Type RecordQueryType `protobuf:"varint,1,opt,name=type,proto3,enum=agntcy.dir.routing.v1.RecordQueryType" json:"type,omitempty"`
	// The query value to match against.
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type RecordQueryType int32

type RecordRefs struct {
	Refs []*v1.RecordRef `protobuf:"bytes,1,rep,name=refs,proto3" json:"refs,omitempty"`
	// contains filtered or unexported fields
}

type RoutingServiceClient interface {
	// Announce to the network that this peer is providing a given record.
	// This enables other peers to discover this record and retrieve it
	// from this peer. Listeners can use this event to perform custom operations,
	// for example by cloning the record.
	//
	// Items need to be periodically republished (eg. 24h) to the network
	// to avoid stale data. Republication should be done in the background.
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Stop serving this record to the network. If other peers try
	// to retrieve this record, the peer will refuse the request.
	Unpublish(ctx context.Context, in *UnpublishRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Search records based on the request across the network.
	// This will search the network for the record with the given parameters.
	//
	// It is possible that the records are stale or that they do not exist.
	// Some records may be provided by multiple peers.
	//
	// Results from the search can be used as an input
	// to Pull operation to retrieve the records.
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (RoutingService_SearchClient, error)
	// List all records that this peer is currently providing
	// that match the given parameters.
	// This operation does not interact with the network.
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (RoutingService_ListClient, error)
}

type RoutingServiceServer interface {
	// Announce to the network that this peer is providing a given record.
	// This enables other peers to discover this record and retrieve it
	// from this peer. Listeners can use this event to perform custom operations,
	// for example by cloning the record.
	//
	// Items need to be periodically republished (eg. 24h) to the network
	// to avoid stale data. Republication should be done in the background.
	Publish(context.Context, *PublishRequest) (*emptypb.Empty, error)
	// Stop serving this record to the network. If other peers try
	// to retrieve this record, the peer will refuse the request.
	Unpublish(context.Context, *UnpublishRequest) (*emptypb.Empty, error)
	// Search records based on the request across the network.
	// This will search the network for the record with the given parameters.
	//
	// It is possible that the records are stale or that they do not exist.
	// Some records may be provided by multiple peers.
	//
	// Results from the search can be used as an input
	// to Pull operation to retrieve the records.
	Search(*SearchRequest, RoutingService_SearchServer) error
	// List all records that this peer is currently providing
	// that match the given parameters.
	// This operation does not interact with the network.
	List(*ListRequest, RoutingService_ListServer) error
}

type RoutingService_ListClient interface {
	Recv() (*ListResponse, error)
	grpc.ClientStream
}

type RoutingService_ListServer interface {
	Send(*ListResponse) error
	grpc.ServerStream
}

type RoutingService_SearchClient interface {
	Recv() (*SearchResponse, error)
	grpc.ClientStream
}

type RoutingService_SearchServer interface {
	Send(*SearchResponse) error
	grpc.ServerStream
}

type SearchRequest struct {

	// List of queries to match against the records.
	Queries []*RecordQuery `protobuf:"bytes,1,rep,name=queries,proto3" json:"queries,omitempty"`
	// Minimal target query match score.
	// For example, if min_match_score=2, it will return records that match
	// at least two of the queries.
	// If not set, it will return records that match at least one query.
	MinMatchScore *uint32 `protobuf:"varint,2,opt,name=min_match_score,json=minMatchScore,proto3,oneof" json:"min_match_score,omitempty"`
	// Limit the number of results returned.
	// If not set, it will return all discovered records.
	// Note that this is a soft limit, as the search may return more results
	// than the limit if there are multiple peers providing the same record.
	Limit *uint32 `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

type SearchResponse struct {

	// The record that matches the search query.
	RecordRef *v1.RecordRef `protobuf:"bytes,1,opt,name=record_ref,json=recordRef,proto3" json:"record_ref,omitempty"`
	// The peer that provided the record.
	Peer *Peer `protobuf:"bytes,2,opt,name=peer,proto3" json:"peer,omitempty"`
	// The queries that were matched.
	MatchQueries []*RecordQuery `protobuf:"bytes,3,rep,name=match_queries,json=matchQueries,proto3" json:"match_queries,omitempty"`
	// The score of the search match.
	MatchScore uint32 `protobuf:"varint,4,opt,name=match_score,json=matchScore,proto3" json:"match_score,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedPublicationServiceServer struct{}

type UnimplementedRoutingServiceServer struct{}

type UnpublishRequest struct {

	// Types that are valid to be assigned to Request:
	//
	//	*UnpublishRequest_RecordRefs
	//	*UnpublishRequest_Queries
	Request isUnpublishRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

type UnpublishRequest_Queries struct {
	// Queries to match against the records to be unpublished.
	Queries *RecordQueries `protobuf:"bytes,2,opt,name=queries,proto3,oneof"`
}

type UnpublishRequest_RecordRefs struct {
	// References to the records to be unpublished.
	RecordRefs *RecordRefs `protobuf:"bytes,1,opt,name=record_refs,json=recordRefs,proto3,oneof"`
}

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

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