grpcserver

type CampusService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

type CarrierFacilityService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

type CarrierService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

type FacilityService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

type InternetExchangeService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

type IxFacilityService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

type IxLanService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

type IxPrefixService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

type ListParams[E any, P any] struct {
	EntityName   string
	PageSize     int32
	PageToken    string
	ApplyFilters func() ([]func(*sql.Selector), error)
	Query        func(ctx context.Context, predicates []func(*sql.Selector), limit, offset int) ([]*E, error)
	Convert      func(*E) *P
}

type NetworkFacilityService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

type NetworkIxLanService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

type NetworkService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

type OrganizationService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

type PocService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

type StreamParams[E any, P any] struct {
	EntityName   string
	Timeout      time.Duration
	SinceID      *int64
	UpdatedSince *timestamppb.Timestamp
	ApplyFilters func() ([]func(*sql.Selector), error)
	Count        func(ctx context.Context, predicates []func(*sql.Selector)) (int, error)
	// QueryBatch fetches the next batch under compound keyset pagination. When
	// cursor.empty() the query runs without a cursor predicate; otherwise the
	// handler emits the compound keyset predicate
	//   WHERE (updated < cursor.Updated) OR (updated = cursor.Updated AND id < cursor.ID)
	// under the `(-updated, -created, -id)` default order (Phase 67, CONTEXT.md
	// D-01 / D-05).
	QueryBatch func(ctx context.Context, predicates []func(*sql.Selector), cursor streamCursor, limit int) ([]*E, error)
	Convert    func(*E) *P
	GetID      func(*E) int
	// GetUpdated extracts the `updated` timestamp from an entity for the
	// compound cursor's primary key. Required by StreamEntities to emit the
	// next-batch cursor after each batch drains.
	GetUpdated func(*E) time.Time
}