service

package
v0.94.3 Latest Latest
Warning

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

 Go to latest Published: Jul 25, 2024 License: Apache-2.0 Imports: 50 Imported by: 0

Documentation

Index

Constants

View Source 
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

View Source 
const (
	// PrometheusMetricsPath is the path for the Prometheus metrics
	PrometheusMetricsPath = "/prom/{org_name}/metrics"
)

Variables

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

func (s *AttestationService) GetContract(ctx context.Context, req *cpAPI.AttestationServiceGetContractRequest) (*cpAPI.AttestationServiceGetContractResponse, 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 AuthURLs 

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

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
	Opts               []NewOpt
}

type NewAttestationStateServiceOpt added in v0.90.0 

type NewAttestationStateServiceOpt struct {
	AttestationStateUseCase *biz.AttestationStateUseCase
	WorkflowUseCase         *biz.WorkflowUseCase
	WorkflowRunUseCase      *biz.WorkflowRunUseCase
	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 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

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.