service

package
v0.11.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 19, 2023 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation

Index

Constants

View Source 
const AuthCallbackPath = "/auth/callback"
View Source 
const AuthLoginPath = "/auth/login"

Variables

View Source 
var ProviderSet = wire.NewSet(
	NewWorkflowService,
	NewAuthService,
	NewRobotAccountService,
	NewWorkflowRunService,
	NewAttestationService,
	NewWorkflowSchemaService,
	NewCASCredentialsService,
	NewOCIRepositoryService,
	NewContextService,
	NewOrgMetricsService,
	NewIntegrationsService,
	NewOrganizationService,
	wire.Struct(new(NewWorkflowRunServiceOpts), "*"),
	wire.Struct(new(NewAttestationServiceOpts), "*"),
)

ProviderSet is service providers.

Functions

This section is empty.

Types

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) GetContract 

func (s *AttestationService) GetContract(ctx context.Context, req *cpAPI.AttestationServiceGetContractRequest) (*cpAPI.AttestationServiceGetContractResponse, error)

func (*AttestationService) GetUploadCreds 

func (s *AttestationService) GetUploadCreds(ctx context.Context, _ *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 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, 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 AuthURLs 

type AuthURLs struct {
	Login string
	// contains filtered or unexported fields
}

type CASCredentialsService 

type CASCredentialsService struct {
	pb.UnimplementedCASCredentialsServiceServer
	// contains filtered or unexported fields
}

func NewCASCredentialsService 

func NewCASCredentialsService(casUC *biz.CASCredentialsUseCase, ociUC *biz.OCIRepositoryUseCase, 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 ContextService 

type ContextService struct {
	pb.UnimplementedContextServiceServer
	// contains filtered or unexported fields
}

func NewContextService 

func NewContextService(repoUC *biz.OCIRepositoryUseCase, 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.AvailableExtensions, 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.OCIRepositoryUseCase
	CredsReader        credentials.Reader
	IntegrationUseCase *biz.IntegrationUseCase
	CasCredsUseCase    *biz.CASCredentialsUseCase
	FanoutDispatcher   *dispatcher.FanOutDispatcher
	Opts               []NewOpt
}

type NewOpt 

type NewOpt func(s *service)

func WithLogger 

func WithLogger(logger log.Logger) NewOpt

type NewWorkflowRunServiceOpts 

type NewWorkflowRunServiceOpts struct {
	WorkflowRunUC      *biz.WorkflowRunUseCase
	WorkflowUC         *biz.WorkflowUseCase
	WorkflowContractUC *biz.WorkflowContractUseCase
	CredsReader        credentials.Reader
	Opts               []NewOpt
}

type OCIRepositoryService 

type OCIRepositoryService struct {
	pb.UnimplementedOCIRepositoryServiceServer
	// contains filtered or unexported fields
}

func NewOCIRepositoryService 

func NewOCIRepositoryService(uc *biz.OCIRepositoryUseCase, opts ...NewOpt) *OCIRepositoryService

func (*OCIRepositoryService) Save 

func (s *OCIRepositoryService) Save(ctx context.Context, req *pb.OCIRepositoryServiceSaveRequest) (*pb.OCIRepositoryServiceSaveResponse, 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) 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(uc *biz.MembershipUseCase, opts ...NewOpt) *OrganizationService

func (*OrganizationService) ListMemberships 

func (s *OrganizationService) ListMemberships(ctx context.Context, _ *pb.OrganizationServiceListMembershipsRequest) (*pb.OrganizationServiceListMembershipsResponse, error)

func (*OrganizationService) SetCurrentMembership 

func (s *OrganizationService) SetCurrentMembership(ctx context.Context, req *pb.SetCurrentMembershipRequest) (*pb.SetCurrentMembershipResponse, 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 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 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, 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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.