v1

type BasicAuthCredentials struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

type CreateSyncRequest struct {

	// URL of the remote Registry to synchronize from.
	//
	// This should be a complete URL including protocol and port if non-standard.
	// Examples:
	// - "https://directory.example.com"
	// - "http://localhost:8080"
	// - "https://directory.example.com:9443"
	RemoteDirectoryUrl string `protobuf:"bytes,1,opt,name=remote_directory_url,json=remoteDirectoryUrl,proto3" json:"remote_directory_url,omitempty"`
	// List of CIDs to synchronize from the remote Directory.
	// If empty, all objects will be synchronized.
	Cids []string `protobuf:"bytes,2,rep,name=cids,proto3" json:"cids,omitempty"`
	// contains filtered or unexported fields
}

type CreateSyncResponse struct {

	// Unique identifier for the created synchronization operation.
	// This ID can be used with other SyncService RPCs to monitor and manage the sync.
	SyncId string `protobuf:"bytes,1,opt,name=sync_id,json=syncId,proto3" json:"sync_id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteSyncRequest struct {

	// Unique identifier of the synchronization operation to delete.
	SyncId string `protobuf:"bytes,1,opt,name=sync_id,json=syncId,proto3" json:"sync_id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteSyncResponse struct {
	// contains filtered or unexported fields
}

type GetSyncRequest struct {

	// Unique identifier of the synchronization operation to query.
	SyncId string `protobuf:"bytes,1,opt,name=sync_id,json=syncId,proto3" json:"sync_id,omitempty"`
	// contains filtered or unexported fields
}

type GetSyncResponse struct {

	// Unique identifier of the synchronization operation.
	SyncId string `protobuf:"bytes,1,opt,name=sync_id,json=syncId,proto3" json:"sync_id,omitempty"`
	// Current status of the synchronization operation.
	Status SyncStatus `protobuf:"varint,2,opt,name=status,proto3,enum=agntcy.dir.store.v1.SyncStatus" json:"status,omitempty"`
	// URL of the remote Directory node being synchronized from.
	RemoteDirectoryUrl string `protobuf:"bytes,3,opt,name=remote_directory_url,json=remoteDirectoryUrl,proto3" json:"remote_directory_url,omitempty"`
	// Timestamp when the synchronization operation was created in the RFC3339 format.
	// Specs: https://www.rfc-editor.org/rfc/rfc3339.html
	CreatedTime string `protobuf:"bytes,4,opt,name=created_time,json=createdTime,proto3" json:"created_time,omitempty"`
	// Timestamp of the most recent status update for this synchronization in the RFC3339 format.
	LastUpdateTime string `protobuf:"bytes,5,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`
	// contains filtered or unexported fields
}

type ListSyncsItem struct {

	// Unique identifier of the synchronization operation.
	SyncId string `protobuf:"bytes,1,opt,name=sync_id,json=syncId,proto3" json:"sync_id,omitempty"`
	// Current status of the synchronization operation.
	Status SyncStatus `protobuf:"varint,2,opt,name=status,proto3,enum=agntcy.dir.store.v1.SyncStatus" json:"status,omitempty"`
	// URL of the remote Directory being synchronized from.
	RemoteDirectoryUrl string `protobuf:"bytes,3,opt,name=remote_directory_url,json=remoteDirectoryUrl,proto3" json:"remote_directory_url,omitempty"`
	// contains filtered or unexported fields
}

type ListSyncsRequest 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 PullReferrerRequest struct {

	// Record reference
	RecordRef *v1.RecordRef `protobuf:"bytes,1,opt,name=record_ref,json=recordRef,proto3" json:"record_ref,omitempty"`
	// Record referrer type to be pulled
	// If not provided, all referrers will be pulled
	ReferrerType *string `protobuf:"bytes,2,opt,name=referrer_type,json=referrerType,proto3,oneof" json:"referrer_type,omitempty"`
	// contains filtered or unexported fields
}

type PullReferrerResponse struct {

	// RecordReferrer object associated with the record
	Referrer *v1.RecordReferrer `protobuf:"bytes,1,opt,name=referrer,proto3" json:"referrer,omitempty"`
	// contains filtered or unexported fields
}

type PushReferrerRequest struct {

	// Record reference
	RecordRef *v1.RecordRef `protobuf:"bytes,1,opt,name=record_ref,json=recordRef,proto3" json:"record_ref,omitempty"`
	// RecordReferrer object to be stored for the record
	Referrer *v1.RecordReferrer `protobuf:"bytes,2,opt,name=referrer,proto3" json:"referrer,omitempty"`
	// contains filtered or unexported fields
}

type PushReferrerResponse struct {

	// The push process result
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// Optional error message if push failed
	ErrorMessage *string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3,oneof" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

type RequestRegistryCredentialsRequest struct {

	// Identity of the requesting node
	// For example: spiffe://example.org/service/foo
	RequestingNodeId string `protobuf:"bytes,1,opt,name=requesting_node_id,json=requestingNodeId,proto3" json:"requesting_node_id,omitempty"`
	// contains filtered or unexported fields
}

type RequestRegistryCredentialsResponse struct {

	// Success status of the credential negotiation
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// Error message if negotiation failed
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// URL of the remote Registry being synchronized from.
	RemoteRegistryUrl string `protobuf:"bytes,3,opt,name=remote_registry_url,json=remoteRegistryUrl,proto3" json:"remote_registry_url,omitempty"`
	// Registry credentials (oneof based on credential type)
	//
	// Types that are valid to be assigned to Credentials:
	//
	//	*RequestRegistryCredentialsResponse_BasicAuth
	Credentials isRequestRegistryCredentialsResponse_Credentials `protobuf_oneof:"credentials"`
	// contains filtered or unexported fields
}

type RequestRegistryCredentialsResponse_BasicAuth struct {
	BasicAuth *BasicAuthCredentials `protobuf:"bytes,4,opt,name=basic_auth,json=basicAuth,proto3,oneof"` // CertificateCredentials certificate = 5;
}

type StoreServiceClient interface {
	// Push performs write operation for given records.
	Push(ctx context.Context, opts ...grpc.CallOption) (StoreService_PushClient, error)
	// Pull performs read operation for given records.
	Pull(ctx context.Context, opts ...grpc.CallOption) (StoreService_PullClient, error)
	// Lookup resolves basic metadata for the records.
	Lookup(ctx context.Context, opts ...grpc.CallOption) (StoreService_LookupClient, error)
	// Remove performs delete operation for the records.
	Delete(ctx context.Context, opts ...grpc.CallOption) (StoreService_DeleteClient, error)
	// PushReferrer performs write operation for record referrers.
	PushReferrer(ctx context.Context, opts ...grpc.CallOption) (StoreService_PushReferrerClient, error)
	// PullReferrer performs read operation for record referrers.
	PullReferrer(ctx context.Context, opts ...grpc.CallOption) (StoreService_PullReferrerClient, error)
}

type StoreServiceServer interface {
	// Push performs write operation for given records.
	Push(StoreService_PushServer) error
	// Pull performs read operation for given records.
	Pull(StoreService_PullServer) error
	// Lookup resolves basic metadata for the records.
	Lookup(StoreService_LookupServer) error
	// Remove performs delete operation for the records.
	Delete(StoreService_DeleteServer) error
	// PushReferrer performs write operation for record referrers.
	PushReferrer(StoreService_PushReferrerServer) error
	// PullReferrer performs read operation for record referrers.
	PullReferrer(StoreService_PullReferrerServer) error
}

type StoreService_DeleteClient interface {
	Send(*v1.RecordRef) error
	CloseAndRecv() (*emptypb.Empty, error)
	grpc.ClientStream
}

type StoreService_DeleteServer interface {
	SendAndClose(*emptypb.Empty) error
	Recv() (*v1.RecordRef, error)
	grpc.ServerStream
}

type StoreService_LookupClient interface {
	Send(*v1.RecordRef) error
	Recv() (*v1.RecordMeta, error)
	grpc.ClientStream
}

type StoreService_LookupServer interface {
	Send(*v1.RecordMeta) error
	Recv() (*v1.RecordRef, error)
	grpc.ServerStream
}

type StoreService_PullClient interface {
	Send(*v1.RecordRef) error
	Recv() (*v1.Record, error)
	grpc.ClientStream
}

type StoreService_PullReferrerClient interface {
	Send(*PullReferrerRequest) error
	Recv() (*PullReferrerResponse, error)
	grpc.ClientStream
}

type StoreService_PullReferrerServer interface {
	Send(*PullReferrerResponse) error
	Recv() (*PullReferrerRequest, error)
	grpc.ServerStream
}

type StoreService_PullServer interface {
	Send(*v1.Record) error
	Recv() (*v1.RecordRef, error)
	grpc.ServerStream
}

type StoreService_PushClient interface {
	Send(*v1.Record) error
	Recv() (*v1.RecordRef, error)
	grpc.ClientStream
}

type StoreService_PushReferrerClient interface {
	Send(*PushReferrerRequest) error
	Recv() (*PushReferrerResponse, error)
	grpc.ClientStream
}

type StoreService_PushReferrerServer interface {
	Send(*PushReferrerResponse) error
	Recv() (*PushReferrerRequest, error)
	grpc.ServerStream
}

type StoreService_PushServer interface {
	Send(*v1.RecordRef) error
	Recv() (*v1.Record, error)
	grpc.ServerStream
}

type SyncServiceClient interface {
	// CreateSync initiates a new synchronization operation from a remote Directory node.
	//
	// The operation is non-blocking and returns immediately with a sync ID that can be used
	// to track progress and manage the sync operation.
	CreateSync(ctx context.Context, in *CreateSyncRequest, opts ...grpc.CallOption) (*CreateSyncResponse, error)
	// ListSyncs returns a stream of all sync operations known to the system.
	//
	// This includes active, completed, and failed synchronizations.
	ListSyncs(ctx context.Context, in *ListSyncsRequest, opts ...grpc.CallOption) (SyncService_ListSyncsClient, error)
	// GetSync retrieves detailed status information for a specific synchronization.
	GetSync(ctx context.Context, in *GetSyncRequest, opts ...grpc.CallOption) (*GetSyncResponse, error)
	// DeleteSync removes a synchronization operation from the system.
	DeleteSync(ctx context.Context, in *DeleteSyncRequest, opts ...grpc.CallOption) (*DeleteSyncResponse, error)
	// RequestRegistryCredentials requests registry credentials between two Directory nodes.
	//
	// This RPC allows a requesting node to authenticate with this node and obtain
	// temporary registry credentials for secure Zot-based synchronization.
	RequestRegistryCredentials(ctx context.Context, in *RequestRegistryCredentialsRequest, opts ...grpc.CallOption) (*RequestRegistryCredentialsResponse, error)
}

type SyncServiceServer interface {
	// CreateSync initiates a new synchronization operation from a remote Directory node.
	//
	// The operation is non-blocking and returns immediately with a sync ID that can be used
	// to track progress and manage the sync operation.
	CreateSync(context.Context, *CreateSyncRequest) (*CreateSyncResponse, error)
	// ListSyncs returns a stream of all sync operations known to the system.
	//
	// This includes active, completed, and failed synchronizations.
	ListSyncs(*ListSyncsRequest, SyncService_ListSyncsServer) error
	// GetSync retrieves detailed status information for a specific synchronization.
	GetSync(context.Context, *GetSyncRequest) (*GetSyncResponse, error)
	// DeleteSync removes a synchronization operation from the system.
	DeleteSync(context.Context, *DeleteSyncRequest) (*DeleteSyncResponse, error)
	// RequestRegistryCredentials requests registry credentials between two Directory nodes.
	//
	// This RPC allows a requesting node to authenticate with this node and obtain
	// temporary registry credentials for secure Zot-based synchronization.
	RequestRegistryCredentials(context.Context, *RequestRegistryCredentialsRequest) (*RequestRegistryCredentialsResponse, error)
}

type SyncService_ListSyncsClient interface {
	Recv() (*ListSyncsItem, error)
	grpc.ClientStream
}

type SyncService_ListSyncsServer interface {
	Send(*ListSyncsItem) error
	grpc.ServerStream
}

type SyncStatus int32

type UnimplementedStoreServiceServer struct{}

type UnimplementedSyncServiceServer struct{}

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

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