Method GetClients

persistence/sql/persister_client.go:134–163

GetClients implements client.Storage.

(ctx context.Context, filters client.Filter)

// GetClients implements client.Storage.
func (p *Persister) GetClients(ctx context.Context, filters client.Filter) (cs []client.Client, _ *keysetpagination.Paginator, err error) {
	ctx, span := p.r.Tracer(ctx).Tracer().Start(ctx, "persistence.sql.GetClients")
	defer otelx.End(span, &err)

	paginator, err := keysetpagination.NewPaginator(append(filters.PageOpts,
		keysetpagination.WithDefaultToken(keysetpagination.NewPageToken(keysetpagination.Column{Name: "id", Value: ""})),
	)...)
	if err != nil {
		return nil, nil, err
	}

	query := p.QueryWithNetwork(ctx).Scope(
		keysetpagination.Paginate[client.Client](paginator))

	if filters.Name != "" {
		query.Where("client_name = ?", filters.Name)
	}
	if filters.Owner != "" {
		query.Where("owner = ?", filters.Owner)
	}
	if len(filters.IDs) > 0 {
		query.Where("id IN (?)", filters.IDs)
	}

	if err := query.All(&cs); err != nil {
		return nil, nil, sqlcon.HandleError(err)
	}
	cs, nextPage := keysetpagination.Result(cs, paginator)
	return cs, nextPage, nil
}

// GetConcreteClient implements client.Storage.
func (p *Persister) GetConcreteClient(ctx context.Context, id string) (c *client.Client, err error) {