Versions in this module Expand all Collapse all v1 v1.0.1 Aug 15, 2024 Changes in this version + type CronMock struct + func (c CronMock) CronCreate(ctx context.Context, request *cronpb.CronCreateRequest) (*cronpb.CronCreateResponse, error) + func (c CronMock) CronDelete(ctx context.Context, request *cronpb.CronDeleteRequest) (*cronpb.CronDeleteResponse, error) + func (c CronMock) CronGet(ctx context.Context, request *cronpb.CronGetRequest) (*cronpb.CronGetResponse, error) + func (c CronMock) CronPaging(ctx context.Context, request *cronpb.CronPagingRequest) (*cronpb.CronPagingResponse, error) + func (c CronMock) CronStart(ctx context.Context, request *cronpb.CronStartRequest) (*cronpb.CronStartResponse, error) + func (c CronMock) CronStop(ctx context.Context, request *cronpb.CronStopRequest) (*cronpb.CronStopResponse, error) + func (c CronMock) CronUpdate(ctx context.Context, request *cronpb.CronUpdateRequest) (*cronpb.CronUpdateResponse, error) + type DefinitionMock struct + func (d DefinitionMock) Create(ctx context.Context, request *pb.PipelineDefinitionCreateRequest) (*pb.PipelineDefinitionCreateResponse, error) + func (d DefinitionMock) Delete(ctx context.Context, request *pb.PipelineDefinitionDeleteRequest) (*pb.PipelineDefinitionDeleteResponse, error) + func (d DefinitionMock) DeleteByRemote(ctx context.Context, request *pb.PipelineDefinitionDeleteByRemoteRequest) (*pb.PipelineDefinitionDeleteResponse, error) + func (d DefinitionMock) Get(ctx context.Context, request *pb.PipelineDefinitionGetRequest) (*pb.PipelineDefinitionGetResponse, error) + func (d DefinitionMock) List(ctx context.Context, request *pb.PipelineDefinitionListRequest) (*pb.PipelineDefinitionListResponse, error) + func (d DefinitionMock) ListByRemote(ctx context.Context, request *pb.PipelineDefinitionListByRemoteRequest) (*pb.PipelineDefinitionListResponse, error) + func (d DefinitionMock) ListUsedRefs(ctx context.Context, request *pb.PipelineDefinitionUsedRefListRequest) (*pb.PipelineDefinitionUsedRefListResponse, error) + func (d DefinitionMock) StatisticsGroupByFilePath(ctx context.Context, request *pb.PipelineDefinitionStatisticsRequest) (*pb.PipelineDefinitionStatisticsResponse, error) + func (d DefinitionMock) StatisticsGroupByRemote(ctx context.Context, request *pb.PipelineDefinitionStatisticsRequest) (*pb.PipelineDefinitionStatisticsResponse, error) + func (d DefinitionMock) Update(ctx context.Context, request *pb.PipelineDefinitionUpdateRequest) (*pb.PipelineDefinitionUpdateResponse, error) + func (d DefinitionMock) UpdateExtra(ctx context.Context, request *pb.PipelineDefinitionExtraUpdateRequest) (*pb.PipelineDefinitionExtraUpdateResponse, error) + type MockHTTPResponseWriter struct + Bytes *bytes.Buffer + MockHeader http.Header + Status int + func NewMockHTTPResponseWriter() *MockHTTPResponseWriter + func (rw *MockHTTPResponseWriter) Header() http.Header + func (rw *MockHTTPResponseWriter) Write(byts []byte) (int, error) + func (rw *MockHTTPResponseWriter) WriteHeader(statusCode int) + type OrgMock struct + func (m OrgMock) ChangeCurrentOrg(ctx context.Context, request *orgpb.ChangeCurrentOrgRequest) (*orgpb.ChangeCurrentOrgResponse, error) + func (m OrgMock) CreateOrg(ctx context.Context, request *orgpb.CreateOrgRequest) (*orgpb.CreateOrgResponse, error) + func (m OrgMock) CreateOrgClusterRelation(ctx context.Context, request *orgpb.OrgClusterRelationCreateRequest) (*orgpb.OrgClusterRelationCreateResponse, error) + func (m OrgMock) DeleteOrg(ctx context.Context, request *orgpb.DeleteOrgRequest) (*orgpb.DeleteOrgResponse, error) + func (m OrgMock) DereferenceCluster(ctx context.Context, request *orgpb.DereferenceClusterRequest) (*orgpb.DereferenceClusterResponse, error) + func (m OrgMock) GenVerifyCode(ctx context.Context, request *orgpb.GenVerifyCodeRequest) (*orgpb.GenVerifyCodeResponse, error) + func (m OrgMock) GetNotifyConfig(ctx context.Context, request *orgpb.GetNotifyConfigRequest) (*orgpb.GetNotifyConfigResponse, error) + func (m OrgMock) GetOrg(ctx context.Context, request *orgpb.GetOrgRequest) (*orgpb.GetOrgResponse, error) + func (m OrgMock) GetOrgByDomain(ctx context.Context, request *orgpb.GetOrgByDomainRequest) (*orgpb.GetOrgByDomainResponse, error) + func (m OrgMock) GetOrgClusterRelationsByOrg(ctx context.Context, request *orgpb.GetOrgClusterRelationsByOrgRequest) (*orgpb.GetOrgClusterRelationsByOrgResponse, error) + func (m OrgMock) ListOrg(ctx context.Context, request *orgpb.ListOrgRequest) (*orgpb.ListOrgResponse, error) + func (m OrgMock) ListOrgClusterRelation(ctx context.Context, request *orgpb.ListOrgClusterRelationRequest) (*orgpb.ListOrgClusterRelationResponse, error) + func (m OrgMock) ListOrgs(ctx context.Context, orgIDs []int64, req *orgpb.ListOrgRequest, all bool) (int, []*orgpb.Org, error) + func (m OrgMock) ListPublicOrg(ctx context.Context, request *orgpb.ListOrgRequest) (*orgpb.ListOrgResponse, error) + func (m OrgMock) SetNotifyConfig(ctx context.Context, request *orgpb.SetNotifyConfigRequest) (*orgpb.SetNotifyConfigResponse, error) + func (m OrgMock) SetReleaseCrossCluster(ctx context.Context, request *orgpb.SetReleaseCrossClusterRequest) (*orgpb.SetReleaseCrossClusterResponse, error) + func (m OrgMock) UpdateOrg(ctx context.Context, request *orgpb.UpdateOrgRequest) (*orgpb.UpdateOrgResponse, error) + func (m OrgMock) WithMember(member *member.Member) + func (m OrgMock) WithPermission(permission *permission.Permission) + func (m OrgMock) WithUc(uc userpb.UserServiceServer)
Go to main page