Documentation ¶
Index ¶
- Constants
- Variables
- type APITokenService
- func (s *APITokenService) Create(ctx context.Context, req *pb.APITokenServiceCreateRequest) (*pb.APITokenServiceCreateResponse, error)
- func (s *APITokenService) List(ctx context.Context, req *pb.APITokenServiceListRequest) (*pb.APITokenServiceListResponse, error)
- func (s *APITokenService) Revoke(ctx context.Context, req *pb.APITokenServiceRevokeRequest) (*pb.APITokenServiceRevokeResponse, error)
- type AttestationService
- func (s *AttestationService) Cancel(ctx context.Context, req *cpAPI.AttestationServiceCancelRequest) (*cpAPI.AttestationServiceCancelResponse, error)
- func (s *AttestationService) FindOrCreateWorkflow(ctx context.Context, req *cpAPI.FindOrCreateWorkflowRequest) (*cpAPI.FindOrCreateWorkflowResponse, error)
- func (s *AttestationService) GetContract(ctx context.Context, req *cpAPI.AttestationServiceGetContractRequest) (*cpAPI.AttestationServiceGetContractResponse, error)
- func (s *AttestationService) GetPolicy(ctx context.Context, req *cpAPI.AttestationServiceGetPolicyRequest) (*cpAPI.AttestationServiceGetPolicyResponse, error)
- func (s *AttestationService) GetPolicyGroup(ctx context.Context, req *cpAPI.AttestationServiceGetPolicyGroupRequest) (*cpAPI.AttestationServiceGetPolicyGroupResponse, error)
- func (s *AttestationService) GetUploadCreds(ctx context.Context, req *cpAPI.AttestationServiceGetUploadCredsRequest) (*cpAPI.AttestationServiceGetUploadCredsResponse, error)
- func (s *AttestationService) Init(ctx context.Context, req *cpAPI.AttestationServiceInitRequest) (*cpAPI.AttestationServiceInitResponse, error)
- func (s *AttestationService) Store(ctx context.Context, req *cpAPI.AttestationServiceStoreRequest) (*cpAPI.AttestationServiceStoreResponse, error)
- type AttestationStateService
- func (s *AttestationStateService) Initialized(ctx context.Context, req *cpAPI.AttestationStateServiceInitializedRequest) (*cpAPI.AttestationStateServiceInitializedResponse, error)
- func (s *AttestationStateService) Read(ctx context.Context, req *cpAPI.AttestationStateServiceReadRequest) (*cpAPI.AttestationStateServiceReadResponse, error)
- func (s *AttestationStateService) Reset(ctx context.Context, req *cpAPI.AttestationStateServiceResetRequest) (*cpAPI.AttestationStateServiceResetResponse, error)
- func (s *AttestationStateService) Save(ctx context.Context, req *cpAPI.AttestationStateServiceSaveRequest) (*cpAPI.AttestationStateServiceSaveResponse, error)
- type AuthService
- type AuthURLs
- type CASBackendService
- func (s *CASBackendService) Create(ctx context.Context, req *pb.CASBackendServiceCreateRequest) (*pb.CASBackendServiceCreateResponse, error)
- func (s *CASBackendService) Delete(ctx context.Context, req *pb.CASBackendServiceDeleteRequest) (*pb.CASBackendServiceDeleteResponse, error)
- func (s *CASBackendService) List(ctx context.Context, _ *pb.CASBackendServiceListRequest) (*pb.CASBackendServiceListResponse, error)
- func (s *CASBackendService) Update(ctx context.Context, req *pb.CASBackendServiceUpdateRequest) (*pb.CASBackendServiceUpdateResponse, error)
- type CASCredentialsService
- type CASRedirectService
- type ContextService
- type IntegrationsService
- func (s *IntegrationsService) Attach(ctx context.Context, req *pb.IntegrationsServiceAttachRequest) (*pb.IntegrationsServiceAttachResponse, error)
- func (s *IntegrationsService) Deregister(ctx context.Context, req *pb.IntegrationsServiceDeregisterRequest) (*pb.IntegrationsServiceDeregisterResponse, error)
- func (s *IntegrationsService) DescribeRegistration(ctx context.Context, req *pb.IntegrationsServiceDescribeRegistrationRequest) (*pb.IntegrationsServiceDescribeRegistrationResponse, error)
- func (s *IntegrationsService) Detach(ctx context.Context, req *pb.IntegrationsServiceDetachRequest) (*pb.IntegrationsServiceDetachResponse, error)
- func (s *IntegrationsService) ListAttachments(ctx context.Context, req *pb.ListAttachmentsRequest) (*pb.ListAttachmentsResponse, error)
- func (s *IntegrationsService) ListAvailable(_ context.Context, _ *pb.IntegrationsServiceListAvailableRequest) (*pb.IntegrationsServiceListAvailableResponse, error)
- func (s *IntegrationsService) ListRegistrations(ctx context.Context, _ *pb.IntegrationsServiceListRegistrationsRequest) (*pb.IntegrationsServiceListRegistrationsResponse, error)
- func (s *IntegrationsService) Register(ctx context.Context, req *pb.IntegrationsServiceRegisterRequest) (*pb.IntegrationsServiceRegisterResponse, error)
- type NewAttestationServiceOpts
- type NewAttestationStateServiceOpt
- type NewOpt
- type NewWorkflowRunServiceOpts
- type OrgInvitationService
- func (s *OrgInvitationService) Create(ctx context.Context, req *pb.OrgInvitationServiceCreateRequest) (*pb.OrgInvitationServiceCreateResponse, error)
- func (s *OrgInvitationService) ListSent(ctx context.Context, _ *pb.OrgInvitationServiceListSentRequest) (*pb.OrgInvitationServiceListSentResponse, error)
- func (s *OrgInvitationService) Revoke(ctx context.Context, req *pb.OrgInvitationServiceRevokeRequest) (*pb.OrgInvitationServiceRevokeResponse, error)
- type OrgMetricsService
- func (s *OrgMetricsService) DailyRunsCount(ctx context.Context, req *pb.DailyRunsCountRequest) (*pb.DailyRunsCountResponse, error)
- func (s *OrgMetricsService) TopWorkflowsByRunsCount(ctx context.Context, req *pb.TopWorkflowsByRunsCountRequest) (*pb.TopWorkflowsByRunsCountResponse, error)
- func (s *OrgMetricsService) Totals(ctx context.Context, req *pb.OrgMetricsServiceTotalsRequest) (*pb.OrgMetricsServiceTotalsResponse, error)
- type OrganizationService
- func (s *OrganizationService) Create(ctx context.Context, req *pb.OrganizationServiceCreateRequest) (*pb.OrganizationServiceCreateResponse, error)
- func (s *OrganizationService) DeleteMembership(ctx context.Context, req *pb.OrganizationServiceDeleteMembershipRequest) (*pb.OrganizationServiceDeleteMembershipResponse, error)
- func (s *OrganizationService) ListMemberships(ctx context.Context, _ *pb.OrganizationServiceListMembershipsRequest) (*pb.OrganizationServiceListMembershipsResponse, error)
- func (s *OrganizationService) UpdateMembership(ctx context.Context, req *pb.OrganizationServiceUpdateMembershipRequest) (*pb.OrganizationServiceUpdateMembershipResponse, error)
- type PrometheusService
- type ReferrerService
- func (s *ReferrerService) DiscoverPrivate(ctx context.Context, req *pb.ReferrerServiceDiscoverPrivateRequest) (*pb.ReferrerServiceDiscoverPrivateResponse, error)
- func (s *ReferrerService) DiscoverPublicShared(ctx context.Context, req *pb.DiscoverPublicSharedRequest) (*pb.DiscoverPublicSharedResponse, error)
- type RobotAccountService
- func (s *RobotAccountService) Create(ctx context.Context, req *pb.RobotAccountServiceCreateRequest) (*pb.RobotAccountServiceCreateResponse, error)
- func (s *RobotAccountService) List(ctx context.Context, req *pb.RobotAccountServiceListRequest) (*pb.RobotAccountServiceListResponse, error)
- func (s *RobotAccountService) Revoke(ctx context.Context, req *pb.RobotAccountServiceRevokeRequest) (*pb.RobotAccountServiceRevokeResponse, error)
- type SigningService
- type StatusService
- type UserService
- func (s *UserService) DeleteMembership(ctx context.Context, req *pb.DeleteMembershipRequest) (*pb.DeleteMembershipResponse, error)
- func (s *UserService) ListMemberships(ctx context.Context, _ *pb.UserServiceListMembershipsRequest) (*pb.UserServiceListMembershipsResponse, error)
- func (s *UserService) SetCurrentMembership(ctx context.Context, req *pb.SetCurrentMembershipRequest) (*pb.SetCurrentMembershipResponse, error)
- type WorkflowContractService
- func (s *WorkflowContractService) Create(ctx context.Context, req *pb.WorkflowContractServiceCreateRequest) (*pb.WorkflowContractServiceCreateResponse, error)
- func (s *WorkflowContractService) Delete(ctx context.Context, req *pb.WorkflowContractServiceDeleteRequest) (*pb.WorkflowContractServiceDeleteResponse, error)
- func (s *WorkflowContractService) Describe(ctx context.Context, req *pb.WorkflowContractServiceDescribeRequest) (*pb.WorkflowContractServiceDescribeResponse, error)
- func (s *WorkflowContractService) List(ctx context.Context, _ *pb.WorkflowContractServiceListRequest) (*pb.WorkflowContractServiceListResponse, error)
- func (s *WorkflowContractService) Update(ctx context.Context, req *pb.WorkflowContractServiceUpdateRequest) (*pb.WorkflowContractServiceUpdateResponse, error)
- type WorkflowRunService
- type WorkflowService
- func (s *WorkflowService) Create(ctx context.Context, req *pb.WorkflowServiceCreateRequest) (*pb.WorkflowServiceCreateResponse, error)
- func (s *WorkflowService) Delete(ctx context.Context, req *pb.WorkflowServiceDeleteRequest) (*pb.WorkflowServiceDeleteResponse, error)
- func (s *WorkflowService) List(ctx context.Context, _ *pb.WorkflowServiceListRequest) (*pb.WorkflowServiceListResponse, error)
- func (s *WorkflowService) Update(ctx context.Context, req *pb.WorkflowServiceUpdateRequest) (*pb.WorkflowServiceUpdateResponse, error)
- func (s *WorkflowService) View(ctx context.Context, req *pb.WorkflowServiceViewRequest) (*pb.WorkflowServiceViewResponse, error)
Constants ¶
const ( // Auth paths AuthLoginPath = "/auth/login" AuthCallbackPath = "/auth/callback" )
The authentication process does the following 1 - Authenticate against a valid OIDC provider, currently only Google is supported 2 - Generate a chainloop signed JWT to be sent to the client
const (
// PrometheusMetricsPath is the path for the Prometheus metrics
PrometheusMetricsPath = "/prom/{org_name}/metrics"
)
Variables ¶
var ProviderSet = wire.NewSet( NewWorkflowService, NewAuthService, NewRobotAccountService, NewWorkflowRunService, NewAttestationService, NewWorkflowSchemaService, NewCASCredentialsService, NewContextService, NewOrgMetricsService, NewIntegrationsService, NewCASBackendService, NewCASRedirectService, NewOrganizationService, NewOrgInvitationService, NewReferrerService, NewAPITokenService, NewAttestationStateService, NewUserService, NewSigningService, NewPrometheusService, wire.Struct(new(NewWorkflowRunServiceOpts), "*"), wire.Struct(new(NewAttestationServiceOpts), "*"), wire.Struct(new(NewAttestationStateServiceOpt), "*"), )
ProviderSet is service providers.
Functions ¶
This section is empty.
Types ¶
type APITokenService ¶ added in v0.55.0
type APITokenService struct { pb.UnimplementedAPITokenServiceServer APITokenUseCase *biz.APITokenUseCase // contains filtered or unexported fields }
func NewAPITokenService ¶ added in v0.55.0
func NewAPITokenService(uc *biz.APITokenUseCase, opts ...NewOpt) *APITokenService
func (*APITokenService) Create ¶ added in v0.55.0
func (s *APITokenService) Create(ctx context.Context, req *pb.APITokenServiceCreateRequest) (*pb.APITokenServiceCreateResponse, error)
func (*APITokenService) List ¶ added in v0.55.0
func (s *APITokenService) List(ctx context.Context, req *pb.APITokenServiceListRequest) (*pb.APITokenServiceListResponse, error)
func (*APITokenService) Revoke ¶ added in v0.55.0
func (s *APITokenService) Revoke(ctx context.Context, req *pb.APITokenServiceRevokeRequest) (*pb.APITokenServiceRevokeResponse, error)
type AttestationService ¶
type AttestationService struct { cpAPI.UnimplementedAttestationServiceServer // contains filtered or unexported fields }
func NewAttestationService ¶
func NewAttestationService(opts *NewAttestationServiceOpts) *AttestationService
func (*AttestationService) Cancel ¶
func (s *AttestationService) Cancel(ctx context.Context, req *cpAPI.AttestationServiceCancelRequest) (*cpAPI.AttestationServiceCancelResponse, error)
func (*AttestationService) FindOrCreateWorkflow ¶ added in v0.97.0
func (s *AttestationService) FindOrCreateWorkflow(ctx context.Context, req *cpAPI.FindOrCreateWorkflowRequest) (*cpAPI.FindOrCreateWorkflowResponse, error)
func (*AttestationService) GetContract ¶
func (s *AttestationService) GetContract(ctx context.Context, req *cpAPI.AttestationServiceGetContractRequest) (*cpAPI.AttestationServiceGetContractResponse, error)
func (*AttestationService) GetPolicy ¶ added in v0.95.7
func (s *AttestationService) GetPolicy(ctx context.Context, req *cpAPI.AttestationServiceGetPolicyRequest) (*cpAPI.AttestationServiceGetPolicyResponse, error)
func (*AttestationService) GetPolicyGroup ¶ added in v0.96.14
func (s *AttestationService) GetPolicyGroup(ctx context.Context, req *cpAPI.AttestationServiceGetPolicyGroupRequest) (*cpAPI.AttestationServiceGetPolicyGroupResponse, error)
func (*AttestationService) GetUploadCreds ¶
func (s *AttestationService) GetUploadCreds(ctx context.Context, req *cpAPI.AttestationServiceGetUploadCredsRequest) (*cpAPI.AttestationServiceGetUploadCredsResponse, error)
There is another endpoint to get credentials via casCredentialsService.Get This one is kept since it leverages robot-accounts in the context of a workflow
func (*AttestationService) Init ¶
func (s *AttestationService) Init(ctx context.Context, req *cpAPI.AttestationServiceInitRequest) (*cpAPI.AttestationServiceInitResponse, error)
func (*AttestationService) Store ¶
func (s *AttestationService) Store(ctx context.Context, req *cpAPI.AttestationServiceStoreRequest) (*cpAPI.AttestationServiceStoreResponse, error)
type AttestationStateService ¶ added in v0.60.0
type AttestationStateService struct { cpAPI.UnimplementedAttestationStateServiceServer // contains filtered or unexported fields }
func NewAttestationStateService ¶ added in v0.60.0
func NewAttestationStateService(opts *NewAttestationStateServiceOpt) *AttestationStateService
func (*AttestationStateService) Initialized ¶ added in v0.60.0
func (s *AttestationStateService) Initialized(ctx context.Context, req *cpAPI.AttestationStateServiceInitializedRequest) (*cpAPI.AttestationStateServiceInitializedResponse, error)
func (*AttestationStateService) Read ¶ added in v0.60.0
func (s *AttestationStateService) Read(ctx context.Context, req *cpAPI.AttestationStateServiceReadRequest) (*cpAPI.AttestationStateServiceReadResponse, error)
func (*AttestationStateService) Reset ¶ added in v0.60.0
func (s *AttestationStateService) Reset(ctx context.Context, req *cpAPI.AttestationStateServiceResetRequest) (*cpAPI.AttestationStateServiceResetResponse, error)
func (*AttestationStateService) Save ¶ added in v0.60.0
func (s *AttestationStateService) Save(ctx context.Context, req *cpAPI.AttestationStateServiceSaveRequest) (*cpAPI.AttestationStateServiceSaveResponse, error)
type AuthService ¶
type AuthService struct { pb.UnimplementedAuthServiceServer AuthURLs *AuthURLs // contains filtered or unexported fields }
func NewAuthService ¶
func NewAuthService(userUC *biz.UserUseCase, orgUC *biz.OrganizationUseCase, mUC *biz.MembershipUseCase, inviteUC *biz.OrgInvitationUseCase, authConfig *conf.Auth, serverConfig *conf.Server, opts ...NewOpt) (*AuthService, error)
func (*AuthService) DeleteAccount ¶
func (svc *AuthService) DeleteAccount(ctx context.Context, _ *pb.AuthServiceDeleteAccountRequest) (*pb.AuthServiceDeleteAccountResponse, error)
DeleteAccount deletes an account
func (*AuthService) RegisterCallbackHandler ¶
func (svc *AuthService) RegisterCallbackHandler() http.Handler
func (*AuthService) RegisterLoginHandler ¶
func (svc *AuthService) RegisterLoginHandler() http.Handler
type CASBackendService ¶ added in v0.14.0
type CASBackendService struct { pb.UnimplementedCASBackendServiceServer // contains filtered or unexported fields }
func NewCASBackendService ¶ added in v0.14.0
func NewCASBackendService(uc *biz.CASBackendUseCase, providers backend.Providers, opts ...NewOpt) *CASBackendService
func (*CASBackendService) Create ¶ added in v0.14.0
func (s *CASBackendService) Create(ctx context.Context, req *pb.CASBackendServiceCreateRequest) (*pb.CASBackendServiceCreateResponse, error)
func (*CASBackendService) Delete ¶ added in v0.14.0
func (s *CASBackendService) Delete(ctx context.Context, req *pb.CASBackendServiceDeleteRequest) (*pb.CASBackendServiceDeleteResponse, error)
Delete the CAS backend
func (*CASBackendService) List ¶ added in v0.14.0
func (s *CASBackendService) List(ctx context.Context, _ *pb.CASBackendServiceListRequest) (*pb.CASBackendServiceListResponse, error)
func (*CASBackendService) Update ¶ added in v0.14.0
func (s *CASBackendService) Update(ctx context.Context, req *pb.CASBackendServiceUpdateRequest) (*pb.CASBackendServiceUpdateResponse, error)
type CASCredentialsService ¶
type CASCredentialsService struct { pb.UnimplementedCASCredentialsServiceServer // contains filtered or unexported fields }
func NewCASCredentialsService ¶
func NewCASCredentialsService(casUC *biz.CASCredentialsUseCase, casmUC *biz.CASMappingUseCase, casBUC *biz.CASBackendUseCase, authz *authz.Enforcer, opts ...NewOpt) *CASCredentialsService
func (*CASCredentialsService) Get ¶
func (s *CASCredentialsService) Get(ctx context.Context, req *pb.CASCredentialsServiceGetRequest) (*pb.CASCredentialsServiceGetResponse, error)
Get will generate temporary credentials to be used against the CAS service for the current organization
type CASRedirectService ¶ added in v0.16.0
type CASRedirectService struct { pb.UnimplementedCASRedirectServiceServer // contains filtered or unexported fields }
func NewCASRedirectService ¶ added in v0.16.0
func NewCASRedirectService(casmUC *biz.CASMappingUseCase, casCredsUC *biz.CASCredentialsUseCase, conf *conf.Bootstrap_CASServer, opts ...NewOpt) (*CASRedirectService, error)
func (*CASRedirectService) GetDownloadURL ¶ added in v0.16.0
func (s *CASRedirectService) GetDownloadURL(ctx context.Context, req *pb.GetDownloadURLRequest) (*pb.GetDownloadURLResponse, error)
GetDownloadURL returns a signed URL to download the artifact from the CAS backend The URL includes a JWT token that is used to authenticate the request, this token has all the information required to validate the request The result would look like "https://cas.chainloop.dev/download/sha256:[DIGEST]?t=tokenJWT
func (*CASRedirectService) HTTPDownload ¶ added in v0.16.0
func (s *CASRedirectService) HTTPDownload(ctx khttp.Context) error
Custom HTTP handler that handles redirect to the CAS download URL This handler does 1 - Force the user to do an oauth login dance 2 - calls GetDownloadURL to generate a proper URL 3 - redirects to the generated URL NOTE: This code is similar to the one that gets autogenerated if we happened to use proto.http but we can't use it because we need custom redirection
type ContextService ¶
type ContextService struct { pb.UnimplementedContextServiceServer // contains filtered or unexported fields }
func NewContextService ¶
func NewContextService(repoUC *biz.CASBackendUseCase, uUC *biz.UserUseCase, opts ...NewOpt) *ContextService
func (*ContextService) Current ¶
func (s *ContextService) Current(ctx context.Context, _ *pb.ContextServiceCurrentRequest) (*pb.ContextServiceCurrentResponse, error)
type IntegrationsService ¶
type IntegrationsService struct { pb.UnimplementedIntegrationsServiceServer // contains filtered or unexported fields }
func NewIntegrationsService ¶
func NewIntegrationsService(uc *biz.IntegrationUseCase, wuc *biz.WorkflowUseCase, integrations sdk.AvailablePlugins, opts ...NewOpt) *IntegrationsService
func (*IntegrationsService) Attach ¶
func (s *IntegrationsService) Attach(ctx context.Context, req *pb.IntegrationsServiceAttachRequest) (*pb.IntegrationsServiceAttachResponse, error)
func (*IntegrationsService) Deregister ¶ added in v0.11.1
func (s *IntegrationsService) Deregister(ctx context.Context, req *pb.IntegrationsServiceDeregisterRequest) (*pb.IntegrationsServiceDeregisterResponse, error)
func (*IntegrationsService) DescribeRegistration ¶ added in v0.11.1
func (s *IntegrationsService) DescribeRegistration(ctx context.Context, req *pb.IntegrationsServiceDescribeRegistrationRequest) (*pb.IntegrationsServiceDescribeRegistrationResponse, error)
func (*IntegrationsService) Detach ¶
func (s *IntegrationsService) Detach(ctx context.Context, req *pb.IntegrationsServiceDetachRequest) (*pb.IntegrationsServiceDetachResponse, error)
func (*IntegrationsService) ListAttachments ¶
func (s *IntegrationsService) ListAttachments(ctx context.Context, req *pb.ListAttachmentsRequest) (*pb.ListAttachmentsResponse, error)
func (*IntegrationsService) ListAvailable ¶ added in v0.11.1
func (s *IntegrationsService) ListAvailable(_ context.Context, _ *pb.IntegrationsServiceListAvailableRequest) (*pb.IntegrationsServiceListAvailableResponse, error)
func (*IntegrationsService) ListRegistrations ¶ added in v0.11.1
func (s *IntegrationsService) ListRegistrations(ctx context.Context, _ *pb.IntegrationsServiceListRegistrationsRequest) (*pb.IntegrationsServiceListRegistrationsResponse, error)
func (*IntegrationsService) Register ¶ added in v0.11.1
func (s *IntegrationsService) Register(ctx context.Context, req *pb.IntegrationsServiceRegisterRequest) (*pb.IntegrationsServiceRegisterResponse, error)
type NewAttestationServiceOpts ¶
type NewAttestationServiceOpts struct { WorkflowRunUC *biz.WorkflowRunUseCase WorkflowUC *biz.WorkflowUseCase WorkflowContractUC *biz.WorkflowContractUseCase OCIUC *biz.CASBackendUseCase CredsReader credentials.Reader IntegrationUseCase *biz.IntegrationUseCase CasCredsUseCase *biz.CASCredentialsUseCase AttestationUC *biz.AttestationUseCase FanoutDispatcher *dispatcher.FanOutDispatcher CASMappingUseCase *biz.CASMappingUseCase ReferrerUC *biz.ReferrerUseCase OrgUC *biz.OrganizationUseCase PromUC *biz.PrometheusUseCase Opts []NewOpt }
type NewAttestationStateServiceOpt ¶ added in v0.90.0
type NewAttestationStateServiceOpt struct { AttestationStateUseCase *biz.AttestationStateUseCase WorkflowUseCase *biz.WorkflowUseCase WorkflowRunUseCase *biz.WorkflowRunUseCase Opts []NewOpt }
type NewWorkflowRunServiceOpts ¶
type NewWorkflowRunServiceOpts struct { WorkflowRunUC *biz.WorkflowRunUseCase WorkflowUC *biz.WorkflowUseCase WorkflowContractUC *biz.WorkflowContractUseCase CredsReader credentials.Reader Opts []NewOpt }
type OrgInvitationService ¶ added in v0.25.0
type OrgInvitationService struct { pb.UnimplementedOrgInvitationServiceServer // contains filtered or unexported fields }
func NewOrgInvitationService ¶ added in v0.25.0
func NewOrgInvitationService(uc *biz.OrgInvitationUseCase, opts ...NewOpt) *OrgInvitationService
func (*OrgInvitationService) Create ¶ added in v0.25.0
func (s *OrgInvitationService) Create(ctx context.Context, req *pb.OrgInvitationServiceCreateRequest) (*pb.OrgInvitationServiceCreateResponse, error)
func (*OrgInvitationService) ListSent ¶ added in v0.25.0
func (s *OrgInvitationService) ListSent(ctx context.Context, _ *pb.OrgInvitationServiceListSentRequest) (*pb.OrgInvitationServiceListSentResponse, error)
func (*OrgInvitationService) Revoke ¶ added in v0.25.0
func (s *OrgInvitationService) Revoke(ctx context.Context, req *pb.OrgInvitationServiceRevokeRequest) (*pb.OrgInvitationServiceRevokeResponse, error)
type OrgMetricsService ¶
type OrgMetricsService struct { pb.UnimplementedOrgMetricsServiceServer // contains filtered or unexported fields }
func NewOrgMetricsService ¶
func NewOrgMetricsService(uc *biz.OrgMetricsUseCase, opts ...NewOpt) *OrgMetricsService
func (*OrgMetricsService) DailyRunsCount ¶ added in v0.80.0
func (s *OrgMetricsService) DailyRunsCount(ctx context.Context, req *pb.DailyRunsCountRequest) (*pb.DailyRunsCountResponse, error)
func (*OrgMetricsService) TopWorkflowsByRunsCount ¶
func (s *OrgMetricsService) TopWorkflowsByRunsCount(ctx context.Context, req *pb.TopWorkflowsByRunsCountRequest) (*pb.TopWorkflowsByRunsCountResponse, error)
func (*OrgMetricsService) Totals ¶
func (s *OrgMetricsService) Totals(ctx context.Context, req *pb.OrgMetricsServiceTotalsRequest) (*pb.OrgMetricsServiceTotalsResponse, error)
type OrganizationService ¶
type OrganizationService struct { pb.UnimplementedOrganizationServiceServer // contains filtered or unexported fields }
func NewOrganizationService ¶
func NewOrganizationService(muc *biz.MembershipUseCase, ouc *biz.OrganizationUseCase, opts ...NewOpt) *OrganizationService
func (*OrganizationService) Create ¶ added in v0.50.0
func (s *OrganizationService) Create(ctx context.Context, req *pb.OrganizationServiceCreateRequest) (*pb.OrganizationServiceCreateResponse, error)
Create persists an organization with a given name and associate it to the current user.
func (*OrganizationService) DeleteMembership ¶ added in v0.50.0
func (s *OrganizationService) DeleteMembership(ctx context.Context, req *pb.OrganizationServiceDeleteMembershipRequest) (*pb.OrganizationServiceDeleteMembershipResponse, error)
func (*OrganizationService) ListMemberships ¶
func (s *OrganizationService) ListMemberships(ctx context.Context, _ *pb.OrganizationServiceListMembershipsRequest) (*pb.OrganizationServiceListMembershipsResponse, error)
func (*OrganizationService) UpdateMembership ¶ added in v0.75.0
func (s *OrganizationService) UpdateMembership(ctx context.Context, req *pb.OrganizationServiceUpdateMembershipRequest) (*pb.OrganizationServiceUpdateMembershipResponse, error)
type PrometheusService ¶ added in v0.94.0
type PrometheusService struct {
// contains filtered or unexported fields
}
PrometheusService is the prometheus service
func NewPrometheusService ¶ added in v0.94.0
func NewPrometheusService(orgUseCase *biz.OrganizationUseCase, prometheusUseCase *biz.PrometheusUseCase, opts ...NewOpt) *PrometheusService
NewPrometheusService creates a new prometheus service
func (*PrometheusService) ServeHTTP ¶ added in v0.94.0
func (p *PrometheusService) ServeHTTP(w http.ResponseWriter, r *http.Request)
MetricsRequestHandler is the handler for the metrics request. It fetches the Prometheus registry and if found, retrieves all metrics in Prometheus format.
type ReferrerService ¶ added in v0.30.0
type ReferrerService struct { pb.UnimplementedReferrerServiceServer // contains filtered or unexported fields }
func NewReferrerService ¶ added in v0.30.0
func NewReferrerService(uc *biz.ReferrerUseCase, opts ...NewOpt) *ReferrerService
func (*ReferrerService) DiscoverPrivate ¶ added in v0.40.0
func (s *ReferrerService) DiscoverPrivate(ctx context.Context, req *pb.ReferrerServiceDiscoverPrivateRequest) (*pb.ReferrerServiceDiscoverPrivateResponse, error)
func (*ReferrerService) DiscoverPublicShared ¶ added in v0.40.0
func (s *ReferrerService) DiscoverPublicShared(ctx context.Context, req *pb.DiscoverPublicSharedRequest) (*pb.DiscoverPublicSharedResponse, error)
type RobotAccountService ¶
type RobotAccountService struct { pb.UnimplementedRobotAccountServiceServer // contains filtered or unexported fields }
func NewRobotAccountService ¶
func NewRobotAccountService(uc *biz.RobotAccountUseCase, opts ...NewOpt) *RobotAccountService
func (*RobotAccountService) Create ¶
func (s *RobotAccountService) Create(ctx context.Context, req *pb.RobotAccountServiceCreateRequest) (*pb.RobotAccountServiceCreateResponse, error)
func (*RobotAccountService) List ¶
func (s *RobotAccountService) List(ctx context.Context, req *pb.RobotAccountServiceListRequest) (*pb.RobotAccountServiceListResponse, error)
func (*RobotAccountService) Revoke ¶
func (s *RobotAccountService) Revoke(ctx context.Context, req *pb.RobotAccountServiceRevokeRequest) (*pb.RobotAccountServiceRevokeResponse, error)
type SigningService ¶ added in v0.90.0
type SigningService struct { v1.UnimplementedSigningServiceServer // contains filtered or unexported fields }
func NewSigningService ¶ added in v0.90.0
func NewSigningService(signing *biz.SigningUseCase, opts ...NewOpt) *SigningService
func (*SigningService) GenerateSigningCert ¶ added in v0.90.0
func (s *SigningService) GenerateSigningCert(ctx context.Context, req *v1.GenerateSigningCertRequest) (*v1.GenerateSigningCertResponse, error)
type StatusService ¶
type StatusService struct { pb.UnimplementedStatusServiceServer // contains filtered or unexported fields }
func NewStatusService ¶
func NewStatusService(logingURL, version string, casClient *biz.CASClientUseCase) *StatusService
func (*StatusService) Infoz ¶
func (s *StatusService) Infoz(_ context.Context, _ *pb.InfozRequest) (*pb.InfozResponse, error)
func (*StatusService) Statusz ¶
func (s *StatusService) Statusz(ctx context.Context, r *pb.StatuszRequest) (*pb.StatuszResponse, error)
Only on readiness probes we check this service external dependencies
type UserService ¶ added in v0.75.0
type UserService struct { pb.UnimplementedUserServiceServer // contains filtered or unexported fields }
func NewUserService ¶ added in v0.75.0
func NewUserService(muc *biz.MembershipUseCase, ouc *biz.OrganizationUseCase, opts ...NewOpt) *UserService
func (*UserService) DeleteMembership ¶ added in v0.75.0
func (s *UserService) DeleteMembership(ctx context.Context, req *pb.DeleteMembershipRequest) (*pb.DeleteMembershipResponse, error)
func (*UserService) ListMemberships ¶ added in v0.75.0
func (s *UserService) ListMemberships(ctx context.Context, _ *pb.UserServiceListMembershipsRequest) (*pb.UserServiceListMembershipsResponse, error)
func (*UserService) SetCurrentMembership ¶ added in v0.75.0
func (s *UserService) SetCurrentMembership(ctx context.Context, req *pb.SetCurrentMembershipRequest) (*pb.SetCurrentMembershipResponse, error)
type WorkflowContractService ¶
type WorkflowContractService struct { pb.UnimplementedWorkflowContractServiceServer // contains filtered or unexported fields }
func NewWorkflowSchemaService ¶
func NewWorkflowSchemaService(uc *biz.WorkflowContractUseCase, opts ...NewOpt) *WorkflowContractService
func (*WorkflowContractService) Create ¶
func (s *WorkflowContractService) Create(ctx context.Context, req *pb.WorkflowContractServiceCreateRequest) (*pb.WorkflowContractServiceCreateResponse, error)
func (*WorkflowContractService) Delete ¶
func (s *WorkflowContractService) Delete(ctx context.Context, req *pb.WorkflowContractServiceDeleteRequest) (*pb.WorkflowContractServiceDeleteResponse, error)
func (*WorkflowContractService) Describe ¶
func (s *WorkflowContractService) Describe(ctx context.Context, req *pb.WorkflowContractServiceDescribeRequest) (*pb.WorkflowContractServiceDescribeResponse, error)
func (*WorkflowContractService) List ¶
func (s *WorkflowContractService) List(ctx context.Context, _ *pb.WorkflowContractServiceListRequest) (*pb.WorkflowContractServiceListResponse, error)
func (*WorkflowContractService) Update ¶
func (s *WorkflowContractService) Update(ctx context.Context, req *pb.WorkflowContractServiceUpdateRequest) (*pb.WorkflowContractServiceUpdateResponse, error)
type WorkflowRunService ¶
type WorkflowRunService struct { pb.UnimplementedWorkflowRunServiceServer // contains filtered or unexported fields }
func NewWorkflowRunService ¶
func NewWorkflowRunService(opts *NewWorkflowRunServiceOpts) *WorkflowRunService
func (*WorkflowRunService) List ¶
func (s *WorkflowRunService) List(ctx context.Context, req *pb.WorkflowRunServiceListRequest) (*pb.WorkflowRunServiceListResponse, error)
func (*WorkflowRunService) View ¶
func (s *WorkflowRunService) View(ctx context.Context, req *pb.WorkflowRunServiceViewRequest) (*pb.WorkflowRunServiceViewResponse, error)
type WorkflowService ¶
type WorkflowService struct { pb.UnimplementedWorkflowServiceServer // contains filtered or unexported fields }
func NewWorkflowService ¶
func NewWorkflowService(uc *biz.WorkflowUseCase, wfuc *biz.WorkflowContractUseCase, opts ...NewOpt) *WorkflowService
func (*WorkflowService) Create ¶
func (s *WorkflowService) Create(ctx context.Context, req *pb.WorkflowServiceCreateRequest) (*pb.WorkflowServiceCreateResponse, error)
func (*WorkflowService) Delete ¶
func (s *WorkflowService) Delete(ctx context.Context, req *pb.WorkflowServiceDeleteRequest) (*pb.WorkflowServiceDeleteResponse, error)
func (*WorkflowService) List ¶
func (s *WorkflowService) List(ctx context.Context, _ *pb.WorkflowServiceListRequest) (*pb.WorkflowServiceListResponse, error)
func (*WorkflowService) Update ¶ added in v0.40.0
func (s *WorkflowService) Update(ctx context.Context, req *pb.WorkflowServiceUpdateRequest) (*pb.WorkflowServiceUpdateResponse, error)
func (*WorkflowService) View ¶ added in v0.80.0
func (s *WorkflowService) View(ctx context.Context, req *pb.WorkflowServiceViewRequest) (*pb.WorkflowServiceViewResponse, error)
Source Files ¶
- apitoken.go
- attestation.go
- attestationstate.go
- auth.go
- casbackend.go
- cascredential.go
- casredirect.go
- context.go
- integration.go
- organization.go
- orginvitation.go
- orgmetric.go
- prometheus.go
- referrer.go
- robotaccount.go
- service.go
- signing.go
- status.go
- user.go
- workflow.go
- workflowcontract.go
- workflowrun.go