v1beta1connect

package

Go to main page

Versions in this module

v0

v0.74.0

Sep 11, 2025

Changes in this version

+ const IdempotencyReplyHeader

+ var ErrConflictRequest = errors.New("already exist")

+ var ErrInvalidActorType = errors.New("invalid actor type")

+ var ErrNamespaceSplitNotation = errors.New("subject/object should be provided as 'namespace:uuid'")

+ func TransformAuditRecordToPB(record auditrecord.AuditRecord) (*frontierv1beta1.CreateAuditRecordResponse, error)

+ type AuditRecordService interface

+ Create func(ctx context.Context, record auditrecord.AuditRecord) (auditrecord.AuditRecord, bool, error)

+ type BootstrapService interface

+ AppendSchema func(ctx context.Context, definition schema.ServiceDefinition) error

+ type CheckoutService interface

+ Apply func(ctx context.Context, ch checkout.Checkout) (*subscription.Subscription, *product.Product, error)

+ Create func(ctx context.Context, ch checkout.Checkout) (checkout.Checkout, error)

+ CreateSessionForCustomerPortal func(ctx context.Context, ch checkout.Checkout) (checkout.Checkout, error)

+ CreateSessionForPaymentMethod func(ctx context.Context, ch checkout.Checkout) (checkout.Checkout, error)

+ GetByID func(ctx context.Context, id string) (checkout.Checkout, error)

+ List func(ctx context.Context, filter checkout.Filter) ([]checkout.Checkout, error)

type ConnectHandler

+ func (h *ConnectHandler) CheckFederatedResourcePermission(ctx context.Context, ...) (*connect.Response[frontierv1beta1.CheckFederatedResourcePermissionResponse], ...)

+ func (h *ConnectHandler) CreateAuditRecord(ctx context.Context, ...) (*connect.Response[frontierv1beta1.CreateAuditRecordResponse], error)

+ func (h *ConnectHandler) CreatePermission(ctx context.Context, ...) (*connect.Response[frontierv1beta1.CreatePermissionResponse], error)

+ func (h *ConnectHandler) CreateRole(ctx context.Context, ...) (*connect.Response[frontierv1beta1.CreateRoleResponse], error)

+ func (h *ConnectHandler) DelegatedCheckout(ctx context.Context, ...) (*connect.Response[frontierv1beta1.DelegatedCheckoutResponse], error)

+ func (h *ConnectHandler) DeleteRole(ctx context.Context, ...) (*connect.Response[frontierv1beta1.DeleteRoleResponse], error)

+ func (h *ConnectHandler) GenerateInvoices(ctx context.Context, ...) (*connect.Response[frontierv1beta1.GenerateInvoicesResponse], error)

+ func (h *ConnectHandler) GetBillingAccount(ctx context.Context, ...) (*connect.Response[frontierv1beta1.GetBillingAccountResponse], error)

+ func (h *ConnectHandler) GetBillingAccountDetails(ctx context.Context, ...) (*connect.Response[frontierv1beta1.GetBillingAccountDetailsResponse], error)

+ func (h *ConnectHandler) ListAllBillingAccounts(ctx context.Context, ...) (*connect.Response[frontierv1beta1.ListAllBillingAccountsResponse], error)

+ func (h *ConnectHandler) ListAllInvoices(ctx context.Context, ...) (*connect.Response[frontierv1beta1.ListAllInvoicesResponse], error)

+ func (h *ConnectHandler) ListGroups(ctx context.Context, ...) (*connect.Response[frontierv1beta1.ListGroupsResponse], error)

+ func (h *ConnectHandler) ListProjects(ctx context.Context, ...) (*connect.Response[frontierv1beta1.ListProjectsResponse], error)

+ func (h *ConnectHandler) ListRelations(ctx context.Context, ...) (*connect.Response[frontierv1beta1.ListRelationsResponse], error)

+ func (h *ConnectHandler) ListResources(ctx context.Context, ...) (*connect.Response[frontierv1beta1.ListResourcesResponse], error)

+ func (h *ConnectHandler) RevertBillingUsage(ctx context.Context, ...) (*connect.Response[frontierv1beta1.RevertBillingUsageResponse], error)

+ func (h *ConnectHandler) SearchInvoices(ctx context.Context, ...) (*connect.Response[frontierv1beta1.SearchInvoicesResponse], error)

+ func (h *ConnectHandler) SearchProjectUsers(ctx context.Context, ...) (*connect.Response[frontierv1beta1.SearchProjectUsersResponse], error)

+ func (h *ConnectHandler) UpdateBillingAccountDetails(ctx context.Context, ...) (*connect.Response[frontierv1beta1.UpdateBillingAccountDetailsResponse], error)

+ func (h *ConnectHandler) UpdateBillingAccountLimits(ctx context.Context, ...) (*connect.Response[frontierv1beta1.UpdateBillingAccountLimitsResponse], error)

+ func (h *ConnectHandler) UpdatePermission(ctx context.Context, ...) (*connect.Response[frontierv1beta1.UpdatePermissionResponse], error)

+ func (h *ConnectHandler) UpdateRole(ctx context.Context, ...) (*connect.Response[frontierv1beta1.UpdateRoleResponse], error)

+ type CustomerService interface

+ Create func(ctx context.Context, customer customer.Customer, offline bool) (customer.Customer, error)

+ GetByID func(ctx context.Context, id string) (customer.Customer, error)

+ GetDetails func(ctx context.Context, customerID string) (customer.Details, error)

+ List func(ctx context.Context, filter customer.Filter) ([]customer.Customer, error)

+ ListPaymentMethods func(ctx context.Context, id string) ([]customer.PaymentMethod, error)

+ UpdateCreditMinByID func(ctx context.Context, customerID string, limit int64) (customer.Details, error)

+ UpdateDetails func(ctx context.Context, customerID string, details customer.Details) (customer.Details, error)

+ type InvoiceService interface

+ GetUpcoming func(ctx context.Context, customerID string) (invoice.Invoice, error)

+ List func(ctx context.Context, filter invoice.Filter) ([]invoice.Invoice, error)

+ ListAll func(ctx context.Context, filter invoice.Filter) ([]invoice.Invoice, error)

+ SearchInvoices func(ctx context.Context, rqlQuery *rql.Query) ([]invoice.InvoiceWithOrganization, error)

+ TriggerCreditOverdraftInvoices func(ctx context.Context) error

+ type PermissionService interface

+ Get func(ctx context.Context, id string) (permission.Permission, error)

+ List func(ctx context.Context, filter permission.Filter) ([]permission.Permission, error)

+ Update func(ctx context.Context, perm permission.Permission) (permission.Permission, error)

+ Upsert func(ctx context.Context, perm permission.Permission) (permission.Permission, error)

+ type ProjectUsersService interface

+ Search func(ctx context.Context, id string, query *rql.Query) (projectusers.ProjectUsers, error)

+ type RelationService interface

+ Create func(ctx context.Context, rel relation.Relation) (relation.Relation, error)

+ Delete func(ctx context.Context, rel relation.Relation) error

+ Get func(ctx context.Context, id string) (relation.Relation, error)

+ List func(ctx context.Context, f relation.Filter) ([]relation.Relation, error)

+ type RoleService interface

+ Delete func(ctx context.Context, id string) error

+ Get func(ctx context.Context, id string) (role.Role, error)

+ List func(ctx context.Context, f role.Filter) ([]role.Role, error)

+ Update func(ctx context.Context, toUpdate role.Role) (role.Role, error)

+ Upsert func(ctx context.Context, toCreate role.Role) (role.Role, error)

+ type UsageService interface

+ Report func(ctx context.Context, usages []usage.Usage) error

+ Revert func(ctx context.Context, accountID, usageID string, amount int64) error

v0.73.0

Aug 21, 2025

Changes in this version

type ConnectHandler

+ func (h *ConnectHandler) ExportOrganizationProjects(ctx context.Context, ...) error

+ func (h *ConnectHandler) ExportOrganizationTokens(ctx context.Context, ...) error

+ func (h *ConnectHandler) ExportOrganizationUsers(ctx context.Context, ...) error

+ func (h *ConnectHandler) ExportUsers(ctx context.Context, ...) error

+ func (h *ConnectHandler) GetOrganizationKyc(ctx context.Context, ...) (*connect.Response[frontierv1beta1.GetOrganizationKycResponse], error)

+ func (h *ConnectHandler) ListOrganizationsKyc(ctx context.Context, ...) (*connect.Response[frontierv1beta1.ListOrganizationsKycResponse], error)

+ func (h *ConnectHandler) SearchUserOrganizations(ctx context.Context, ...) (*connect.Response[frontierv1beta1.SearchUserOrganizationsResponse], error)

+ func (h *ConnectHandler) SearchUserProjects(ctx context.Context, ...) (*connect.Response[frontierv1beta1.SearchUserProjectsResponse], error)

+ func (h *ConnectHandler) SearchUsers(ctx context.Context, ...) (*connect.Response[frontierv1beta1.SearchUsersResponse], error)

+ func (h *ConnectHandler) SetOrganizationKyc(ctx context.Context, ...) (*connect.Response[frontierv1beta1.SetOrganizationKycResponse], error)

+ type KycService interface

+ GetKyc func(context.Context, string) (kyc.KYC, error)

+ ListKycs func(context.Context) ([]kyc.KYC, error)

+ SetKyc func(context.Context, kyc.KYC) (kyc.KYC, error)

+ type UserOrgsService interface

+ Search func(ctx context.Context, id string, query *rql.Query) (userorgs.UserOrgs, error)

+ type UserProjectsService interface

+ Search func(ctx context.Context, userId string, orgId string, query *rql.Query) (userprojects.UserProjects, error)

v0.72.3

Aug 6, 2025

v0.72.2

Aug 6, 2025

v0.72.0

Aug 4, 2025

v0.71.0

Jul 30, 2025

Changes in this version

+ var ErrBadBodyMetaSchemaError = errors.New(ErrBadRequest.Error() + " : " + ErrInvalidMetadata.Error())

+ var ErrInvalidMetadata = errors.New("metadata schema validation failed")

type ConnectHandler

+ func (h *ConnectHandler) AdminCreateOrganization(ctx context.Context, ...) (*connect.Response[frontierv1beta1.AdminCreateOrganizationResponse], error)

+ func (h *ConnectHandler) ExportOrganizations(ctx context.Context, ...) error

+ func (h *ConnectHandler) ListAllOrganizations(ctx context.Context, ...) (*connect.Response[frontierv1beta1.ListAllOrganizationsResponse], error)

+ func (h *ConnectHandler) SearchOrganizationInvoices(ctx context.Context, ...) (*connect.Response[frontierv1beta1.SearchOrganizationInvoicesResponse], error)

+ func (h *ConnectHandler) SearchOrganizationProjects(ctx context.Context, ...) (*connect.Response[frontierv1beta1.SearchOrganizationProjectsResponse], error)

+ func (h *ConnectHandler) SearchOrganizationServiceUserCredentials(ctx context.Context, ...) (...)

+ func (h *ConnectHandler) SearchOrganizationTokens(ctx context.Context, ...) (*connect.Response[frontierv1beta1.SearchOrganizationTokensResponse], error)

+ func (h *ConnectHandler) SearchOrganizationUsers(ctx context.Context, ...) (*connect.Response[frontierv1beta1.SearchOrganizationUsersResponse], error)

+ func (h *ConnectHandler) SearchOrganizations(ctx context.Context, ...) (*connect.Response[frontierv1beta1.SearchOrganizationsResponse], error)

+ type OrgBillingService interface

+ Export func(ctx context.Context) ([]byte, string, error)

+ Search func(ctx context.Context, query *rql.Query) (orgbilling.OrgBilling, error)

+ type OrgInvoicesService interface

+ Search func(ctx context.Context, id string, query *rql.Query) (orginvoices.OrganizationInvoices, error)

+ type OrgProjectsService interface

+ Export func(ctx context.Context, orgID string) ([]byte, string, error)

+ Search func(ctx context.Context, id string, query *rql.Query) (orgprojects.OrgProjects, error)

+ type OrgServiceUserCredentialsService interface

+ Search func(ctx context.Context, id string, query *rql.Query) (svc.OrganizationServiceUserCredentials, error)

+ type OrgTokensService interface

+ Export func(ctx context.Context, orgID string) ([]byte, string, error)

+ Search func(ctx context.Context, id string, query *rql.Query) (svc.OrganizationTokens, error)

+ type OrgUsersService interface

+ Export func(ctx context.Context, orgID string) ([]byte, string, error)

+ Search func(ctx context.Context, id string, query *rql.Query) (orgusers.OrgUsers, error)

v0.70.1

Jul 24, 2025

v0.70.0

Jul 21, 2025

Changes in this version

type ConnectHandler

+ func (h *ConnectHandler) GetCurrentAdminUser(ctx context.Context, ...) (*connect.Response[frontierv1beta1.GetCurrentAdminUserResponse], error)

v0.69.0

Jul 17, 2025

Changes in this version

+ var ErrBadRequest = errors.New("invalid syntax in body")

+ var ErrInternalServerError = errors.New("internal server error")

+ var ErrInvalidEmail = errors.New("Invalid email")

+ var ErrInvalidNamesapceOrID = errors.New("namespace and ID cannot be empty")

+ var ErrNotFound = errors.New("not found")

+ var ErrOperationUnsupported = errors.New("operation not supported")

+ var ErrUnauthenticated = errors.New("not authenticated")

+ var ErrUnauthorized = errors.New("not authorized")

+ var ErrUserNotExist = errors.New("user doesn't exist")

+ func ExtractLogger(ctx context.Context) *zap.Logger

type ConnectHandler

+ func (h *ConnectHandler) AuthCallback(ctx context.Context, ...) (*connect.Response[frontierv1beta1.AuthCallbackResponse], error)

+ func (h *ConnectHandler) AuthLogout(ctx context.Context, ...) (*connect.Response[frontierv1beta1.AuthLogoutResponse], error)

+ func (h *ConnectHandler) AuthToken(ctx context.Context, ...) (*connect.Response[frontierv1beta1.AuthTokenResponse], error)

+ func (h *ConnectHandler) Authenticate(ctx context.Context, ...) (*connect.Response[frontierv1beta1.AuthenticateResponse], error)

+ func (h *ConnectHandler) CheckPlanEntitlement(ctx context.Context, obj relation.Object) error

+ func (h *ConnectHandler) GetLoggedInPrincipal(ctx context.Context, via ...authenticate.ClientAssertion) (authenticate.Principal, error)

+ func (h *ConnectHandler) GetOrganization(ctx context.Context, ...) (*connect.Response[frontierv1beta1.GetOrganizationResponse], error)

+ func (h *ConnectHandler) GetRawCheckout(ctx context.Context, id string) (checkout.Checkout, error)

+ func (h *ConnectHandler) GetServiceUser(ctx context.Context, ...) (*connect.Response[frontierv1beta1.GetServiceUserResponse], error)

+ func (h *ConnectHandler) IsAuthorized(ctx context.Context, object relation.Object, permission string) error

+ func (h *ConnectHandler) IsSuperUser(ctx context.Context) error

+ func (h *ConnectHandler) ListAuthStrategies(ctx context.Context, ...) (*connect.Response[frontierv1beta1.ListAuthStrategiesResponse], error)

+ func (h *ConnectHandler) ListPlatformPreferences(ctx context.Context) (map[string]string, error)

v0.68.0

Jul 16, 2025

v0.67.0

Jul 14, 2025

Changes in this version

type ConnectHandler

+ func (h *ConnectHandler) ListAllServiceUsers(context.Context, *connect.Request[frontierv1beta1.ListAllServiceUsersRequest]) (*connect.Response[frontierv1beta1.ListAllServiceUsersResponse], error)

v0.66.0

Jul 9, 2025

Changes in this version

+ type ConnectHandler struct

+ func NewConnectHandler(deps api.Deps) *ConnectHandler

+ func (h *ConnectHandler) ListAllUsers(context.Context, *connect.Request[frontierv1beta1.ListAllUsersRequest]) (*connect.Response[frontierv1beta1.ListAllUsersResponse], error)

+ func (h *ConnectHandler) ListUsers(context.Context, *connect.Request[frontierv1beta1.ListUsersRequest]) (*connect.Response[frontierv1beta1.ListUsersResponse], error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL