mocks

package
v1.13.0-rc0 Latest Latest
Warning

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

 Go to latest Published: Jun 26, 2024 License: Apache-2.0 Imports: 7 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AdminServiceClient 

type AdminServiceClient struct {
	mock.Mock
}

AdminServiceClient is an autogenerated mock type for the AdminServiceClient type

func (*AdminServiceClient) CreateExecution 

func (_m *AdminServiceClient) CreateExecution(ctx context.Context, in *admin.ExecutionCreateRequest, opts ...grpc.CallOption) (*admin.ExecutionCreateResponse, error)

CreateExecution provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) CreateLaunchPlan 

func (_m *AdminServiceClient) CreateLaunchPlan(ctx context.Context, in *admin.LaunchPlanCreateRequest, opts ...grpc.CallOption) (*admin.LaunchPlanCreateResponse, error)

CreateLaunchPlan provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) CreateNodeEvent 

func (_m *AdminServiceClient) CreateNodeEvent(ctx context.Context, in *admin.NodeExecutionEventRequest, opts ...grpc.CallOption) (*admin.NodeExecutionEventResponse, error)

CreateNodeEvent provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) CreateTask 

func (_m *AdminServiceClient) CreateTask(ctx context.Context, in *admin.TaskCreateRequest, opts ...grpc.CallOption) (*admin.TaskCreateResponse, error)

CreateTask provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) CreateTaskEvent 

func (_m *AdminServiceClient) CreateTaskEvent(ctx context.Context, in *admin.TaskExecutionEventRequest, opts ...grpc.CallOption) (*admin.TaskExecutionEventResponse, error)

CreateTaskEvent provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) CreateWorkflow 

func (_m *AdminServiceClient) CreateWorkflow(ctx context.Context, in *admin.WorkflowCreateRequest, opts ...grpc.CallOption) (*admin.WorkflowCreateResponse, error)

CreateWorkflow provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) CreateWorkflowEvent 

func (_m *AdminServiceClient) CreateWorkflowEvent(ctx context.Context, in *admin.WorkflowExecutionEventRequest, opts ...grpc.CallOption) (*admin.WorkflowExecutionEventResponse, error)

CreateWorkflowEvent provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) DeleteProjectAttributes 

func (_m *AdminServiceClient) DeleteProjectAttributes(ctx context.Context, in *admin.ProjectAttributesDeleteRequest, opts ...grpc.CallOption) (*admin.ProjectAttributesDeleteResponse, error)

DeleteProjectAttributes provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) DeleteProjectDomainAttributes 

func (_m *AdminServiceClient) DeleteProjectDomainAttributes(ctx context.Context, in *admin.ProjectDomainAttributesDeleteRequest, opts ...grpc.CallOption) (*admin.ProjectDomainAttributesDeleteResponse, error)

DeleteProjectDomainAttributes provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) DeleteWorkflowAttributes 

func (_m *AdminServiceClient) DeleteWorkflowAttributes(ctx context.Context, in *admin.WorkflowAttributesDeleteRequest, opts ...grpc.CallOption) (*admin.WorkflowAttributesDeleteResponse, error)

DeleteWorkflowAttributes provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) GetActiveLaunchPlan 

func (_m *AdminServiceClient) GetActiveLaunchPlan(ctx context.Context, in *admin.ActiveLaunchPlanRequest, opts ...grpc.CallOption) (*admin.LaunchPlan, error)

GetActiveLaunchPlan provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) GetDescriptionEntity 

func (_m *AdminServiceClient) GetDescriptionEntity(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) (*admin.DescriptionEntity, error)

GetDescriptionEntity provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) GetDomains added in v1.13.0 

func (_m *AdminServiceClient) GetDomains(ctx context.Context, in *admin.GetDomainRequest, opts ...grpc.CallOption) (*admin.GetDomainsResponse, error)

GetDomains provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) GetDynamicNodeWorkflow added in v1.10.7 

func (_m *AdminServiceClient) GetDynamicNodeWorkflow(ctx context.Context, in *admin.GetDynamicNodeWorkflowRequest, opts ...grpc.CallOption) (*admin.DynamicNodeWorkflowResponse, error)

GetDynamicNodeWorkflow provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) GetExecution 

func (_m *AdminServiceClient) GetExecution(ctx context.Context, in *admin.WorkflowExecutionGetRequest, opts ...grpc.CallOption) (*admin.Execution, error)

GetExecution provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) GetExecutionData 

func (_m *AdminServiceClient) GetExecutionData(ctx context.Context, in *admin.WorkflowExecutionGetDataRequest, opts ...grpc.CallOption) (*admin.WorkflowExecutionGetDataResponse, error)

GetExecutionData provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) GetExecutionMetrics 

func (_m *AdminServiceClient) GetExecutionMetrics(ctx context.Context, in *admin.WorkflowExecutionGetMetricsRequest, opts ...grpc.CallOption) (*admin.WorkflowExecutionGetMetricsResponse, error)

GetExecutionMetrics provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) GetLaunchPlan 

func (_m *AdminServiceClient) GetLaunchPlan(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) (*admin.LaunchPlan, error)

GetLaunchPlan provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) GetNamedEntity 

func (_m *AdminServiceClient) GetNamedEntity(ctx context.Context, in *admin.NamedEntityGetRequest, opts ...grpc.CallOption) (*admin.NamedEntity, error)

GetNamedEntity provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) GetNodeExecution 

func (_m *AdminServiceClient) GetNodeExecution(ctx context.Context, in *admin.NodeExecutionGetRequest, opts ...grpc.CallOption) (*admin.NodeExecution, error)

GetNodeExecution provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) GetNodeExecutionData 

func (_m *AdminServiceClient) GetNodeExecutionData(ctx context.Context, in *admin.NodeExecutionGetDataRequest, opts ...grpc.CallOption) (*admin.NodeExecutionGetDataResponse, error)

GetNodeExecutionData provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) GetProject added in v1.12.0 

func (_m *AdminServiceClient) GetProject(ctx context.Context, in *admin.ProjectGetRequest, opts ...grpc.CallOption) (*admin.Project, error)

GetProject provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) GetProjectAttributes 

func (_m *AdminServiceClient) GetProjectAttributes(ctx context.Context, in *admin.ProjectAttributesGetRequest, opts ...grpc.CallOption) (*admin.ProjectAttributesGetResponse, error)

GetProjectAttributes provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) GetProjectDomainAttributes 

func (_m *AdminServiceClient) GetProjectDomainAttributes(ctx context.Context, in *admin.ProjectDomainAttributesGetRequest, opts ...grpc.CallOption) (*admin.ProjectDomainAttributesGetResponse, error)

GetProjectDomainAttributes provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) GetTask 

func (_m *AdminServiceClient) GetTask(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) (*admin.Task, error)

GetTask provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) GetTaskExecution 

func (_m *AdminServiceClient) GetTaskExecution(ctx context.Context, in *admin.TaskExecutionGetRequest, opts ...grpc.CallOption) (*admin.TaskExecution, error)

GetTaskExecution provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) GetTaskExecutionData 

func (_m *AdminServiceClient) GetTaskExecutionData(ctx context.Context, in *admin.TaskExecutionGetDataRequest, opts ...grpc.CallOption) (*admin.TaskExecutionGetDataResponse, error)

GetTaskExecutionData provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) GetVersion 

func (_m *AdminServiceClient) GetVersion(ctx context.Context, in *admin.GetVersionRequest, opts ...grpc.CallOption) (*admin.GetVersionResponse, error)

GetVersion provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) GetWorkflow 

func (_m *AdminServiceClient) GetWorkflow(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) (*admin.Workflow, error)

GetWorkflow provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) GetWorkflowAttributes 

func (_m *AdminServiceClient) GetWorkflowAttributes(ctx context.Context, in *admin.WorkflowAttributesGetRequest, opts ...grpc.CallOption) (*admin.WorkflowAttributesGetResponse, error)

GetWorkflowAttributes provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) ListActiveLaunchPlans 

func (_m *AdminServiceClient) ListActiveLaunchPlans(ctx context.Context, in *admin.ActiveLaunchPlanListRequest, opts ...grpc.CallOption) (*admin.LaunchPlanList, error)

ListActiveLaunchPlans provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) ListDescriptionEntities 

func (_m *AdminServiceClient) ListDescriptionEntities(ctx context.Context, in *admin.DescriptionEntityListRequest, opts ...grpc.CallOption) (*admin.DescriptionEntityList, error)

ListDescriptionEntities provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) ListExecutions 

func (_m *AdminServiceClient) ListExecutions(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) (*admin.ExecutionList, error)

ListExecutions provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) ListLaunchPlanIds 

func (_m *AdminServiceClient) ListLaunchPlanIds(ctx context.Context, in *admin.NamedEntityIdentifierListRequest, opts ...grpc.CallOption) (*admin.NamedEntityIdentifierList, error)

ListLaunchPlanIds provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) ListLaunchPlans 

func (_m *AdminServiceClient) ListLaunchPlans(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) (*admin.LaunchPlanList, error)

ListLaunchPlans provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) ListMatchableAttributes 

func (_m *AdminServiceClient) ListMatchableAttributes(ctx context.Context, in *admin.ListMatchableAttributesRequest, opts ...grpc.CallOption) (*admin.ListMatchableAttributesResponse, error)

ListMatchableAttributes provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) ListNamedEntities 

func (_m *AdminServiceClient) ListNamedEntities(ctx context.Context, in *admin.NamedEntityListRequest, opts ...grpc.CallOption) (*admin.NamedEntityList, error)

ListNamedEntities provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) ListNodeExecutions 

func (_m *AdminServiceClient) ListNodeExecutions(ctx context.Context, in *admin.NodeExecutionListRequest, opts ...grpc.CallOption) (*admin.NodeExecutionList, error)

ListNodeExecutions provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) ListNodeExecutionsForTask 

func (_m *AdminServiceClient) ListNodeExecutionsForTask(ctx context.Context, in *admin.NodeExecutionForTaskListRequest, opts ...grpc.CallOption) (*admin.NodeExecutionList, error)

ListNodeExecutionsForTask provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) ListProjects 

func (_m *AdminServiceClient) ListProjects(ctx context.Context, in *admin.ProjectListRequest, opts ...grpc.CallOption) (*admin.Projects, error)

ListProjects provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) ListTaskExecutions 

func (_m *AdminServiceClient) ListTaskExecutions(ctx context.Context, in *admin.TaskExecutionListRequest, opts ...grpc.CallOption) (*admin.TaskExecutionList, error)

ListTaskExecutions provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) ListTaskIds 

func (_m *AdminServiceClient) ListTaskIds(ctx context.Context, in *admin.NamedEntityIdentifierListRequest, opts ...grpc.CallOption) (*admin.NamedEntityIdentifierList, error)

ListTaskIds provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) ListTasks 

func (_m *AdminServiceClient) ListTasks(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) (*admin.TaskList, error)

ListTasks provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) ListWorkflowIds 

func (_m *AdminServiceClient) ListWorkflowIds(ctx context.Context, in *admin.NamedEntityIdentifierListRequest, opts ...grpc.CallOption) (*admin.NamedEntityIdentifierList, error)

ListWorkflowIds provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) ListWorkflows 

func (_m *AdminServiceClient) ListWorkflows(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) (*admin.WorkflowList, error)

ListWorkflows provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) OnCreateExecution 

func (_m *AdminServiceClient) OnCreateExecution(ctx context.Context, in *admin.ExecutionCreateRequest, opts ...grpc.CallOption) *AdminServiceClient_CreateExecution

func (*AdminServiceClient) OnCreateExecutionMatch 

func (_m *AdminServiceClient) OnCreateExecutionMatch(matchers ...interface{}) *AdminServiceClient_CreateExecution

func (*AdminServiceClient) OnCreateLaunchPlan 

func (_m *AdminServiceClient) OnCreateLaunchPlan(ctx context.Context, in *admin.LaunchPlanCreateRequest, opts ...grpc.CallOption) *AdminServiceClient_CreateLaunchPlan

func (*AdminServiceClient) OnCreateLaunchPlanMatch 

func (_m *AdminServiceClient) OnCreateLaunchPlanMatch(matchers ...interface{}) *AdminServiceClient_CreateLaunchPlan

func (*AdminServiceClient) OnCreateNodeEvent 

func (_m *AdminServiceClient) OnCreateNodeEvent(ctx context.Context, in *admin.NodeExecutionEventRequest, opts ...grpc.CallOption) *AdminServiceClient_CreateNodeEvent

func (*AdminServiceClient) OnCreateNodeEventMatch 

func (_m *AdminServiceClient) OnCreateNodeEventMatch(matchers ...interface{}) *AdminServiceClient_CreateNodeEvent

func (*AdminServiceClient) OnCreateTask 

func (_m *AdminServiceClient) OnCreateTask(ctx context.Context, in *admin.TaskCreateRequest, opts ...grpc.CallOption) *AdminServiceClient_CreateTask

func (*AdminServiceClient) OnCreateTaskEvent 

func (_m *AdminServiceClient) OnCreateTaskEvent(ctx context.Context, in *admin.TaskExecutionEventRequest, opts ...grpc.CallOption) *AdminServiceClient_CreateTaskEvent

func (*AdminServiceClient) OnCreateTaskEventMatch 

func (_m *AdminServiceClient) OnCreateTaskEventMatch(matchers ...interface{}) *AdminServiceClient_CreateTaskEvent

func (*AdminServiceClient) OnCreateTaskMatch 

func (_m *AdminServiceClient) OnCreateTaskMatch(matchers ...interface{}) *AdminServiceClient_CreateTask

func (*AdminServiceClient) OnCreateWorkflow 

func (_m *AdminServiceClient) OnCreateWorkflow(ctx context.Context, in *admin.WorkflowCreateRequest, opts ...grpc.CallOption) *AdminServiceClient_CreateWorkflow

func (*AdminServiceClient) OnCreateWorkflowEvent 

func (_m *AdminServiceClient) OnCreateWorkflowEvent(ctx context.Context, in *admin.WorkflowExecutionEventRequest, opts ...grpc.CallOption) *AdminServiceClient_CreateWorkflowEvent

func (*AdminServiceClient) OnCreateWorkflowEventMatch 

func (_m *AdminServiceClient) OnCreateWorkflowEventMatch(matchers ...interface{}) *AdminServiceClient_CreateWorkflowEvent

func (*AdminServiceClient) OnCreateWorkflowMatch 

func (_m *AdminServiceClient) OnCreateWorkflowMatch(matchers ...interface{}) *AdminServiceClient_CreateWorkflow

func (*AdminServiceClient) OnDeleteProjectAttributes 

func (_m *AdminServiceClient) OnDeleteProjectAttributes(ctx context.Context, in *admin.ProjectAttributesDeleteRequest, opts ...grpc.CallOption) *AdminServiceClient_DeleteProjectAttributes

func (*AdminServiceClient) OnDeleteProjectAttributesMatch 

func (_m *AdminServiceClient) OnDeleteProjectAttributesMatch(matchers ...interface{}) *AdminServiceClient_DeleteProjectAttributes

func (*AdminServiceClient) OnDeleteProjectDomainAttributes 

func (_m *AdminServiceClient) OnDeleteProjectDomainAttributes(ctx context.Context, in *admin.ProjectDomainAttributesDeleteRequest, opts ...grpc.CallOption) *AdminServiceClient_DeleteProjectDomainAttributes

func (*AdminServiceClient) OnDeleteProjectDomainAttributesMatch 

func (_m *AdminServiceClient) OnDeleteProjectDomainAttributesMatch(matchers ...interface{}) *AdminServiceClient_DeleteProjectDomainAttributes

func (*AdminServiceClient) OnDeleteWorkflowAttributes 

func (_m *AdminServiceClient) OnDeleteWorkflowAttributes(ctx context.Context, in *admin.WorkflowAttributesDeleteRequest, opts ...grpc.CallOption) *AdminServiceClient_DeleteWorkflowAttributes

func (*AdminServiceClient) OnDeleteWorkflowAttributesMatch 

func (_m *AdminServiceClient) OnDeleteWorkflowAttributesMatch(matchers ...interface{}) *AdminServiceClient_DeleteWorkflowAttributes

func (*AdminServiceClient) OnGetActiveLaunchPlan 

func (_m *AdminServiceClient) OnGetActiveLaunchPlan(ctx context.Context, in *admin.ActiveLaunchPlanRequest, opts ...grpc.CallOption) *AdminServiceClient_GetActiveLaunchPlan

func (*AdminServiceClient) OnGetActiveLaunchPlanMatch 

func (_m *AdminServiceClient) OnGetActiveLaunchPlanMatch(matchers ...interface{}) *AdminServiceClient_GetActiveLaunchPlan

func (*AdminServiceClient) OnGetDescriptionEntity 

func (_m *AdminServiceClient) OnGetDescriptionEntity(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) *AdminServiceClient_GetDescriptionEntity

func (*AdminServiceClient) OnGetDescriptionEntityMatch 

func (_m *AdminServiceClient) OnGetDescriptionEntityMatch(matchers ...interface{}) *AdminServiceClient_GetDescriptionEntity

func (*AdminServiceClient) OnGetDomains added in v1.13.0 

func (_m *AdminServiceClient) OnGetDomains(ctx context.Context, in *admin.GetDomainRequest, opts ...grpc.CallOption) *AdminServiceClient_GetDomains

func (*AdminServiceClient) OnGetDomainsMatch added in v1.13.0 

func (_m *AdminServiceClient) OnGetDomainsMatch(matchers ...interface{}) *AdminServiceClient_GetDomains

func (*AdminServiceClient) OnGetDynamicNodeWorkflow added in v1.10.7 

func (_m *AdminServiceClient) OnGetDynamicNodeWorkflow(ctx context.Context, in *admin.GetDynamicNodeWorkflowRequest, opts ...grpc.CallOption) *AdminServiceClient_GetDynamicNodeWorkflow

func (*AdminServiceClient) OnGetDynamicNodeWorkflowMatch added in v1.10.7 

func (_m *AdminServiceClient) OnGetDynamicNodeWorkflowMatch(matchers ...interface{}) *AdminServiceClient_GetDynamicNodeWorkflow

func (*AdminServiceClient) OnGetExecution 

func (_m *AdminServiceClient) OnGetExecution(ctx context.Context, in *admin.WorkflowExecutionGetRequest, opts ...grpc.CallOption) *AdminServiceClient_GetExecution

func (*AdminServiceClient) OnGetExecutionData 

func (_m *AdminServiceClient) OnGetExecutionData(ctx context.Context, in *admin.WorkflowExecutionGetDataRequest, opts ...grpc.CallOption) *AdminServiceClient_GetExecutionData

func (*AdminServiceClient) OnGetExecutionDataMatch 

func (_m *AdminServiceClient) OnGetExecutionDataMatch(matchers ...interface{}) *AdminServiceClient_GetExecutionData

func (*AdminServiceClient) OnGetExecutionMatch 

func (_m *AdminServiceClient) OnGetExecutionMatch(matchers ...interface{}) *AdminServiceClient_GetExecution

func (*AdminServiceClient) OnGetExecutionMetrics 

func (_m *AdminServiceClient) OnGetExecutionMetrics(ctx context.Context, in *admin.WorkflowExecutionGetMetricsRequest, opts ...grpc.CallOption) *AdminServiceClient_GetExecutionMetrics

func (*AdminServiceClient) OnGetExecutionMetricsMatch 

func (_m *AdminServiceClient) OnGetExecutionMetricsMatch(matchers ...interface{}) *AdminServiceClient_GetExecutionMetrics

func (*AdminServiceClient) OnGetLaunchPlan 

func (_m *AdminServiceClient) OnGetLaunchPlan(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) *AdminServiceClient_GetLaunchPlan

func (*AdminServiceClient) OnGetLaunchPlanMatch 

func (_m *AdminServiceClient) OnGetLaunchPlanMatch(matchers ...interface{}) *AdminServiceClient_GetLaunchPlan

func (*AdminServiceClient) OnGetNamedEntity 

func (_m *AdminServiceClient) OnGetNamedEntity(ctx context.Context, in *admin.NamedEntityGetRequest, opts ...grpc.CallOption) *AdminServiceClient_GetNamedEntity

func (*AdminServiceClient) OnGetNamedEntityMatch 

func (_m *AdminServiceClient) OnGetNamedEntityMatch(matchers ...interface{}) *AdminServiceClient_GetNamedEntity

func (*AdminServiceClient) OnGetNodeExecution 

func (_m *AdminServiceClient) OnGetNodeExecution(ctx context.Context, in *admin.NodeExecutionGetRequest, opts ...grpc.CallOption) *AdminServiceClient_GetNodeExecution

func (*AdminServiceClient) OnGetNodeExecutionData 

func (_m *AdminServiceClient) OnGetNodeExecutionData(ctx context.Context, in *admin.NodeExecutionGetDataRequest, opts ...grpc.CallOption) *AdminServiceClient_GetNodeExecutionData

func (*AdminServiceClient) OnGetNodeExecutionDataMatch 

func (_m *AdminServiceClient) OnGetNodeExecutionDataMatch(matchers ...interface{}) *AdminServiceClient_GetNodeExecutionData

func (*AdminServiceClient) OnGetNodeExecutionMatch 

func (_m *AdminServiceClient) OnGetNodeExecutionMatch(matchers ...interface{}) *AdminServiceClient_GetNodeExecution

func (*AdminServiceClient) OnGetProject added in v1.12.0 

func (_m *AdminServiceClient) OnGetProject(ctx context.Context, in *admin.ProjectGetRequest, opts ...grpc.CallOption) *AdminServiceClient_GetProject

func (*AdminServiceClient) OnGetProjectAttributes 

func (_m *AdminServiceClient) OnGetProjectAttributes(ctx context.Context, in *admin.ProjectAttributesGetRequest, opts ...grpc.CallOption) *AdminServiceClient_GetProjectAttributes

func (*AdminServiceClient) OnGetProjectAttributesMatch 

func (_m *AdminServiceClient) OnGetProjectAttributesMatch(matchers ...interface{}) *AdminServiceClient_GetProjectAttributes

func (*AdminServiceClient) OnGetProjectDomainAttributes 

func (_m *AdminServiceClient) OnGetProjectDomainAttributes(ctx context.Context, in *admin.ProjectDomainAttributesGetRequest, opts ...grpc.CallOption) *AdminServiceClient_GetProjectDomainAttributes

func (*AdminServiceClient) OnGetProjectDomainAttributesMatch 

func (_m *AdminServiceClient) OnGetProjectDomainAttributesMatch(matchers ...interface{}) *AdminServiceClient_GetProjectDomainAttributes

func (*AdminServiceClient) OnGetProjectMatch added in v1.12.0 

func (_m *AdminServiceClient) OnGetProjectMatch(matchers ...interface{}) *AdminServiceClient_GetProject

func (*AdminServiceClient) OnGetTask 

func (_m *AdminServiceClient) OnGetTask(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) *AdminServiceClient_GetTask

func (*AdminServiceClient) OnGetTaskExecution 

func (_m *AdminServiceClient) OnGetTaskExecution(ctx context.Context, in *admin.TaskExecutionGetRequest, opts ...grpc.CallOption) *AdminServiceClient_GetTaskExecution

func (*AdminServiceClient) OnGetTaskExecutionData 

func (_m *AdminServiceClient) OnGetTaskExecutionData(ctx context.Context, in *admin.TaskExecutionGetDataRequest, opts ...grpc.CallOption) *AdminServiceClient_GetTaskExecutionData

func (*AdminServiceClient) OnGetTaskExecutionDataMatch 

func (_m *AdminServiceClient) OnGetTaskExecutionDataMatch(matchers ...interface{}) *AdminServiceClient_GetTaskExecutionData

func (*AdminServiceClient) OnGetTaskExecutionMatch 

func (_m *AdminServiceClient) OnGetTaskExecutionMatch(matchers ...interface{}) *AdminServiceClient_GetTaskExecution

func (*AdminServiceClient) OnGetTaskMatch 

func (_m *AdminServiceClient) OnGetTaskMatch(matchers ...interface{}) *AdminServiceClient_GetTask

func (*AdminServiceClient) OnGetVersion 

func (_m *AdminServiceClient) OnGetVersion(ctx context.Context, in *admin.GetVersionRequest, opts ...grpc.CallOption) *AdminServiceClient_GetVersion

func (*AdminServiceClient) OnGetVersionMatch 

func (_m *AdminServiceClient) OnGetVersionMatch(matchers ...interface{}) *AdminServiceClient_GetVersion

func (*AdminServiceClient) OnGetWorkflow 

func (_m *AdminServiceClient) OnGetWorkflow(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) *AdminServiceClient_GetWorkflow

func (*AdminServiceClient) OnGetWorkflowAttributes 

func (_m *AdminServiceClient) OnGetWorkflowAttributes(ctx context.Context, in *admin.WorkflowAttributesGetRequest, opts ...grpc.CallOption) *AdminServiceClient_GetWorkflowAttributes

func (*AdminServiceClient) OnGetWorkflowAttributesMatch 

func (_m *AdminServiceClient) OnGetWorkflowAttributesMatch(matchers ...interface{}) *AdminServiceClient_GetWorkflowAttributes

func (*AdminServiceClient) OnGetWorkflowMatch 

func (_m *AdminServiceClient) OnGetWorkflowMatch(matchers ...interface{}) *AdminServiceClient_GetWorkflow

func (*AdminServiceClient) OnListActiveLaunchPlans 

func (_m *AdminServiceClient) OnListActiveLaunchPlans(ctx context.Context, in *admin.ActiveLaunchPlanListRequest, opts ...grpc.CallOption) *AdminServiceClient_ListActiveLaunchPlans

func (*AdminServiceClient) OnListActiveLaunchPlansMatch 

func (_m *AdminServiceClient) OnListActiveLaunchPlansMatch(matchers ...interface{}) *AdminServiceClient_ListActiveLaunchPlans

func (*AdminServiceClient) OnListDescriptionEntities 

func (_m *AdminServiceClient) OnListDescriptionEntities(ctx context.Context, in *admin.DescriptionEntityListRequest, opts ...grpc.CallOption) *AdminServiceClient_ListDescriptionEntities

func (*AdminServiceClient) OnListDescriptionEntitiesMatch 

func (_m *AdminServiceClient) OnListDescriptionEntitiesMatch(matchers ...interface{}) *AdminServiceClient_ListDescriptionEntities

func (*AdminServiceClient) OnListExecutions 

func (_m *AdminServiceClient) OnListExecutions(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) *AdminServiceClient_ListExecutions

func (*AdminServiceClient) OnListExecutionsMatch 

func (_m *AdminServiceClient) OnListExecutionsMatch(matchers ...interface{}) *AdminServiceClient_ListExecutions

func (*AdminServiceClient) OnListLaunchPlanIds 

func (_m *AdminServiceClient) OnListLaunchPlanIds(ctx context.Context, in *admin.NamedEntityIdentifierListRequest, opts ...grpc.CallOption) *AdminServiceClient_ListLaunchPlanIds

func (*AdminServiceClient) OnListLaunchPlanIdsMatch 

func (_m *AdminServiceClient) OnListLaunchPlanIdsMatch(matchers ...interface{}) *AdminServiceClient_ListLaunchPlanIds

func (*AdminServiceClient) OnListLaunchPlans 

func (_m *AdminServiceClient) OnListLaunchPlans(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) *AdminServiceClient_ListLaunchPlans

func (*AdminServiceClient) OnListLaunchPlansMatch 

func (_m *AdminServiceClient) OnListLaunchPlansMatch(matchers ...interface{}) *AdminServiceClient_ListLaunchPlans

func (*AdminServiceClient) OnListMatchableAttributes 

func (_m *AdminServiceClient) OnListMatchableAttributes(ctx context.Context, in *admin.ListMatchableAttributesRequest, opts ...grpc.CallOption) *AdminServiceClient_ListMatchableAttributes

func (*AdminServiceClient) OnListMatchableAttributesMatch 

func (_m *AdminServiceClient) OnListMatchableAttributesMatch(matchers ...interface{}) *AdminServiceClient_ListMatchableAttributes

func (*AdminServiceClient) OnListNamedEntities 

func (_m *AdminServiceClient) OnListNamedEntities(ctx context.Context, in *admin.NamedEntityListRequest, opts ...grpc.CallOption) *AdminServiceClient_ListNamedEntities

func (*AdminServiceClient) OnListNamedEntitiesMatch 

func (_m *AdminServiceClient) OnListNamedEntitiesMatch(matchers ...interface{}) *AdminServiceClient_ListNamedEntities

func (*AdminServiceClient) OnListNodeExecutions 

func (_m *AdminServiceClient) OnListNodeExecutions(ctx context.Context, in *admin.NodeExecutionListRequest, opts ...grpc.CallOption) *AdminServiceClient_ListNodeExecutions

func (*AdminServiceClient) OnListNodeExecutionsForTask 

func (_m *AdminServiceClient) OnListNodeExecutionsForTask(ctx context.Context, in *admin.NodeExecutionForTaskListRequest, opts ...grpc.CallOption) *AdminServiceClient_ListNodeExecutionsForTask

func (*AdminServiceClient) OnListNodeExecutionsForTaskMatch 

func (_m *AdminServiceClient) OnListNodeExecutionsForTaskMatch(matchers ...interface{}) *AdminServiceClient_ListNodeExecutionsForTask

func (*AdminServiceClient) OnListNodeExecutionsMatch 

func (_m *AdminServiceClient) OnListNodeExecutionsMatch(matchers ...interface{}) *AdminServiceClient_ListNodeExecutions

func (*AdminServiceClient) OnListProjects 

func (_m *AdminServiceClient) OnListProjects(ctx context.Context, in *admin.ProjectListRequest, opts ...grpc.CallOption) *AdminServiceClient_ListProjects

func (*AdminServiceClient) OnListProjectsMatch 

func (_m *AdminServiceClient) OnListProjectsMatch(matchers ...interface{}) *AdminServiceClient_ListProjects

func (*AdminServiceClient) OnListTaskExecutions 

func (_m *AdminServiceClient) OnListTaskExecutions(ctx context.Context, in *admin.TaskExecutionListRequest, opts ...grpc.CallOption) *AdminServiceClient_ListTaskExecutions

func (*AdminServiceClient) OnListTaskExecutionsMatch 

func (_m *AdminServiceClient) OnListTaskExecutionsMatch(matchers ...interface{}) *AdminServiceClient_ListTaskExecutions

func (*AdminServiceClient) OnListTaskIds 

func (_m *AdminServiceClient) OnListTaskIds(ctx context.Context, in *admin.NamedEntityIdentifierListRequest, opts ...grpc.CallOption) *AdminServiceClient_ListTaskIds

func (*AdminServiceClient) OnListTaskIdsMatch 

func (_m *AdminServiceClient) OnListTaskIdsMatch(matchers ...interface{}) *AdminServiceClient_ListTaskIds

func (*AdminServiceClient) OnListTasks 

func (_m *AdminServiceClient) OnListTasks(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) *AdminServiceClient_ListTasks

func (*AdminServiceClient) OnListTasksMatch 

func (_m *AdminServiceClient) OnListTasksMatch(matchers ...interface{}) *AdminServiceClient_ListTasks

func (*AdminServiceClient) OnListWorkflowIds 

func (_m *AdminServiceClient) OnListWorkflowIds(ctx context.Context, in *admin.NamedEntityIdentifierListRequest, opts ...grpc.CallOption) *AdminServiceClient_ListWorkflowIds

func (*AdminServiceClient) OnListWorkflowIdsMatch 

func (_m *AdminServiceClient) OnListWorkflowIdsMatch(matchers ...interface{}) *AdminServiceClient_ListWorkflowIds

func (*AdminServiceClient) OnListWorkflows 

func (_m *AdminServiceClient) OnListWorkflows(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) *AdminServiceClient_ListWorkflows

func (*AdminServiceClient) OnListWorkflowsMatch 

func (_m *AdminServiceClient) OnListWorkflowsMatch(matchers ...interface{}) *AdminServiceClient_ListWorkflows

func (*AdminServiceClient) OnRecoverExecution 

func (_m *AdminServiceClient) OnRecoverExecution(ctx context.Context, in *admin.ExecutionRecoverRequest, opts ...grpc.CallOption) *AdminServiceClient_RecoverExecution

func (*AdminServiceClient) OnRecoverExecutionMatch 

func (_m *AdminServiceClient) OnRecoverExecutionMatch(matchers ...interface{}) *AdminServiceClient_RecoverExecution

func (*AdminServiceClient) OnRegisterProject 

func (_m *AdminServiceClient) OnRegisterProject(ctx context.Context, in *admin.ProjectRegisterRequest, opts ...grpc.CallOption) *AdminServiceClient_RegisterProject

func (*AdminServiceClient) OnRegisterProjectMatch 

func (_m *AdminServiceClient) OnRegisterProjectMatch(matchers ...interface{}) *AdminServiceClient_RegisterProject

func (*AdminServiceClient) OnRelaunchExecution 

func (_m *AdminServiceClient) OnRelaunchExecution(ctx context.Context, in *admin.ExecutionRelaunchRequest, opts ...grpc.CallOption) *AdminServiceClient_RelaunchExecution

func (*AdminServiceClient) OnRelaunchExecutionMatch 

func (_m *AdminServiceClient) OnRelaunchExecutionMatch(matchers ...interface{}) *AdminServiceClient_RelaunchExecution

func (*AdminServiceClient) OnTerminateExecution 

func (_m *AdminServiceClient) OnTerminateExecution(ctx context.Context, in *admin.ExecutionTerminateRequest, opts ...grpc.CallOption) *AdminServiceClient_TerminateExecution

func (*AdminServiceClient) OnTerminateExecutionMatch 

func (_m *AdminServiceClient) OnTerminateExecutionMatch(matchers ...interface{}) *AdminServiceClient_TerminateExecution

func (*AdminServiceClient) OnUpdateExecution 

func (_m *AdminServiceClient) OnUpdateExecution(ctx context.Context, in *admin.ExecutionUpdateRequest, opts ...grpc.CallOption) *AdminServiceClient_UpdateExecution

func (*AdminServiceClient) OnUpdateExecutionMatch 

func (_m *AdminServiceClient) OnUpdateExecutionMatch(matchers ...interface{}) *AdminServiceClient_UpdateExecution

func (*AdminServiceClient) OnUpdateLaunchPlan 

func (_m *AdminServiceClient) OnUpdateLaunchPlan(ctx context.Context, in *admin.LaunchPlanUpdateRequest, opts ...grpc.CallOption) *AdminServiceClient_UpdateLaunchPlan

func (*AdminServiceClient) OnUpdateLaunchPlanMatch 

func (_m *AdminServiceClient) OnUpdateLaunchPlanMatch(matchers ...interface{}) *AdminServiceClient_UpdateLaunchPlan

func (*AdminServiceClient) OnUpdateNamedEntity 

func (_m *AdminServiceClient) OnUpdateNamedEntity(ctx context.Context, in *admin.NamedEntityUpdateRequest, opts ...grpc.CallOption) *AdminServiceClient_UpdateNamedEntity

func (*AdminServiceClient) OnUpdateNamedEntityMatch 

func (_m *AdminServiceClient) OnUpdateNamedEntityMatch(matchers ...interface{}) *AdminServiceClient_UpdateNamedEntity

func (*AdminServiceClient) OnUpdateProject 

func (_m *AdminServiceClient) OnUpdateProject(ctx context.Context, in *admin.Project, opts ...grpc.CallOption) *AdminServiceClient_UpdateProject

func (*AdminServiceClient) OnUpdateProjectAttributes 

func (_m *AdminServiceClient) OnUpdateProjectAttributes(ctx context.Context, in *admin.ProjectAttributesUpdateRequest, opts ...grpc.CallOption) *AdminServiceClient_UpdateProjectAttributes

func (*AdminServiceClient) OnUpdateProjectAttributesMatch 

func (_m *AdminServiceClient) OnUpdateProjectAttributesMatch(matchers ...interface{}) *AdminServiceClient_UpdateProjectAttributes

func (*AdminServiceClient) OnUpdateProjectDomainAttributes 

func (_m *AdminServiceClient) OnUpdateProjectDomainAttributes(ctx context.Context, in *admin.ProjectDomainAttributesUpdateRequest, opts ...grpc.CallOption) *AdminServiceClient_UpdateProjectDomainAttributes

func (*AdminServiceClient) OnUpdateProjectDomainAttributesMatch 

func (_m *AdminServiceClient) OnUpdateProjectDomainAttributesMatch(matchers ...interface{}) *AdminServiceClient_UpdateProjectDomainAttributes

func (*AdminServiceClient) OnUpdateProjectMatch 

func (_m *AdminServiceClient) OnUpdateProjectMatch(matchers ...interface{}) *AdminServiceClient_UpdateProject

func (*AdminServiceClient) OnUpdateWorkflowAttributes 

func (_m *AdminServiceClient) OnUpdateWorkflowAttributes(ctx context.Context, in *admin.WorkflowAttributesUpdateRequest, opts ...grpc.CallOption) *AdminServiceClient_UpdateWorkflowAttributes

func (*AdminServiceClient) OnUpdateWorkflowAttributesMatch 

func (_m *AdminServiceClient) OnUpdateWorkflowAttributesMatch(matchers ...interface{}) *AdminServiceClient_UpdateWorkflowAttributes

func (*AdminServiceClient) RecoverExecution 

func (_m *AdminServiceClient) RecoverExecution(ctx context.Context, in *admin.ExecutionRecoverRequest, opts ...grpc.CallOption) (*admin.ExecutionCreateResponse, error)

RecoverExecution provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) RegisterProject 

func (_m *AdminServiceClient) RegisterProject(ctx context.Context, in *admin.ProjectRegisterRequest, opts ...grpc.CallOption) (*admin.ProjectRegisterResponse, error)

RegisterProject provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) RelaunchExecution 

func (_m *AdminServiceClient) RelaunchExecution(ctx context.Context, in *admin.ExecutionRelaunchRequest, opts ...grpc.CallOption) (*admin.ExecutionCreateResponse, error)

RelaunchExecution provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) TerminateExecution 

func (_m *AdminServiceClient) TerminateExecution(ctx context.Context, in *admin.ExecutionTerminateRequest, opts ...grpc.CallOption) (*admin.ExecutionTerminateResponse, error)

TerminateExecution provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) UpdateExecution 

func (_m *AdminServiceClient) UpdateExecution(ctx context.Context, in *admin.ExecutionUpdateRequest, opts ...grpc.CallOption) (*admin.ExecutionUpdateResponse, error)

UpdateExecution provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) UpdateLaunchPlan 

func (_m *AdminServiceClient) UpdateLaunchPlan(ctx context.Context, in *admin.LaunchPlanUpdateRequest, opts ...grpc.CallOption) (*admin.LaunchPlanUpdateResponse, error)

UpdateLaunchPlan provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) UpdateNamedEntity 

func (_m *AdminServiceClient) UpdateNamedEntity(ctx context.Context, in *admin.NamedEntityUpdateRequest, opts ...grpc.CallOption) (*admin.NamedEntityUpdateResponse, error)

UpdateNamedEntity provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) UpdateProject 

func (_m *AdminServiceClient) UpdateProject(ctx context.Context, in *admin.Project, opts ...grpc.CallOption) (*admin.ProjectUpdateResponse, error)

UpdateProject provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) UpdateProjectAttributes 

func (_m *AdminServiceClient) UpdateProjectAttributes(ctx context.Context, in *admin.ProjectAttributesUpdateRequest, opts ...grpc.CallOption) (*admin.ProjectAttributesUpdateResponse, error)

UpdateProjectAttributes provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) UpdateProjectDomainAttributes 

func (_m *AdminServiceClient) UpdateProjectDomainAttributes(ctx context.Context, in *admin.ProjectDomainAttributesUpdateRequest, opts ...grpc.CallOption) (*admin.ProjectDomainAttributesUpdateResponse, error)

UpdateProjectDomainAttributes provides a mock function with given fields: ctx, in, opts

func (*AdminServiceClient) UpdateWorkflowAttributes 

func (_m *AdminServiceClient) UpdateWorkflowAttributes(ctx context.Context, in *admin.WorkflowAttributesUpdateRequest, opts ...grpc.CallOption) (*admin.WorkflowAttributesUpdateResponse, error)

UpdateWorkflowAttributes provides a mock function with given fields: ctx, in, opts

type AdminServiceClient_CreateExecution 

type AdminServiceClient_CreateExecution struct {
	*mock.Call
}

func (AdminServiceClient_CreateExecution) Return 

func (_m AdminServiceClient_CreateExecution) Return(_a0 *admin.ExecutionCreateResponse, _a1 error) *AdminServiceClient_CreateExecution

type AdminServiceClient_CreateLaunchPlan 

type AdminServiceClient_CreateLaunchPlan struct {
	*mock.Call
}

func (AdminServiceClient_CreateLaunchPlan) Return 

func (_m AdminServiceClient_CreateLaunchPlan) Return(_a0 *admin.LaunchPlanCreateResponse, _a1 error) *AdminServiceClient_CreateLaunchPlan

type AdminServiceClient_CreateNodeEvent 

type AdminServiceClient_CreateNodeEvent struct {
	*mock.Call
}

func (AdminServiceClient_CreateNodeEvent) Return 

func (_m AdminServiceClient_CreateNodeEvent) Return(_a0 *admin.NodeExecutionEventResponse, _a1 error) *AdminServiceClient_CreateNodeEvent

type AdminServiceClient_CreateTask 

type AdminServiceClient_CreateTask struct {
	*mock.Call
}

func (AdminServiceClient_CreateTask) Return 

func (_m AdminServiceClient_CreateTask) Return(_a0 *admin.TaskCreateResponse, _a1 error) *AdminServiceClient_CreateTask

type AdminServiceClient_CreateTaskEvent 

type AdminServiceClient_CreateTaskEvent struct {
	*mock.Call
}

func (AdminServiceClient_CreateTaskEvent) Return 

func (_m AdminServiceClient_CreateTaskEvent) Return(_a0 *admin.TaskExecutionEventResponse, _a1 error) *AdminServiceClient_CreateTaskEvent

type AdminServiceClient_CreateWorkflow 

type AdminServiceClient_CreateWorkflow struct {
	*mock.Call
}

func (AdminServiceClient_CreateWorkflow) Return 

func (_m AdminServiceClient_CreateWorkflow) Return(_a0 *admin.WorkflowCreateResponse, _a1 error) *AdminServiceClient_CreateWorkflow

type AdminServiceClient_CreateWorkflowEvent 

type AdminServiceClient_CreateWorkflowEvent struct {
	*mock.Call
}

func (AdminServiceClient_CreateWorkflowEvent) Return 

func (_m AdminServiceClient_CreateWorkflowEvent) Return(_a0 *admin.WorkflowExecutionEventResponse, _a1 error) *AdminServiceClient_CreateWorkflowEvent

type AdminServiceClient_DeleteProjectAttributes 

type AdminServiceClient_DeleteProjectAttributes struct {
	*mock.Call
}

func (AdminServiceClient_DeleteProjectAttributes) Return 

func (_m AdminServiceClient_DeleteProjectAttributes) Return(_a0 *admin.ProjectAttributesDeleteResponse, _a1 error) *AdminServiceClient_DeleteProjectAttributes

type AdminServiceClient_DeleteProjectDomainAttributes 

type AdminServiceClient_DeleteProjectDomainAttributes struct {
	*mock.Call
}

func (AdminServiceClient_DeleteProjectDomainAttributes) Return 

func (_m AdminServiceClient_DeleteProjectDomainAttributes) Return(_a0 *admin.ProjectDomainAttributesDeleteResponse, _a1 error) *AdminServiceClient_DeleteProjectDomainAttributes

type AdminServiceClient_DeleteWorkflowAttributes 

type AdminServiceClient_DeleteWorkflowAttributes struct {
	*mock.Call
}

func (AdminServiceClient_DeleteWorkflowAttributes) Return 

func (_m AdminServiceClient_DeleteWorkflowAttributes) Return(_a0 *admin.WorkflowAttributesDeleteResponse, _a1 error) *AdminServiceClient_DeleteWorkflowAttributes

type AdminServiceClient_GetActiveLaunchPlan 

type AdminServiceClient_GetActiveLaunchPlan struct {
	*mock.Call
}

func (AdminServiceClient_GetActiveLaunchPlan) Return 

func (_m AdminServiceClient_GetActiveLaunchPlan) Return(_a0 *admin.LaunchPlan, _a1 error) *AdminServiceClient_GetActiveLaunchPlan

type AdminServiceClient_GetDescriptionEntity 

type AdminServiceClient_GetDescriptionEntity struct {
	*mock.Call
}

func (AdminServiceClient_GetDescriptionEntity) Return 

func (_m AdminServiceClient_GetDescriptionEntity) Return(_a0 *admin.DescriptionEntity, _a1 error) *AdminServiceClient_GetDescriptionEntity

type AdminServiceClient_GetDomains added in v1.13.0 

type AdminServiceClient_GetDomains struct {
	*mock.Call
}

func (AdminServiceClient_GetDomains) Return added in v1.13.0 

func (_m AdminServiceClient_GetDomains) Return(_a0 *admin.GetDomainsResponse, _a1 error) *AdminServiceClient_GetDomains

type AdminServiceClient_GetDynamicNodeWorkflow added in v1.10.7 

type AdminServiceClient_GetDynamicNodeWorkflow struct {
	*mock.Call
}

func (AdminServiceClient_GetDynamicNodeWorkflow) Return added in v1.10.7 

func (_m AdminServiceClient_GetDynamicNodeWorkflow) Return(_a0 *admin.DynamicNodeWorkflowResponse, _a1 error) *AdminServiceClient_GetDynamicNodeWorkflow

type AdminServiceClient_GetExecution 

type AdminServiceClient_GetExecution struct {
	*mock.Call
}

func (AdminServiceClient_GetExecution) Return 

func (_m AdminServiceClient_GetExecution) Return(_a0 *admin.Execution, _a1 error) *AdminServiceClient_GetExecution

type AdminServiceClient_GetExecutionData 

type AdminServiceClient_GetExecutionData struct {
	*mock.Call
}

func (AdminServiceClient_GetExecutionData) Return 

func (_m AdminServiceClient_GetExecutionData) Return(_a0 *admin.WorkflowExecutionGetDataResponse, _a1 error) *AdminServiceClient_GetExecutionData

type AdminServiceClient_GetExecutionMetrics 

type AdminServiceClient_GetExecutionMetrics struct {
	*mock.Call
}

func (AdminServiceClient_GetExecutionMetrics) Return 

func (_m AdminServiceClient_GetExecutionMetrics) Return(_a0 *admin.WorkflowExecutionGetMetricsResponse, _a1 error) *AdminServiceClient_GetExecutionMetrics

type AdminServiceClient_GetLaunchPlan 

type AdminServiceClient_GetLaunchPlan struct {
	*mock.Call
}

func (AdminServiceClient_GetLaunchPlan) Return 

func (_m AdminServiceClient_GetLaunchPlan) Return(_a0 *admin.LaunchPlan, _a1 error) *AdminServiceClient_GetLaunchPlan

type AdminServiceClient_GetNamedEntity 

type AdminServiceClient_GetNamedEntity struct {
	*mock.Call
}

func (AdminServiceClient_GetNamedEntity) Return 

func (_m AdminServiceClient_GetNamedEntity) Return(_a0 *admin.NamedEntity, _a1 error) *AdminServiceClient_GetNamedEntity

type AdminServiceClient_GetNodeExecution 

type AdminServiceClient_GetNodeExecution struct {
	*mock.Call
}

func (AdminServiceClient_GetNodeExecution) Return 

func (_m AdminServiceClient_GetNodeExecution) Return(_a0 *admin.NodeExecution, _a1 error) *AdminServiceClient_GetNodeExecution

type AdminServiceClient_GetNodeExecutionData 

type AdminServiceClient_GetNodeExecutionData struct {
	*mock.Call
}

func (AdminServiceClient_GetNodeExecutionData) Return 

func (_m AdminServiceClient_GetNodeExecutionData) Return(_a0 *admin.NodeExecutionGetDataResponse, _a1 error) *AdminServiceClient_GetNodeExecutionData

type AdminServiceClient_GetProject added in v1.12.0 

type AdminServiceClient_GetProject struct {
	*mock.Call
}

func (AdminServiceClient_GetProject) Return added in v1.12.0 

func (_m AdminServiceClient_GetProject) Return(_a0 *admin.Project, _a1 error) *AdminServiceClient_GetProject

type AdminServiceClient_GetProjectAttributes 

type AdminServiceClient_GetProjectAttributes struct {
	*mock.Call
}

func (AdminServiceClient_GetProjectAttributes) Return 

func (_m AdminServiceClient_GetProjectAttributes) Return(_a0 *admin.ProjectAttributesGetResponse, _a1 error) *AdminServiceClient_GetProjectAttributes

type AdminServiceClient_GetProjectDomainAttributes 

type AdminServiceClient_GetProjectDomainAttributes struct {
	*mock.Call
}

func (AdminServiceClient_GetProjectDomainAttributes) Return 

func (_m AdminServiceClient_GetProjectDomainAttributes) Return(_a0 *admin.ProjectDomainAttributesGetResponse, _a1 error) *AdminServiceClient_GetProjectDomainAttributes

type AdminServiceClient_GetTask 

type AdminServiceClient_GetTask struct {
	*mock.Call
}

func (AdminServiceClient_GetTask) Return 

func (_m AdminServiceClient_GetTask) Return(_a0 *admin.Task, _a1 error) *AdminServiceClient_GetTask

type AdminServiceClient_GetTaskExecution 

type AdminServiceClient_GetTaskExecution struct {
	*mock.Call
}

func (AdminServiceClient_GetTaskExecution) Return 

func (_m AdminServiceClient_GetTaskExecution) Return(_a0 *admin.TaskExecution, _a1 error) *AdminServiceClient_GetTaskExecution

type AdminServiceClient_GetTaskExecutionData 

type AdminServiceClient_GetTaskExecutionData struct {
	*mock.Call
}

func (AdminServiceClient_GetTaskExecutionData) Return 

func (_m AdminServiceClient_GetTaskExecutionData) Return(_a0 *admin.TaskExecutionGetDataResponse, _a1 error) *AdminServiceClient_GetTaskExecutionData

type AdminServiceClient_GetVersion 

type AdminServiceClient_GetVersion struct {
	*mock.Call
}

func (AdminServiceClient_GetVersion) Return 

func (_m AdminServiceClient_GetVersion) Return(_a0 *admin.GetVersionResponse, _a1 error) *AdminServiceClient_GetVersion

type AdminServiceClient_GetWorkflow 

type AdminServiceClient_GetWorkflow struct {
	*mock.Call
}

func (AdminServiceClient_GetWorkflow) Return 

func (_m AdminServiceClient_GetWorkflow) Return(_a0 *admin.Workflow, _a1 error) *AdminServiceClient_GetWorkflow

type AdminServiceClient_GetWorkflowAttributes 

type AdminServiceClient_GetWorkflowAttributes struct {
	*mock.Call
}

func (AdminServiceClient_GetWorkflowAttributes) Return 

func (_m AdminServiceClient_GetWorkflowAttributes) Return(_a0 *admin.WorkflowAttributesGetResponse, _a1 error) *AdminServiceClient_GetWorkflowAttributes

type AdminServiceClient_ListActiveLaunchPlans 

type AdminServiceClient_ListActiveLaunchPlans struct {
	*mock.Call
}

func (AdminServiceClient_ListActiveLaunchPlans) Return 

func (_m AdminServiceClient_ListActiveLaunchPlans) Return(_a0 *admin.LaunchPlanList, _a1 error) *AdminServiceClient_ListActiveLaunchPlans

type AdminServiceClient_ListDescriptionEntities 

type AdminServiceClient_ListDescriptionEntities struct {
	*mock.Call
}

func (AdminServiceClient_ListDescriptionEntities) Return 

func (_m AdminServiceClient_ListDescriptionEntities) Return(_a0 *admin.DescriptionEntityList, _a1 error) *AdminServiceClient_ListDescriptionEntities

type AdminServiceClient_ListExecutions 

type AdminServiceClient_ListExecutions struct {
	*mock.Call
}

func (AdminServiceClient_ListExecutions) Return 

func (_m AdminServiceClient_ListExecutions) Return(_a0 *admin.ExecutionList, _a1 error) *AdminServiceClient_ListExecutions

type AdminServiceClient_ListLaunchPlanIds 

type AdminServiceClient_ListLaunchPlanIds struct {
	*mock.Call
}

func (AdminServiceClient_ListLaunchPlanIds) Return 

func (_m AdminServiceClient_ListLaunchPlanIds) Return(_a0 *admin.NamedEntityIdentifierList, _a1 error) *AdminServiceClient_ListLaunchPlanIds

type AdminServiceClient_ListLaunchPlans 

type AdminServiceClient_ListLaunchPlans struct {
	*mock.Call
}

func (AdminServiceClient_ListLaunchPlans) Return 

func (_m AdminServiceClient_ListLaunchPlans) Return(_a0 *admin.LaunchPlanList, _a1 error) *AdminServiceClient_ListLaunchPlans

type AdminServiceClient_ListMatchableAttributes 

type AdminServiceClient_ListMatchableAttributes struct {
	*mock.Call
}

func (AdminServiceClient_ListMatchableAttributes) Return 

func (_m AdminServiceClient_ListMatchableAttributes) Return(_a0 *admin.ListMatchableAttributesResponse, _a1 error) *AdminServiceClient_ListMatchableAttributes

type AdminServiceClient_ListNamedEntities 

type AdminServiceClient_ListNamedEntities struct {
	*mock.Call
}

func (AdminServiceClient_ListNamedEntities) Return 

func (_m AdminServiceClient_ListNamedEntities) Return(_a0 *admin.NamedEntityList, _a1 error) *AdminServiceClient_ListNamedEntities

type AdminServiceClient_ListNodeExecutions 

type AdminServiceClient_ListNodeExecutions struct {
	*mock.Call
}

func (AdminServiceClient_ListNodeExecutions) Return 

func (_m AdminServiceClient_ListNodeExecutions) Return(_a0 *admin.NodeExecutionList, _a1 error) *AdminServiceClient_ListNodeExecutions

type AdminServiceClient_ListNodeExecutionsForTask 

type AdminServiceClient_ListNodeExecutionsForTask struct {
	*mock.Call
}

func (AdminServiceClient_ListNodeExecutionsForTask) Return 

func (_m AdminServiceClient_ListNodeExecutionsForTask) Return(_a0 *admin.NodeExecutionList, _a1 error) *AdminServiceClient_ListNodeExecutionsForTask

type AdminServiceClient_ListProjects 

type AdminServiceClient_ListProjects struct {
	*mock.Call
}

func (AdminServiceClient_ListProjects) Return 

func (_m AdminServiceClient_ListProjects) Return(_a0 *admin.Projects, _a1 error) *AdminServiceClient_ListProjects

type AdminServiceClient_ListTaskExecutions 

type AdminServiceClient_ListTaskExecutions struct {
	*mock.Call
}

func (AdminServiceClient_ListTaskExecutions) Return 

func (_m AdminServiceClient_ListTaskExecutions) Return(_a0 *admin.TaskExecutionList, _a1 error) *AdminServiceClient_ListTaskExecutions

type AdminServiceClient_ListTaskIds 

type AdminServiceClient_ListTaskIds struct {
	*mock.Call
}

func (AdminServiceClient_ListTaskIds) Return 

func (_m AdminServiceClient_ListTaskIds) Return(_a0 *admin.NamedEntityIdentifierList, _a1 error) *AdminServiceClient_ListTaskIds

type AdminServiceClient_ListTasks 

type AdminServiceClient_ListTasks struct {
	*mock.Call
}

func (AdminServiceClient_ListTasks) Return 

func (_m AdminServiceClient_ListTasks) Return(_a0 *admin.TaskList, _a1 error) *AdminServiceClient_ListTasks

type AdminServiceClient_ListWorkflowIds 

type AdminServiceClient_ListWorkflowIds struct {
	*mock.Call
}

func (AdminServiceClient_ListWorkflowIds) Return 

func (_m AdminServiceClient_ListWorkflowIds) Return(_a0 *admin.NamedEntityIdentifierList, _a1 error) *AdminServiceClient_ListWorkflowIds

type AdminServiceClient_ListWorkflows 

type AdminServiceClient_ListWorkflows struct {
	*mock.Call
}

func (AdminServiceClient_ListWorkflows) Return 

func (_m AdminServiceClient_ListWorkflows) Return(_a0 *admin.WorkflowList, _a1 error) *AdminServiceClient_ListWorkflows

type AdminServiceClient_RecoverExecution 

type AdminServiceClient_RecoverExecution struct {
	*mock.Call
}

func (AdminServiceClient_RecoverExecution) Return 

func (_m AdminServiceClient_RecoverExecution) Return(_a0 *admin.ExecutionCreateResponse, _a1 error) *AdminServiceClient_RecoverExecution

type AdminServiceClient_RegisterProject 

type AdminServiceClient_RegisterProject struct {
	*mock.Call
}

func (AdminServiceClient_RegisterProject) Return 

func (_m AdminServiceClient_RegisterProject) Return(_a0 *admin.ProjectRegisterResponse, _a1 error) *AdminServiceClient_RegisterProject

type AdminServiceClient_RelaunchExecution 

type AdminServiceClient_RelaunchExecution struct {
	*mock.Call
}

func (AdminServiceClient_RelaunchExecution) Return 

func (_m AdminServiceClient_RelaunchExecution) Return(_a0 *admin.ExecutionCreateResponse, _a1 error) *AdminServiceClient_RelaunchExecution

type AdminServiceClient_TerminateExecution 

type AdminServiceClient_TerminateExecution struct {
	*mock.Call
}

func (AdminServiceClient_TerminateExecution) Return 

func (_m AdminServiceClient_TerminateExecution) Return(_a0 *admin.ExecutionTerminateResponse, _a1 error) *AdminServiceClient_TerminateExecution

type AdminServiceClient_UpdateExecution 

type AdminServiceClient_UpdateExecution struct {
	*mock.Call
}

func (AdminServiceClient_UpdateExecution) Return 

func (_m AdminServiceClient_UpdateExecution) Return(_a0 *admin.ExecutionUpdateResponse, _a1 error) *AdminServiceClient_UpdateExecution

type AdminServiceClient_UpdateLaunchPlan 

type AdminServiceClient_UpdateLaunchPlan struct {
	*mock.Call
}

func (AdminServiceClient_UpdateLaunchPlan) Return 

func (_m AdminServiceClient_UpdateLaunchPlan) Return(_a0 *admin.LaunchPlanUpdateResponse, _a1 error) *AdminServiceClient_UpdateLaunchPlan

type AdminServiceClient_UpdateNamedEntity 

type AdminServiceClient_UpdateNamedEntity struct {
	*mock.Call
}

func (AdminServiceClient_UpdateNamedEntity) Return 

func (_m AdminServiceClient_UpdateNamedEntity) Return(_a0 *admin.NamedEntityUpdateResponse, _a1 error) *AdminServiceClient_UpdateNamedEntity

type AdminServiceClient_UpdateProject 

type AdminServiceClient_UpdateProject struct {
	*mock.Call
}

func (AdminServiceClient_UpdateProject) Return 

func (_m AdminServiceClient_UpdateProject) Return(_a0 *admin.ProjectUpdateResponse, _a1 error) *AdminServiceClient_UpdateProject

type AdminServiceClient_UpdateProjectAttributes 

type AdminServiceClient_UpdateProjectAttributes struct {
	*mock.Call
}

func (AdminServiceClient_UpdateProjectAttributes) Return 

func (_m AdminServiceClient_UpdateProjectAttributes) Return(_a0 *admin.ProjectAttributesUpdateResponse, _a1 error) *AdminServiceClient_UpdateProjectAttributes

type AdminServiceClient_UpdateProjectDomainAttributes 

type AdminServiceClient_UpdateProjectDomainAttributes struct {
	*mock.Call
}

func (AdminServiceClient_UpdateProjectDomainAttributes) Return 

func (_m AdminServiceClient_UpdateProjectDomainAttributes) Return(_a0 *admin.ProjectDomainAttributesUpdateResponse, _a1 error) *AdminServiceClient_UpdateProjectDomainAttributes

type AdminServiceClient_UpdateWorkflowAttributes 

type AdminServiceClient_UpdateWorkflowAttributes struct {
	*mock.Call
}

func (AdminServiceClient_UpdateWorkflowAttributes) Return 

func (_m AdminServiceClient_UpdateWorkflowAttributes) Return(_a0 *admin.WorkflowAttributesUpdateResponse, _a1 error) *AdminServiceClient_UpdateWorkflowAttributes

type AdminServiceServer 

type AdminServiceServer struct {
	mock.Mock
}

AdminServiceServer is an autogenerated mock type for the AdminServiceServer type

func (*AdminServiceServer) CreateExecution 

func (_m *AdminServiceServer) CreateExecution(_a0 context.Context, _a1 *admin.ExecutionCreateRequest) (*admin.ExecutionCreateResponse, error)

CreateExecution provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) CreateLaunchPlan 

func (_m *AdminServiceServer) CreateLaunchPlan(_a0 context.Context, _a1 *admin.LaunchPlanCreateRequest) (*admin.LaunchPlanCreateResponse, error)

CreateLaunchPlan provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) CreateNodeEvent 

func (_m *AdminServiceServer) CreateNodeEvent(_a0 context.Context, _a1 *admin.NodeExecutionEventRequest) (*admin.NodeExecutionEventResponse, error)

CreateNodeEvent provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) CreateTask 

func (_m *AdminServiceServer) CreateTask(_a0 context.Context, _a1 *admin.TaskCreateRequest) (*admin.TaskCreateResponse, error)

CreateTask provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) CreateTaskEvent 

func (_m *AdminServiceServer) CreateTaskEvent(_a0 context.Context, _a1 *admin.TaskExecutionEventRequest) (*admin.TaskExecutionEventResponse, error)

CreateTaskEvent provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) CreateWorkflow 

func (_m *AdminServiceServer) CreateWorkflow(_a0 context.Context, _a1 *admin.WorkflowCreateRequest) (*admin.WorkflowCreateResponse, error)

CreateWorkflow provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) CreateWorkflowEvent 

func (_m *AdminServiceServer) CreateWorkflowEvent(_a0 context.Context, _a1 *admin.WorkflowExecutionEventRequest) (*admin.WorkflowExecutionEventResponse, error)

CreateWorkflowEvent provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) DeleteProjectAttributes 

func (_m *AdminServiceServer) DeleteProjectAttributes(_a0 context.Context, _a1 *admin.ProjectAttributesDeleteRequest) (*admin.ProjectAttributesDeleteResponse, error)

DeleteProjectAttributes provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) DeleteProjectDomainAttributes 

func (_m *AdminServiceServer) DeleteProjectDomainAttributes(_a0 context.Context, _a1 *admin.ProjectDomainAttributesDeleteRequest) (*admin.ProjectDomainAttributesDeleteResponse, error)

DeleteProjectDomainAttributes provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) DeleteWorkflowAttributes 

func (_m *AdminServiceServer) DeleteWorkflowAttributes(_a0 context.Context, _a1 *admin.WorkflowAttributesDeleteRequest) (*admin.WorkflowAttributesDeleteResponse, error)

DeleteWorkflowAttributes provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) GetActiveLaunchPlan 

func (_m *AdminServiceServer) GetActiveLaunchPlan(_a0 context.Context, _a1 *admin.ActiveLaunchPlanRequest) (*admin.LaunchPlan, error)

GetActiveLaunchPlan provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) GetDescriptionEntity 

func (_m *AdminServiceServer) GetDescriptionEntity(_a0 context.Context, _a1 *admin.ObjectGetRequest) (*admin.DescriptionEntity, error)

GetDescriptionEntity provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) GetDomains added in v1.13.0 

func (_m *AdminServiceServer) GetDomains(_a0 context.Context, _a1 *admin.GetDomainRequest) (*admin.GetDomainsResponse, error)

GetDomains provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) GetDynamicNodeWorkflow added in v1.10.7 

func (_m *AdminServiceServer) GetDynamicNodeWorkflow(_a0 context.Context, _a1 *admin.GetDynamicNodeWorkflowRequest) (*admin.DynamicNodeWorkflowResponse, error)

GetDynamicNodeWorkflow provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) GetExecution 

func (_m *AdminServiceServer) GetExecution(_a0 context.Context, _a1 *admin.WorkflowExecutionGetRequest) (*admin.Execution, error)

GetExecution provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) GetExecutionData 

func (_m *AdminServiceServer) GetExecutionData(_a0 context.Context, _a1 *admin.WorkflowExecutionGetDataRequest) (*admin.WorkflowExecutionGetDataResponse, error)

GetExecutionData provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) GetExecutionMetrics 

func (_m *AdminServiceServer) GetExecutionMetrics(_a0 context.Context, _a1 *admin.WorkflowExecutionGetMetricsRequest) (*admin.WorkflowExecutionGetMetricsResponse, error)

GetExecutionMetrics provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) GetLaunchPlan 

func (_m *AdminServiceServer) GetLaunchPlan(_a0 context.Context, _a1 *admin.ObjectGetRequest) (*admin.LaunchPlan, error)

GetLaunchPlan provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) GetNamedEntity 

func (_m *AdminServiceServer) GetNamedEntity(_a0 context.Context, _a1 *admin.NamedEntityGetRequest) (*admin.NamedEntity, error)

GetNamedEntity provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) GetNodeExecution 

func (_m *AdminServiceServer) GetNodeExecution(_a0 context.Context, _a1 *admin.NodeExecutionGetRequest) (*admin.NodeExecution, error)

GetNodeExecution provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) GetNodeExecutionData 

func (_m *AdminServiceServer) GetNodeExecutionData(_a0 context.Context, _a1 *admin.NodeExecutionGetDataRequest) (*admin.NodeExecutionGetDataResponse, error)

GetNodeExecutionData provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) GetProject added in v1.12.0 

func (_m *AdminServiceServer) GetProject(_a0 context.Context, _a1 *admin.ProjectGetRequest) (*admin.Project, error)

GetProject provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) GetProjectAttributes 

func (_m *AdminServiceServer) GetProjectAttributes(_a0 context.Context, _a1 *admin.ProjectAttributesGetRequest) (*admin.ProjectAttributesGetResponse, error)

GetProjectAttributes provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) GetProjectDomainAttributes 

func (_m *AdminServiceServer) GetProjectDomainAttributes(_a0 context.Context, _a1 *admin.ProjectDomainAttributesGetRequest) (*admin.ProjectDomainAttributesGetResponse, error)

GetProjectDomainAttributes provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) GetTask 

func (_m *AdminServiceServer) GetTask(_a0 context.Context, _a1 *admin.ObjectGetRequest) (*admin.Task, error)

GetTask provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) GetTaskExecution 

func (_m *AdminServiceServer) GetTaskExecution(_a0 context.Context, _a1 *admin.TaskExecutionGetRequest) (*admin.TaskExecution, error)

GetTaskExecution provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) GetTaskExecutionData 

func (_m *AdminServiceServer) GetTaskExecutionData(_a0 context.Context, _a1 *admin.TaskExecutionGetDataRequest) (*admin.TaskExecutionGetDataResponse, error)

GetTaskExecutionData provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) GetVersion 

func (_m *AdminServiceServer) GetVersion(_a0 context.Context, _a1 *admin.GetVersionRequest) (*admin.GetVersionResponse, error)

GetVersion provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) GetWorkflow 

func (_m *AdminServiceServer) GetWorkflow(_a0 context.Context, _a1 *admin.ObjectGetRequest) (*admin.Workflow, error)

GetWorkflow provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) GetWorkflowAttributes 

func (_m *AdminServiceServer) GetWorkflowAttributes(_a0 context.Context, _a1 *admin.WorkflowAttributesGetRequest) (*admin.WorkflowAttributesGetResponse, error)

GetWorkflowAttributes provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) ListActiveLaunchPlans 

func (_m *AdminServiceServer) ListActiveLaunchPlans(_a0 context.Context, _a1 *admin.ActiveLaunchPlanListRequest) (*admin.LaunchPlanList, error)

ListActiveLaunchPlans provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) ListDescriptionEntities 

func (_m *AdminServiceServer) ListDescriptionEntities(_a0 context.Context, _a1 *admin.DescriptionEntityListRequest) (*admin.DescriptionEntityList, error)

ListDescriptionEntities provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) ListExecutions 

func (_m *AdminServiceServer) ListExecutions(_a0 context.Context, _a1 *admin.ResourceListRequest) (*admin.ExecutionList, error)

ListExecutions provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) ListLaunchPlanIds 

func (_m *AdminServiceServer) ListLaunchPlanIds(_a0 context.Context, _a1 *admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error)

ListLaunchPlanIds provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) ListLaunchPlans 

func (_m *AdminServiceServer) ListLaunchPlans(_a0 context.Context, _a1 *admin.ResourceListRequest) (*admin.LaunchPlanList, error)

ListLaunchPlans provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) ListMatchableAttributes 

func (_m *AdminServiceServer) ListMatchableAttributes(_a0 context.Context, _a1 *admin.ListMatchableAttributesRequest) (*admin.ListMatchableAttributesResponse, error)

ListMatchableAttributes provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) ListNamedEntities 

func (_m *AdminServiceServer) ListNamedEntities(_a0 context.Context, _a1 *admin.NamedEntityListRequest) (*admin.NamedEntityList, error)

ListNamedEntities provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) ListNodeExecutions 

func (_m *AdminServiceServer) ListNodeExecutions(_a0 context.Context, _a1 *admin.NodeExecutionListRequest) (*admin.NodeExecutionList, error)

ListNodeExecutions provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) ListNodeExecutionsForTask 

func (_m *AdminServiceServer) ListNodeExecutionsForTask(_a0 context.Context, _a1 *admin.NodeExecutionForTaskListRequest) (*admin.NodeExecutionList, error)

ListNodeExecutionsForTask provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) ListProjects 

func (_m *AdminServiceServer) ListProjects(_a0 context.Context, _a1 *admin.ProjectListRequest) (*admin.Projects, error)

ListProjects provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) ListTaskExecutions 

func (_m *AdminServiceServer) ListTaskExecutions(_a0 context.Context, _a1 *admin.TaskExecutionListRequest) (*admin.TaskExecutionList, error)

ListTaskExecutions provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) ListTaskIds 

func (_m *AdminServiceServer) ListTaskIds(_a0 context.Context, _a1 *admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error)

ListTaskIds provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) ListTasks 

func (_m *AdminServiceServer) ListTasks(_a0 context.Context, _a1 *admin.ResourceListRequest) (*admin.TaskList, error)

ListTasks provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) ListWorkflowIds 

func (_m *AdminServiceServer) ListWorkflowIds(_a0 context.Context, _a1 *admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error)

ListWorkflowIds provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) ListWorkflows 

func (_m *AdminServiceServer) ListWorkflows(_a0 context.Context, _a1 *admin.ResourceListRequest) (*admin.WorkflowList, error)

ListWorkflows provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) OnCreateExecution 

func (_m *AdminServiceServer) OnCreateExecution(_a0 context.Context, _a1 *admin.ExecutionCreateRequest) *AdminServiceServer_CreateExecution

func (*AdminServiceServer) OnCreateExecutionMatch 

func (_m *AdminServiceServer) OnCreateExecutionMatch(matchers ...interface{}) *AdminServiceServer_CreateExecution

func (*AdminServiceServer) OnCreateLaunchPlan 

func (_m *AdminServiceServer) OnCreateLaunchPlan(_a0 context.Context, _a1 *admin.LaunchPlanCreateRequest) *AdminServiceServer_CreateLaunchPlan

func (*AdminServiceServer) OnCreateLaunchPlanMatch 

func (_m *AdminServiceServer) OnCreateLaunchPlanMatch(matchers ...interface{}) *AdminServiceServer_CreateLaunchPlan

func (*AdminServiceServer) OnCreateNodeEvent 

func (_m *AdminServiceServer) OnCreateNodeEvent(_a0 context.Context, _a1 *admin.NodeExecutionEventRequest) *AdminServiceServer_CreateNodeEvent

func (*AdminServiceServer) OnCreateNodeEventMatch 

func (_m *AdminServiceServer) OnCreateNodeEventMatch(matchers ...interface{}) *AdminServiceServer_CreateNodeEvent

func (*AdminServiceServer) OnCreateTask 

func (_m *AdminServiceServer) OnCreateTask(_a0 context.Context, _a1 *admin.TaskCreateRequest) *AdminServiceServer_CreateTask

func (*AdminServiceServer) OnCreateTaskEvent 

func (_m *AdminServiceServer) OnCreateTaskEvent(_a0 context.Context, _a1 *admin.TaskExecutionEventRequest) *AdminServiceServer_CreateTaskEvent

func (*AdminServiceServer) OnCreateTaskEventMatch 

func (_m *AdminServiceServer) OnCreateTaskEventMatch(matchers ...interface{}) *AdminServiceServer_CreateTaskEvent

func (*AdminServiceServer) OnCreateTaskMatch 

func (_m *AdminServiceServer) OnCreateTaskMatch(matchers ...interface{}) *AdminServiceServer_CreateTask

func (*AdminServiceServer) OnCreateWorkflow 

func (_m *AdminServiceServer) OnCreateWorkflow(_a0 context.Context, _a1 *admin.WorkflowCreateRequest) *AdminServiceServer_CreateWorkflow

func (*AdminServiceServer) OnCreateWorkflowEvent 

func (_m *AdminServiceServer) OnCreateWorkflowEvent(_a0 context.Context, _a1 *admin.WorkflowExecutionEventRequest) *AdminServiceServer_CreateWorkflowEvent

func (*AdminServiceServer) OnCreateWorkflowEventMatch 

func (_m *AdminServiceServer) OnCreateWorkflowEventMatch(matchers ...interface{}) *AdminServiceServer_CreateWorkflowEvent

func (*AdminServiceServer) OnCreateWorkflowMatch 

func (_m *AdminServiceServer) OnCreateWorkflowMatch(matchers ...interface{}) *AdminServiceServer_CreateWorkflow

func (*AdminServiceServer) OnDeleteProjectAttributes 

func (_m *AdminServiceServer) OnDeleteProjectAttributes(_a0 context.Context, _a1 *admin.ProjectAttributesDeleteRequest) *AdminServiceServer_DeleteProjectAttributes

func (*AdminServiceServer) OnDeleteProjectAttributesMatch 

func (_m *AdminServiceServer) OnDeleteProjectAttributesMatch(matchers ...interface{}) *AdminServiceServer_DeleteProjectAttributes

func (*AdminServiceServer) OnDeleteProjectDomainAttributes 

func (_m *AdminServiceServer) OnDeleteProjectDomainAttributes(_a0 context.Context, _a1 *admin.ProjectDomainAttributesDeleteRequest) *AdminServiceServer_DeleteProjectDomainAttributes

func (*AdminServiceServer) OnDeleteProjectDomainAttributesMatch 

func (_m *AdminServiceServer) OnDeleteProjectDomainAttributesMatch(matchers ...interface{}) *AdminServiceServer_DeleteProjectDomainAttributes

func (*AdminServiceServer) OnDeleteWorkflowAttributes 

func (_m *AdminServiceServer) OnDeleteWorkflowAttributes(_a0 context.Context, _a1 *admin.WorkflowAttributesDeleteRequest) *AdminServiceServer_DeleteWorkflowAttributes

func (*AdminServiceServer) OnDeleteWorkflowAttributesMatch 

func (_m *AdminServiceServer) OnDeleteWorkflowAttributesMatch(matchers ...interface{}) *AdminServiceServer_DeleteWorkflowAttributes

func (*AdminServiceServer) OnGetActiveLaunchPlan 

func (_m *AdminServiceServer) OnGetActiveLaunchPlan(_a0 context.Context, _a1 *admin.ActiveLaunchPlanRequest) *AdminServiceServer_GetActiveLaunchPlan

func (*AdminServiceServer) OnGetActiveLaunchPlanMatch 

func (_m *AdminServiceServer) OnGetActiveLaunchPlanMatch(matchers ...interface{}) *AdminServiceServer_GetActiveLaunchPlan

func (*AdminServiceServer) OnGetDescriptionEntity 

func (_m *AdminServiceServer) OnGetDescriptionEntity(_a0 context.Context, _a1 *admin.ObjectGetRequest) *AdminServiceServer_GetDescriptionEntity

func (*AdminServiceServer) OnGetDescriptionEntityMatch 

func (_m *AdminServiceServer) OnGetDescriptionEntityMatch(matchers ...interface{}) *AdminServiceServer_GetDescriptionEntity

func (*AdminServiceServer) OnGetDomains added in v1.13.0 

func (_m *AdminServiceServer) OnGetDomains(_a0 context.Context, _a1 *admin.GetDomainRequest) *AdminServiceServer_GetDomains

func (*AdminServiceServer) OnGetDomainsMatch added in v1.13.0 

func (_m *AdminServiceServer) OnGetDomainsMatch(matchers ...interface{}) *AdminServiceServer_GetDomains

func (*AdminServiceServer) OnGetDynamicNodeWorkflow added in v1.10.7 

func (_m *AdminServiceServer) OnGetDynamicNodeWorkflow(_a0 context.Context, _a1 *admin.GetDynamicNodeWorkflowRequest) *AdminServiceServer_GetDynamicNodeWorkflow

func (*AdminServiceServer) OnGetDynamicNodeWorkflowMatch added in v1.10.7 

func (_m *AdminServiceServer) OnGetDynamicNodeWorkflowMatch(matchers ...interface{}) *AdminServiceServer_GetDynamicNodeWorkflow

func (*AdminServiceServer) OnGetExecution 

func (_m *AdminServiceServer) OnGetExecution(_a0 context.Context, _a1 *admin.WorkflowExecutionGetRequest) *AdminServiceServer_GetExecution

func (*AdminServiceServer) OnGetExecutionData 

func (_m *AdminServiceServer) OnGetExecutionData(_a0 context.Context, _a1 *admin.WorkflowExecutionGetDataRequest) *AdminServiceServer_GetExecutionData

func (*AdminServiceServer) OnGetExecutionDataMatch 

func (_m *AdminServiceServer) OnGetExecutionDataMatch(matchers ...interface{}) *AdminServiceServer_GetExecutionData

func (*AdminServiceServer) OnGetExecutionMatch 

func (_m *AdminServiceServer) OnGetExecutionMatch(matchers ...interface{}) *AdminServiceServer_GetExecution

func (*AdminServiceServer) OnGetExecutionMetrics 

func (_m *AdminServiceServer) OnGetExecutionMetrics(_a0 context.Context, _a1 *admin.WorkflowExecutionGetMetricsRequest) *AdminServiceServer_GetExecutionMetrics

func (*AdminServiceServer) OnGetExecutionMetricsMatch 

func (_m *AdminServiceServer) OnGetExecutionMetricsMatch(matchers ...interface{}) *AdminServiceServer_GetExecutionMetrics

func (*AdminServiceServer) OnGetLaunchPlan 

func (_m *AdminServiceServer) OnGetLaunchPlan(_a0 context.Context, _a1 *admin.ObjectGetRequest) *AdminServiceServer_GetLaunchPlan

func (*AdminServiceServer) OnGetLaunchPlanMatch 

func (_m *AdminServiceServer) OnGetLaunchPlanMatch(matchers ...interface{}) *AdminServiceServer_GetLaunchPlan

func (*AdminServiceServer) OnGetNamedEntity 

func (_m *AdminServiceServer) OnGetNamedEntity(_a0 context.Context, _a1 *admin.NamedEntityGetRequest) *AdminServiceServer_GetNamedEntity

func (*AdminServiceServer) OnGetNamedEntityMatch 

func (_m *AdminServiceServer) OnGetNamedEntityMatch(matchers ...interface{}) *AdminServiceServer_GetNamedEntity

func (*AdminServiceServer) OnGetNodeExecution 

func (_m *AdminServiceServer) OnGetNodeExecution(_a0 context.Context, _a1 *admin.NodeExecutionGetRequest) *AdminServiceServer_GetNodeExecution

func (*AdminServiceServer) OnGetNodeExecutionData 

func (_m *AdminServiceServer) OnGetNodeExecutionData(_a0 context.Context, _a1 *admin.NodeExecutionGetDataRequest) *AdminServiceServer_GetNodeExecutionData

func (*AdminServiceServer) OnGetNodeExecutionDataMatch 

func (_m *AdminServiceServer) OnGetNodeExecutionDataMatch(matchers ...interface{}) *AdminServiceServer_GetNodeExecutionData

func (*AdminServiceServer) OnGetNodeExecutionMatch 

func (_m *AdminServiceServer) OnGetNodeExecutionMatch(matchers ...interface{}) *AdminServiceServer_GetNodeExecution

func (*AdminServiceServer) OnGetProject added in v1.12.0 

func (_m *AdminServiceServer) OnGetProject(_a0 context.Context, _a1 *admin.ProjectGetRequest) *AdminServiceServer_GetProject

func (*AdminServiceServer) OnGetProjectAttributes 

func (_m *AdminServiceServer) OnGetProjectAttributes(_a0 context.Context, _a1 *admin.ProjectAttributesGetRequest) *AdminServiceServer_GetProjectAttributes

func (*AdminServiceServer) OnGetProjectAttributesMatch 

func (_m *AdminServiceServer) OnGetProjectAttributesMatch(matchers ...interface{}) *AdminServiceServer_GetProjectAttributes

func (*AdminServiceServer) OnGetProjectDomainAttributes 

func (_m *AdminServiceServer) OnGetProjectDomainAttributes(_a0 context.Context, _a1 *admin.ProjectDomainAttributesGetRequest) *AdminServiceServer_GetProjectDomainAttributes

func (*AdminServiceServer) OnGetProjectDomainAttributesMatch 

func (_m *AdminServiceServer) OnGetProjectDomainAttributesMatch(matchers ...interface{}) *AdminServiceServer_GetProjectDomainAttributes

func (*AdminServiceServer) OnGetProjectMatch added in v1.12.0 

func (_m *AdminServiceServer) OnGetProjectMatch(matchers ...interface{}) *AdminServiceServer_GetProject

func (*AdminServiceServer) OnGetTask 

func (_m *AdminServiceServer) OnGetTask(_a0 context.Context, _a1 *admin.ObjectGetRequest) *AdminServiceServer_GetTask

func (*AdminServiceServer) OnGetTaskExecution 

func (_m *AdminServiceServer) OnGetTaskExecution(_a0 context.Context, _a1 *admin.TaskExecutionGetRequest) *AdminServiceServer_GetTaskExecution

func (*AdminServiceServer) OnGetTaskExecutionData 

func (_m *AdminServiceServer) OnGetTaskExecutionData(_a0 context.Context, _a1 *admin.TaskExecutionGetDataRequest) *AdminServiceServer_GetTaskExecutionData

func (*AdminServiceServer) OnGetTaskExecutionDataMatch 

func (_m *AdminServiceServer) OnGetTaskExecutionDataMatch(matchers ...interface{}) *AdminServiceServer_GetTaskExecutionData

func (*AdminServiceServer) OnGetTaskExecutionMatch 

func (_m *AdminServiceServer) OnGetTaskExecutionMatch(matchers ...interface{}) *AdminServiceServer_GetTaskExecution

func (*AdminServiceServer) OnGetTaskMatch 

func (_m *AdminServiceServer) OnGetTaskMatch(matchers ...interface{}) *AdminServiceServer_GetTask

func (*AdminServiceServer) OnGetVersion 

func (_m *AdminServiceServer) OnGetVersion(_a0 context.Context, _a1 *admin.GetVersionRequest) *AdminServiceServer_GetVersion

func (*AdminServiceServer) OnGetVersionMatch 

func (_m *AdminServiceServer) OnGetVersionMatch(matchers ...interface{}) *AdminServiceServer_GetVersion

func (*AdminServiceServer) OnGetWorkflow 

func (_m *AdminServiceServer) OnGetWorkflow(_a0 context.Context, _a1 *admin.ObjectGetRequest) *AdminServiceServer_GetWorkflow

func (*AdminServiceServer) OnGetWorkflowAttributes 

func (_m *AdminServiceServer) OnGetWorkflowAttributes(_a0 context.Context, _a1 *admin.WorkflowAttributesGetRequest) *AdminServiceServer_GetWorkflowAttributes

func (*AdminServiceServer) OnGetWorkflowAttributesMatch 

func (_m *AdminServiceServer) OnGetWorkflowAttributesMatch(matchers ...interface{}) *AdminServiceServer_GetWorkflowAttributes

func (*AdminServiceServer) OnGetWorkflowMatch 

func (_m *AdminServiceServer) OnGetWorkflowMatch(matchers ...interface{}) *AdminServiceServer_GetWorkflow

func (*AdminServiceServer) OnListActiveLaunchPlans 

func (_m *AdminServiceServer) OnListActiveLaunchPlans(_a0 context.Context, _a1 *admin.ActiveLaunchPlanListRequest) *AdminServiceServer_ListActiveLaunchPlans

func (*AdminServiceServer) OnListActiveLaunchPlansMatch 

func (_m *AdminServiceServer) OnListActiveLaunchPlansMatch(matchers ...interface{}) *AdminServiceServer_ListActiveLaunchPlans

func (*AdminServiceServer) OnListDescriptionEntities 

func (_m *AdminServiceServer) OnListDescriptionEntities(_a0 context.Context, _a1 *admin.DescriptionEntityListRequest) *AdminServiceServer_ListDescriptionEntities

func (*AdminServiceServer) OnListDescriptionEntitiesMatch 

func (_m *AdminServiceServer) OnListDescriptionEntitiesMatch(matchers ...interface{}) *AdminServiceServer_ListDescriptionEntities

func (*AdminServiceServer) OnListExecutions 

func (_m *AdminServiceServer) OnListExecutions(_a0 context.Context, _a1 *admin.ResourceListRequest) *AdminServiceServer_ListExecutions

func (*AdminServiceServer) OnListExecutionsMatch 

func (_m *AdminServiceServer) OnListExecutionsMatch(matchers ...interface{}) *AdminServiceServer_ListExecutions

func (*AdminServiceServer) OnListLaunchPlanIds 

func (_m *AdminServiceServer) OnListLaunchPlanIds(_a0 context.Context, _a1 *admin.NamedEntityIdentifierListRequest) *AdminServiceServer_ListLaunchPlanIds

func (*AdminServiceServer) OnListLaunchPlanIdsMatch 

func (_m *AdminServiceServer) OnListLaunchPlanIdsMatch(matchers ...interface{}) *AdminServiceServer_ListLaunchPlanIds

func (*AdminServiceServer) OnListLaunchPlans 

func (_m *AdminServiceServer) OnListLaunchPlans(_a0 context.Context, _a1 *admin.ResourceListRequest) *AdminServiceServer_ListLaunchPlans

func (*AdminServiceServer) OnListLaunchPlansMatch 

func (_m *AdminServiceServer) OnListLaunchPlansMatch(matchers ...interface{}) *AdminServiceServer_ListLaunchPlans

func (*AdminServiceServer) OnListMatchableAttributes 

func (_m *AdminServiceServer) OnListMatchableAttributes(_a0 context.Context, _a1 *admin.ListMatchableAttributesRequest) *AdminServiceServer_ListMatchableAttributes

func (*AdminServiceServer) OnListMatchableAttributesMatch 

func (_m *AdminServiceServer) OnListMatchableAttributesMatch(matchers ...interface{}) *AdminServiceServer_ListMatchableAttributes

func (*AdminServiceServer) OnListNamedEntities 

func (_m *AdminServiceServer) OnListNamedEntities(_a0 context.Context, _a1 *admin.NamedEntityListRequest) *AdminServiceServer_ListNamedEntities

func (*AdminServiceServer) OnListNamedEntitiesMatch 

func (_m *AdminServiceServer) OnListNamedEntitiesMatch(matchers ...interface{}) *AdminServiceServer_ListNamedEntities

func (*AdminServiceServer) OnListNodeExecutions 

func (_m *AdminServiceServer) OnListNodeExecutions(_a0 context.Context, _a1 *admin.NodeExecutionListRequest) *AdminServiceServer_ListNodeExecutions

func (*AdminServiceServer) OnListNodeExecutionsForTask 

func (_m *AdminServiceServer) OnListNodeExecutionsForTask(_a0 context.Context, _a1 *admin.NodeExecutionForTaskListRequest) *AdminServiceServer_ListNodeExecutionsForTask

func (*AdminServiceServer) OnListNodeExecutionsForTaskMatch 

func (_m *AdminServiceServer) OnListNodeExecutionsForTaskMatch(matchers ...interface{}) *AdminServiceServer_ListNodeExecutionsForTask

func (*AdminServiceServer) OnListNodeExecutionsMatch 

func (_m *AdminServiceServer) OnListNodeExecutionsMatch(matchers ...interface{}) *AdminServiceServer_ListNodeExecutions

func (*AdminServiceServer) OnListProjects 

func (_m *AdminServiceServer) OnListProjects(_a0 context.Context, _a1 *admin.ProjectListRequest) *AdminServiceServer_ListProjects

func (*AdminServiceServer) OnListProjectsMatch 

func (_m *AdminServiceServer) OnListProjectsMatch(matchers ...interface{}) *AdminServiceServer_ListProjects

func (*AdminServiceServer) OnListTaskExecutions 

func (_m *AdminServiceServer) OnListTaskExecutions(_a0 context.Context, _a1 *admin.TaskExecutionListRequest) *AdminServiceServer_ListTaskExecutions

func (*AdminServiceServer) OnListTaskExecutionsMatch 

func (_m *AdminServiceServer) OnListTaskExecutionsMatch(matchers ...interface{}) *AdminServiceServer_ListTaskExecutions

func (*AdminServiceServer) OnListTaskIds 

func (_m *AdminServiceServer) OnListTaskIds(_a0 context.Context, _a1 *admin.NamedEntityIdentifierListRequest) *AdminServiceServer_ListTaskIds

func (*AdminServiceServer) OnListTaskIdsMatch 

func (_m *AdminServiceServer) OnListTaskIdsMatch(matchers ...interface{}) *AdminServiceServer_ListTaskIds

func (*AdminServiceServer) OnListTasks 

func (_m *AdminServiceServer) OnListTasks(_a0 context.Context, _a1 *admin.ResourceListRequest) *AdminServiceServer_ListTasks

func (*AdminServiceServer) OnListTasksMatch 

func (_m *AdminServiceServer) OnListTasksMatch(matchers ...interface{}) *AdminServiceServer_ListTasks

func (*AdminServiceServer) OnListWorkflowIds 

func (_m *AdminServiceServer) OnListWorkflowIds(_a0 context.Context, _a1 *admin.NamedEntityIdentifierListRequest) *AdminServiceServer_ListWorkflowIds

func (*AdminServiceServer) OnListWorkflowIdsMatch 

func (_m *AdminServiceServer) OnListWorkflowIdsMatch(matchers ...interface{}) *AdminServiceServer_ListWorkflowIds

func (*AdminServiceServer) OnListWorkflows 

func (_m *AdminServiceServer) OnListWorkflows(_a0 context.Context, _a1 *admin.ResourceListRequest) *AdminServiceServer_ListWorkflows

func (*AdminServiceServer) OnListWorkflowsMatch 

func (_m *AdminServiceServer) OnListWorkflowsMatch(matchers ...interface{}) *AdminServiceServer_ListWorkflows

func (*AdminServiceServer) OnRecoverExecution 

func (_m *AdminServiceServer) OnRecoverExecution(_a0 context.Context, _a1 *admin.ExecutionRecoverRequest) *AdminServiceServer_RecoverExecution

func (*AdminServiceServer) OnRecoverExecutionMatch 

func (_m *AdminServiceServer) OnRecoverExecutionMatch(matchers ...interface{}) *AdminServiceServer_RecoverExecution

func (*AdminServiceServer) OnRegisterProject 

func (_m *AdminServiceServer) OnRegisterProject(_a0 context.Context, _a1 *admin.ProjectRegisterRequest) *AdminServiceServer_RegisterProject

func (*AdminServiceServer) OnRegisterProjectMatch 

func (_m *AdminServiceServer) OnRegisterProjectMatch(matchers ...interface{}) *AdminServiceServer_RegisterProject

func (*AdminServiceServer) OnRelaunchExecution 

func (_m *AdminServiceServer) OnRelaunchExecution(_a0 context.Context, _a1 *admin.ExecutionRelaunchRequest) *AdminServiceServer_RelaunchExecution

func (*AdminServiceServer) OnRelaunchExecutionMatch 

func (_m *AdminServiceServer) OnRelaunchExecutionMatch(matchers ...interface{}) *AdminServiceServer_RelaunchExecution

func (*AdminServiceServer) OnTerminateExecution 

func (_m *AdminServiceServer) OnTerminateExecution(_a0 context.Context, _a1 *admin.ExecutionTerminateRequest) *AdminServiceServer_TerminateExecution

func (*AdminServiceServer) OnTerminateExecutionMatch 

func (_m *AdminServiceServer) OnTerminateExecutionMatch(matchers ...interface{}) *AdminServiceServer_TerminateExecution

func (*AdminServiceServer) OnUpdateExecution 

func (_m *AdminServiceServer) OnUpdateExecution(_a0 context.Context, _a1 *admin.ExecutionUpdateRequest) *AdminServiceServer_UpdateExecution

func (*AdminServiceServer) OnUpdateExecutionMatch 

func (_m *AdminServiceServer) OnUpdateExecutionMatch(matchers ...interface{}) *AdminServiceServer_UpdateExecution

func (*AdminServiceServer) OnUpdateLaunchPlan 

func (_m *AdminServiceServer) OnUpdateLaunchPlan(_a0 context.Context, _a1 *admin.LaunchPlanUpdateRequest) *AdminServiceServer_UpdateLaunchPlan

func (*AdminServiceServer) OnUpdateLaunchPlanMatch 

func (_m *AdminServiceServer) OnUpdateLaunchPlanMatch(matchers ...interface{}) *AdminServiceServer_UpdateLaunchPlan

func (*AdminServiceServer) OnUpdateNamedEntity 

func (_m *AdminServiceServer) OnUpdateNamedEntity(_a0 context.Context, _a1 *admin.NamedEntityUpdateRequest) *AdminServiceServer_UpdateNamedEntity

func (*AdminServiceServer) OnUpdateNamedEntityMatch 

func (_m *AdminServiceServer) OnUpdateNamedEntityMatch(matchers ...interface{}) *AdminServiceServer_UpdateNamedEntity

func (*AdminServiceServer) OnUpdateProject 

func (_m *AdminServiceServer) OnUpdateProject(_a0 context.Context, _a1 *admin.Project) *AdminServiceServer_UpdateProject

func (*AdminServiceServer) OnUpdateProjectAttributes 

func (_m *AdminServiceServer) OnUpdateProjectAttributes(_a0 context.Context, _a1 *admin.ProjectAttributesUpdateRequest) *AdminServiceServer_UpdateProjectAttributes

func (*AdminServiceServer) OnUpdateProjectAttributesMatch 

func (_m *AdminServiceServer) OnUpdateProjectAttributesMatch(matchers ...interface{}) *AdminServiceServer_UpdateProjectAttributes

func (*AdminServiceServer) OnUpdateProjectDomainAttributes 

func (_m *AdminServiceServer) OnUpdateProjectDomainAttributes(_a0 context.Context, _a1 *admin.ProjectDomainAttributesUpdateRequest) *AdminServiceServer_UpdateProjectDomainAttributes

func (*AdminServiceServer) OnUpdateProjectDomainAttributesMatch 

func (_m *AdminServiceServer) OnUpdateProjectDomainAttributesMatch(matchers ...interface{}) *AdminServiceServer_UpdateProjectDomainAttributes

func (*AdminServiceServer) OnUpdateProjectMatch 

func (_m *AdminServiceServer) OnUpdateProjectMatch(matchers ...interface{}) *AdminServiceServer_UpdateProject

func (*AdminServiceServer) OnUpdateWorkflowAttributes 

func (_m *AdminServiceServer) OnUpdateWorkflowAttributes(_a0 context.Context, _a1 *admin.WorkflowAttributesUpdateRequest) *AdminServiceServer_UpdateWorkflowAttributes

func (*AdminServiceServer) OnUpdateWorkflowAttributesMatch 

func (_m *AdminServiceServer) OnUpdateWorkflowAttributesMatch(matchers ...interface{}) *AdminServiceServer_UpdateWorkflowAttributes

func (*AdminServiceServer) RecoverExecution 

func (_m *AdminServiceServer) RecoverExecution(_a0 context.Context, _a1 *admin.ExecutionRecoverRequest) (*admin.ExecutionCreateResponse, error)

RecoverExecution provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) RegisterProject 

func (_m *AdminServiceServer) RegisterProject(_a0 context.Context, _a1 *admin.ProjectRegisterRequest) (*admin.ProjectRegisterResponse, error)

RegisterProject provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) RelaunchExecution 

func (_m *AdminServiceServer) RelaunchExecution(_a0 context.Context, _a1 *admin.ExecutionRelaunchRequest) (*admin.ExecutionCreateResponse, error)

RelaunchExecution provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) TerminateExecution 

func (_m *AdminServiceServer) TerminateExecution(_a0 context.Context, _a1 *admin.ExecutionTerminateRequest) (*admin.ExecutionTerminateResponse, error)

TerminateExecution provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) UpdateExecution 

func (_m *AdminServiceServer) UpdateExecution(_a0 context.Context, _a1 *admin.ExecutionUpdateRequest) (*admin.ExecutionUpdateResponse, error)

UpdateExecution provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) UpdateLaunchPlan 

func (_m *AdminServiceServer) UpdateLaunchPlan(_a0 context.Context, _a1 *admin.LaunchPlanUpdateRequest) (*admin.LaunchPlanUpdateResponse, error)

UpdateLaunchPlan provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) UpdateNamedEntity 

func (_m *AdminServiceServer) UpdateNamedEntity(_a0 context.Context, _a1 *admin.NamedEntityUpdateRequest) (*admin.NamedEntityUpdateResponse, error)

UpdateNamedEntity provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) UpdateProject 

func (_m *AdminServiceServer) UpdateProject(_a0 context.Context, _a1 *admin.Project) (*admin.ProjectUpdateResponse, error)

UpdateProject provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) UpdateProjectAttributes 

func (_m *AdminServiceServer) UpdateProjectAttributes(_a0 context.Context, _a1 *admin.ProjectAttributesUpdateRequest) (*admin.ProjectAttributesUpdateResponse, error)

UpdateProjectAttributes provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) UpdateProjectDomainAttributes 

func (_m *AdminServiceServer) UpdateProjectDomainAttributes(_a0 context.Context, _a1 *admin.ProjectDomainAttributesUpdateRequest) (*admin.ProjectDomainAttributesUpdateResponse, error)

UpdateProjectDomainAttributes provides a mock function with given fields: _a0, _a1

func (*AdminServiceServer) UpdateWorkflowAttributes 

func (_m *AdminServiceServer) UpdateWorkflowAttributes(_a0 context.Context, _a1 *admin.WorkflowAttributesUpdateRequest) (*admin.WorkflowAttributesUpdateResponse, error)

UpdateWorkflowAttributes provides a mock function with given fields: _a0, _a1

type AdminServiceServer_CreateExecution 

type AdminServiceServer_CreateExecution struct {
	*mock.Call
}

func (AdminServiceServer_CreateExecution) Return 

func (_m AdminServiceServer_CreateExecution) Return(_a0 *admin.ExecutionCreateResponse, _a1 error) *AdminServiceServer_CreateExecution

type AdminServiceServer_CreateLaunchPlan 

type AdminServiceServer_CreateLaunchPlan struct {
	*mock.Call
}

func (AdminServiceServer_CreateLaunchPlan) Return 

func (_m AdminServiceServer_CreateLaunchPlan) Return(_a0 *admin.LaunchPlanCreateResponse, _a1 error) *AdminServiceServer_CreateLaunchPlan

type AdminServiceServer_CreateNodeEvent 

type AdminServiceServer_CreateNodeEvent struct {
	*mock.Call
}

func (AdminServiceServer_CreateNodeEvent) Return 

func (_m AdminServiceServer_CreateNodeEvent) Return(_a0 *admin.NodeExecutionEventResponse, _a1 error) *AdminServiceServer_CreateNodeEvent

type AdminServiceServer_CreateTask 

type AdminServiceServer_CreateTask struct {
	*mock.Call
}

func (AdminServiceServer_CreateTask) Return 

func (_m AdminServiceServer_CreateTask) Return(_a0 *admin.TaskCreateResponse, _a1 error) *AdminServiceServer_CreateTask

type AdminServiceServer_CreateTaskEvent 

type AdminServiceServer_CreateTaskEvent struct {
	*mock.Call
}

func (AdminServiceServer_CreateTaskEvent) Return 

func (_m AdminServiceServer_CreateTaskEvent) Return(_a0 *admin.TaskExecutionEventResponse, _a1 error) *AdminServiceServer_CreateTaskEvent

type AdminServiceServer_CreateWorkflow 

type AdminServiceServer_CreateWorkflow struct {
	*mock.Call
}

func (AdminServiceServer_CreateWorkflow) Return 

func (_m AdminServiceServer_CreateWorkflow) Return(_a0 *admin.WorkflowCreateResponse, _a1 error) *AdminServiceServer_CreateWorkflow

type AdminServiceServer_CreateWorkflowEvent 

type AdminServiceServer_CreateWorkflowEvent struct {
	*mock.Call
}

func (AdminServiceServer_CreateWorkflowEvent) Return 

func (_m AdminServiceServer_CreateWorkflowEvent) Return(_a0 *admin.WorkflowExecutionEventResponse, _a1 error) *AdminServiceServer_CreateWorkflowEvent

type AdminServiceServer_DeleteProjectAttributes 

type AdminServiceServer_DeleteProjectAttributes struct {
	*mock.Call
}

func (AdminServiceServer_DeleteProjectAttributes) Return 

func (_m AdminServiceServer_DeleteProjectAttributes) Return(_a0 *admin.ProjectAttributesDeleteResponse, _a1 error) *AdminServiceServer_DeleteProjectAttributes

type AdminServiceServer_DeleteProjectDomainAttributes 

type AdminServiceServer_DeleteProjectDomainAttributes struct {
	*mock.Call
}

func (AdminServiceServer_DeleteProjectDomainAttributes) Return 

func (_m AdminServiceServer_DeleteProjectDomainAttributes) Return(_a0 *admin.ProjectDomainAttributesDeleteResponse, _a1 error) *AdminServiceServer_DeleteProjectDomainAttributes

type AdminServiceServer_DeleteWorkflowAttributes 

type AdminServiceServer_DeleteWorkflowAttributes struct {
	*mock.Call
}

func (AdminServiceServer_DeleteWorkflowAttributes) Return 

func (_m AdminServiceServer_DeleteWorkflowAttributes) Return(_a0 *admin.WorkflowAttributesDeleteResponse, _a1 error) *AdminServiceServer_DeleteWorkflowAttributes

type AdminServiceServer_GetActiveLaunchPlan 

type AdminServiceServer_GetActiveLaunchPlan struct {
	*mock.Call
}

func (AdminServiceServer_GetActiveLaunchPlan) Return 

func (_m AdminServiceServer_GetActiveLaunchPlan) Return(_a0 *admin.LaunchPlan, _a1 error) *AdminServiceServer_GetActiveLaunchPlan

type AdminServiceServer_GetDescriptionEntity 

type AdminServiceServer_GetDescriptionEntity struct {
	*mock.Call
}

func (AdminServiceServer_GetDescriptionEntity) Return 

func (_m AdminServiceServer_GetDescriptionEntity) Return(_a0 *admin.DescriptionEntity, _a1 error) *AdminServiceServer_GetDescriptionEntity

type AdminServiceServer_GetDomains added in v1.13.0 

type AdminServiceServer_GetDomains struct {
	*mock.Call
}

func (AdminServiceServer_GetDomains) Return added in v1.13.0 

func (_m AdminServiceServer_GetDomains) Return(_a0 *admin.GetDomainsResponse, _a1 error) *AdminServiceServer_GetDomains

type AdminServiceServer_GetDynamicNodeWorkflow added in v1.10.7 

type AdminServiceServer_GetDynamicNodeWorkflow struct {
	*mock.Call
}

func (AdminServiceServer_GetDynamicNodeWorkflow) Return added in v1.10.7 

func (_m AdminServiceServer_GetDynamicNodeWorkflow) Return(_a0 *admin.DynamicNodeWorkflowResponse, _a1 error) *AdminServiceServer_GetDynamicNodeWorkflow

type AdminServiceServer_GetExecution 

type AdminServiceServer_GetExecution struct {
	*mock.Call
}

func (AdminServiceServer_GetExecution) Return 

func (_m AdminServiceServer_GetExecution) Return(_a0 *admin.Execution, _a1 error) *AdminServiceServer_GetExecution

type AdminServiceServer_GetExecutionData 

type AdminServiceServer_GetExecutionData struct {
	*mock.Call
}

func (AdminServiceServer_GetExecutionData) Return 

func (_m AdminServiceServer_GetExecutionData) Return(_a0 *admin.WorkflowExecutionGetDataResponse, _a1 error) *AdminServiceServer_GetExecutionData

type AdminServiceServer_GetExecutionMetrics 

type AdminServiceServer_GetExecutionMetrics struct {
	*mock.Call
}

func (AdminServiceServer_GetExecutionMetrics) Return 

func (_m AdminServiceServer_GetExecutionMetrics) Return(_a0 *admin.WorkflowExecutionGetMetricsResponse, _a1 error) *AdminServiceServer_GetExecutionMetrics

type AdminServiceServer_GetLaunchPlan 

type AdminServiceServer_GetLaunchPlan struct {
	*mock.Call
}

func (AdminServiceServer_GetLaunchPlan) Return 

func (_m AdminServiceServer_GetLaunchPlan) Return(_a0 *admin.LaunchPlan, _a1 error) *AdminServiceServer_GetLaunchPlan

type AdminServiceServer_GetNamedEntity 

type AdminServiceServer_GetNamedEntity struct {
	*mock.Call
}

func (AdminServiceServer_GetNamedEntity) Return 

func (_m AdminServiceServer_GetNamedEntity) Return(_a0 *admin.NamedEntity, _a1 error) *AdminServiceServer_GetNamedEntity

type AdminServiceServer_GetNodeExecution 

type AdminServiceServer_GetNodeExecution struct {
	*mock.Call
}

func (AdminServiceServer_GetNodeExecution) Return 

func (_m AdminServiceServer_GetNodeExecution) Return(_a0 *admin.NodeExecution, _a1 error) *AdminServiceServer_GetNodeExecution

type AdminServiceServer_GetNodeExecutionData 

type AdminServiceServer_GetNodeExecutionData struct {
	*mock.Call
}

func (AdminServiceServer_GetNodeExecutionData) Return 

func (_m AdminServiceServer_GetNodeExecutionData) Return(_a0 *admin.NodeExecutionGetDataResponse, _a1 error) *AdminServiceServer_GetNodeExecutionData

type AdminServiceServer_GetProject added in v1.12.0 

type AdminServiceServer_GetProject struct {
	*mock.Call
}

func (AdminServiceServer_GetProject) Return added in v1.12.0 

func (_m AdminServiceServer_GetProject) Return(_a0 *admin.Project, _a1 error) *AdminServiceServer_GetProject

type AdminServiceServer_GetProjectAttributes 

type AdminServiceServer_GetProjectAttributes struct {
	*mock.Call
}

func (AdminServiceServer_GetProjectAttributes) Return 

func (_m AdminServiceServer_GetProjectAttributes) Return(_a0 *admin.ProjectAttributesGetResponse, _a1 error) *AdminServiceServer_GetProjectAttributes

type AdminServiceServer_GetProjectDomainAttributes 

type AdminServiceServer_GetProjectDomainAttributes struct {
	*mock.Call
}

func (AdminServiceServer_GetProjectDomainAttributes) Return 

func (_m AdminServiceServer_GetProjectDomainAttributes) Return(_a0 *admin.ProjectDomainAttributesGetResponse, _a1 error) *AdminServiceServer_GetProjectDomainAttributes

type AdminServiceServer_GetTask 

type AdminServiceServer_GetTask struct {
	*mock.Call
}

func (AdminServiceServer_GetTask) Return 

func (_m AdminServiceServer_GetTask) Return(_a0 *admin.Task, _a1 error) *AdminServiceServer_GetTask

type AdminServiceServer_GetTaskExecution 

type AdminServiceServer_GetTaskExecution struct {
	*mock.Call
}

func (AdminServiceServer_GetTaskExecution) Return 

func (_m AdminServiceServer_GetTaskExecution) Return(_a0 *admin.TaskExecution, _a1 error) *AdminServiceServer_GetTaskExecution

type AdminServiceServer_GetTaskExecutionData 

type AdminServiceServer_GetTaskExecutionData struct {
	*mock.Call
}

func (AdminServiceServer_GetTaskExecutionData) Return 

func (_m AdminServiceServer_GetTaskExecutionData) Return(_a0 *admin.TaskExecutionGetDataResponse, _a1 error) *AdminServiceServer_GetTaskExecutionData

type AdminServiceServer_GetVersion 

type AdminServiceServer_GetVersion struct {
	*mock.Call
}

func (AdminServiceServer_GetVersion) Return 

func (_m AdminServiceServer_GetVersion) Return(_a0 *admin.GetVersionResponse, _a1 error) *AdminServiceServer_GetVersion

type AdminServiceServer_GetWorkflow 

type AdminServiceServer_GetWorkflow struct {
	*mock.Call
}

func (AdminServiceServer_GetWorkflow) Return 

func (_m AdminServiceServer_GetWorkflow) Return(_a0 *admin.Workflow, _a1 error) *AdminServiceServer_GetWorkflow

type AdminServiceServer_GetWorkflowAttributes 

type AdminServiceServer_GetWorkflowAttributes struct {
	*mock.Call
}

func (AdminServiceServer_GetWorkflowAttributes) Return 

func (_m AdminServiceServer_GetWorkflowAttributes) Return(_a0 *admin.WorkflowAttributesGetResponse, _a1 error) *AdminServiceServer_GetWorkflowAttributes

type AdminServiceServer_ListActiveLaunchPlans 

type AdminServiceServer_ListActiveLaunchPlans struct {
	*mock.Call
}

func (AdminServiceServer_ListActiveLaunchPlans) Return 

func (_m AdminServiceServer_ListActiveLaunchPlans) Return(_a0 *admin.LaunchPlanList, _a1 error) *AdminServiceServer_ListActiveLaunchPlans

type AdminServiceServer_ListDescriptionEntities 

type AdminServiceServer_ListDescriptionEntities struct {
	*mock.Call
}

func (AdminServiceServer_ListDescriptionEntities) Return 

func (_m AdminServiceServer_ListDescriptionEntities) Return(_a0 *admin.DescriptionEntityList, _a1 error) *AdminServiceServer_ListDescriptionEntities

type AdminServiceServer_ListExecutions 

type AdminServiceServer_ListExecutions struct {
	*mock.Call
}

func (AdminServiceServer_ListExecutions) Return 

func (_m AdminServiceServer_ListExecutions) Return(_a0 *admin.ExecutionList, _a1 error) *AdminServiceServer_ListExecutions

type AdminServiceServer_ListLaunchPlanIds 

type AdminServiceServer_ListLaunchPlanIds struct {
	*mock.Call
}

func (AdminServiceServer_ListLaunchPlanIds) Return 

func (_m AdminServiceServer_ListLaunchPlanIds) Return(_a0 *admin.NamedEntityIdentifierList, _a1 error) *AdminServiceServer_ListLaunchPlanIds

type AdminServiceServer_ListLaunchPlans 

type AdminServiceServer_ListLaunchPlans struct {
	*mock.Call
}

func (AdminServiceServer_ListLaunchPlans) Return 

func (_m AdminServiceServer_ListLaunchPlans) Return(_a0 *admin.LaunchPlanList, _a1 error) *AdminServiceServer_ListLaunchPlans

type AdminServiceServer_ListMatchableAttributes 

type AdminServiceServer_ListMatchableAttributes struct {
	*mock.Call
}

func (AdminServiceServer_ListMatchableAttributes) Return 

func (_m AdminServiceServer_ListMatchableAttributes) Return(_a0 *admin.ListMatchableAttributesResponse, _a1 error) *AdminServiceServer_ListMatchableAttributes

type AdminServiceServer_ListNamedEntities 

type AdminServiceServer_ListNamedEntities struct {
	*mock.Call
}

func (AdminServiceServer_ListNamedEntities) Return 

func (_m AdminServiceServer_ListNamedEntities) Return(_a0 *admin.NamedEntityList, _a1 error) *AdminServiceServer_ListNamedEntities

type AdminServiceServer_ListNodeExecutions 

type AdminServiceServer_ListNodeExecutions struct {
	*mock.Call
}

func (AdminServiceServer_ListNodeExecutions) Return 

func (_m AdminServiceServer_ListNodeExecutions) Return(_a0 *admin.NodeExecutionList, _a1 error) *AdminServiceServer_ListNodeExecutions

type AdminServiceServer_ListNodeExecutionsForTask 

type AdminServiceServer_ListNodeExecutionsForTask struct {
	*mock.Call
}

func (AdminServiceServer_ListNodeExecutionsForTask) Return 

func (_m AdminServiceServer_ListNodeExecutionsForTask) Return(_a0 *admin.NodeExecutionList, _a1 error) *AdminServiceServer_ListNodeExecutionsForTask

type AdminServiceServer_ListProjects 

type AdminServiceServer_ListProjects struct {
	*mock.Call
}

func (AdminServiceServer_ListProjects) Return 

func (_m AdminServiceServer_ListProjects) Return(_a0 *admin.Projects, _a1 error) *AdminServiceServer_ListProjects

type AdminServiceServer_ListTaskExecutions 

type AdminServiceServer_ListTaskExecutions struct {
	*mock.Call
}

func (AdminServiceServer_ListTaskExecutions) Return 

func (_m AdminServiceServer_ListTaskExecutions) Return(_a0 *admin.TaskExecutionList, _a1 error) *AdminServiceServer_ListTaskExecutions

type AdminServiceServer_ListTaskIds 

type AdminServiceServer_ListTaskIds struct {
	*mock.Call
}

func (AdminServiceServer_ListTaskIds) Return 

func (_m AdminServiceServer_ListTaskIds) Return(_a0 *admin.NamedEntityIdentifierList, _a1 error) *AdminServiceServer_ListTaskIds

type AdminServiceServer_ListTasks 

type AdminServiceServer_ListTasks struct {
	*mock.Call
}

func (AdminServiceServer_ListTasks) Return 

func (_m AdminServiceServer_ListTasks) Return(_a0 *admin.TaskList, _a1 error) *AdminServiceServer_ListTasks

type AdminServiceServer_ListWorkflowIds 

type AdminServiceServer_ListWorkflowIds struct {
	*mock.Call
}

func (AdminServiceServer_ListWorkflowIds) Return 

func (_m AdminServiceServer_ListWorkflowIds) Return(_a0 *admin.NamedEntityIdentifierList, _a1 error) *AdminServiceServer_ListWorkflowIds

type AdminServiceServer_ListWorkflows 

type AdminServiceServer_ListWorkflows struct {
	*mock.Call
}

func (AdminServiceServer_ListWorkflows) Return 

func (_m AdminServiceServer_ListWorkflows) Return(_a0 *admin.WorkflowList, _a1 error) *AdminServiceServer_ListWorkflows

type AdminServiceServer_RecoverExecution 

type AdminServiceServer_RecoverExecution struct {
	*mock.Call
}

func (AdminServiceServer_RecoverExecution) Return 

func (_m AdminServiceServer_RecoverExecution) Return(_a0 *admin.ExecutionCreateResponse, _a1 error) *AdminServiceServer_RecoverExecution

type AdminServiceServer_RegisterProject 

type AdminServiceServer_RegisterProject struct {
	*mock.Call
}

func (AdminServiceServer_RegisterProject) Return 

func (_m AdminServiceServer_RegisterProject) Return(_a0 *admin.ProjectRegisterResponse, _a1 error) *AdminServiceServer_RegisterProject

type AdminServiceServer_RelaunchExecution 

type AdminServiceServer_RelaunchExecution struct {
	*mock.Call
}

func (AdminServiceServer_RelaunchExecution) Return 

func (_m AdminServiceServer_RelaunchExecution) Return(_a0 *admin.ExecutionCreateResponse, _a1 error) *AdminServiceServer_RelaunchExecution

type AdminServiceServer_TerminateExecution 

type AdminServiceServer_TerminateExecution struct {
	*mock.Call
}

func (AdminServiceServer_TerminateExecution) Return 

func (_m AdminServiceServer_TerminateExecution) Return(_a0 *admin.ExecutionTerminateResponse, _a1 error) *AdminServiceServer_TerminateExecution

type AdminServiceServer_UpdateExecution 

type AdminServiceServer_UpdateExecution struct {
	*mock.Call
}

func (AdminServiceServer_UpdateExecution) Return 

func (_m AdminServiceServer_UpdateExecution) Return(_a0 *admin.ExecutionUpdateResponse, _a1 error) *AdminServiceServer_UpdateExecution

type AdminServiceServer_UpdateLaunchPlan 

type AdminServiceServer_UpdateLaunchPlan struct {
	*mock.Call
}

func (AdminServiceServer_UpdateLaunchPlan) Return 

func (_m AdminServiceServer_UpdateLaunchPlan) Return(_a0 *admin.LaunchPlanUpdateResponse, _a1 error) *AdminServiceServer_UpdateLaunchPlan

type AdminServiceServer_UpdateNamedEntity 

type AdminServiceServer_UpdateNamedEntity struct {
	*mock.Call
}

func (AdminServiceServer_UpdateNamedEntity) Return 

func (_m AdminServiceServer_UpdateNamedEntity) Return(_a0 *admin.NamedEntityUpdateResponse, _a1 error) *AdminServiceServer_UpdateNamedEntity

type AdminServiceServer_UpdateProject 

type AdminServiceServer_UpdateProject struct {
	*mock.Call
}

func (AdminServiceServer_UpdateProject) Return 

func (_m AdminServiceServer_UpdateProject) Return(_a0 *admin.ProjectUpdateResponse, _a1 error) *AdminServiceServer_UpdateProject

type AdminServiceServer_UpdateProjectAttributes 

type AdminServiceServer_UpdateProjectAttributes struct {
	*mock.Call
}

func (AdminServiceServer_UpdateProjectAttributes) Return 

func (_m AdminServiceServer_UpdateProjectAttributes) Return(_a0 *admin.ProjectAttributesUpdateResponse, _a1 error) *AdminServiceServer_UpdateProjectAttributes

type AdminServiceServer_UpdateProjectDomainAttributes 

type AdminServiceServer_UpdateProjectDomainAttributes struct {
	*mock.Call
}

func (AdminServiceServer_UpdateProjectDomainAttributes) Return 

func (_m AdminServiceServer_UpdateProjectDomainAttributes) Return(_a0 *admin.ProjectDomainAttributesUpdateResponse, _a1 error) *AdminServiceServer_UpdateProjectDomainAttributes

type AdminServiceServer_UpdateWorkflowAttributes 

type AdminServiceServer_UpdateWorkflowAttributes struct {
	*mock.Call
}

func (AdminServiceServer_UpdateWorkflowAttributes) Return 

func (_m AdminServiceServer_UpdateWorkflowAttributes) Return(_a0 *admin.WorkflowAttributesUpdateResponse, _a1 error) *AdminServiceServer_UpdateWorkflowAttributes

type AgentMetadataServiceClient added in v1.10.7 

type AgentMetadataServiceClient struct {
	mock.Mock
}

AgentMetadataServiceClient is an autogenerated mock type for the AgentMetadataServiceClient type

func (*AgentMetadataServiceClient) GetAgent added in v1.10.7 

func (_m *AgentMetadataServiceClient) GetAgent(ctx context.Context, in *admin.GetAgentRequest, opts ...grpc.CallOption) (*admin.GetAgentResponse, error)

GetAgent provides a mock function with given fields: ctx, in, opts

func (*AgentMetadataServiceClient) ListAgents added in v1.10.7 

func (_m *AgentMetadataServiceClient) ListAgents(ctx context.Context, in *admin.ListAgentsRequest, opts ...grpc.CallOption) (*admin.ListAgentsResponse, error)

ListAgents provides a mock function with given fields: ctx, in, opts

func (*AgentMetadataServiceClient) OnGetAgent added in v1.10.7 

func (_m *AgentMetadataServiceClient) OnGetAgent(ctx context.Context, in *admin.GetAgentRequest, opts ...grpc.CallOption) *AgentMetadataServiceClient_GetAgent

func (*AgentMetadataServiceClient) OnGetAgentMatch added in v1.10.7 

func (_m *AgentMetadataServiceClient) OnGetAgentMatch(matchers ...interface{}) *AgentMetadataServiceClient_GetAgent

func (*AgentMetadataServiceClient) OnListAgents added in v1.10.7 

func (_m *AgentMetadataServiceClient) OnListAgents(ctx context.Context, in *admin.ListAgentsRequest, opts ...grpc.CallOption) *AgentMetadataServiceClient_ListAgents

func (*AgentMetadataServiceClient) OnListAgentsMatch added in v1.10.7 

func (_m *AgentMetadataServiceClient) OnListAgentsMatch(matchers ...interface{}) *AgentMetadataServiceClient_ListAgents

type AgentMetadataServiceClient_GetAgent added in v1.10.7 

type AgentMetadataServiceClient_GetAgent struct {
	*mock.Call
}

func (AgentMetadataServiceClient_GetAgent) Return added in v1.10.7 

func (_m AgentMetadataServiceClient_GetAgent) Return(_a0 *admin.GetAgentResponse, _a1 error) *AgentMetadataServiceClient_GetAgent

type AgentMetadataServiceClient_ListAgents added in v1.10.7 

type AgentMetadataServiceClient_ListAgents struct {
	*mock.Call
}

func (AgentMetadataServiceClient_ListAgents) Return added in v1.10.7 

func (_m AgentMetadataServiceClient_ListAgents) Return(_a0 *admin.ListAgentsResponse, _a1 error) *AgentMetadataServiceClient_ListAgents

type AgentMetadataServiceServer added in v1.10.7 

type AgentMetadataServiceServer struct {
	mock.Mock
}

AgentMetadataServiceServer is an autogenerated mock type for the AgentMetadataServiceServer type

func (*AgentMetadataServiceServer) GetAgent added in v1.10.7 

func (_m *AgentMetadataServiceServer) GetAgent(_a0 context.Context, _a1 *admin.GetAgentRequest) (*admin.GetAgentResponse, error)

GetAgent provides a mock function with given fields: _a0, _a1

func (*AgentMetadataServiceServer) ListAgents added in v1.10.7 

func (_m *AgentMetadataServiceServer) ListAgents(_a0 context.Context, _a1 *admin.ListAgentsRequest) (*admin.ListAgentsResponse, error)

ListAgents provides a mock function with given fields: _a0, _a1

func (*AgentMetadataServiceServer) OnGetAgent added in v1.10.7 

func (_m *AgentMetadataServiceServer) OnGetAgent(_a0 context.Context, _a1 *admin.GetAgentRequest) *AgentMetadataServiceServer_GetAgent

func (*AgentMetadataServiceServer) OnGetAgentMatch added in v1.10.7 

func (_m *AgentMetadataServiceServer) OnGetAgentMatch(matchers ...interface{}) *AgentMetadataServiceServer_GetAgent

func (*AgentMetadataServiceServer) OnListAgents added in v1.10.7 

func (_m *AgentMetadataServiceServer) OnListAgents(_a0 context.Context, _a1 *admin.ListAgentsRequest) *AgentMetadataServiceServer_ListAgents

func (*AgentMetadataServiceServer) OnListAgentsMatch added in v1.10.7 

func (_m *AgentMetadataServiceServer) OnListAgentsMatch(matchers ...interface{}) *AgentMetadataServiceServer_ListAgents

type AgentMetadataServiceServer_GetAgent added in v1.10.7 

type AgentMetadataServiceServer_GetAgent struct {
	*mock.Call
}

func (AgentMetadataServiceServer_GetAgent) Return added in v1.10.7 

func (_m AgentMetadataServiceServer_GetAgent) Return(_a0 *admin.GetAgentResponse, _a1 error) *AgentMetadataServiceServer_GetAgent

type AgentMetadataServiceServer_ListAgents added in v1.10.7 

type AgentMetadataServiceServer_ListAgents struct {
	*mock.Call
}

func (AgentMetadataServiceServer_ListAgents) Return added in v1.10.7 

func (_m AgentMetadataServiceServer_ListAgents) Return(_a0 *admin.ListAgentsResponse, _a1 error) *AgentMetadataServiceServer_ListAgents

type AgentServiceClient 

type AgentServiceClient struct {
	mock.Mock
}

AgentServiceClient is an autogenerated mock type for the AgentServiceClient type

func (*AgentServiceClient) CreateTask 

func (_m *AgentServiceClient) CreateTask(ctx context.Context, in *admin.CreateTaskRequest, opts ...grpc.CallOption) (*admin.CreateTaskResponse, error)

CreateTask provides a mock function with given fields: ctx, in, opts

func (*AgentServiceClient) DeleteTask 

func (_m *AgentServiceClient) DeleteTask(ctx context.Context, in *admin.DeleteTaskRequest, opts ...grpc.CallOption) (*admin.DeleteTaskResponse, error)

DeleteTask provides a mock function with given fields: ctx, in, opts

func (*AgentServiceClient) GetTask 

func (_m *AgentServiceClient) GetTask(ctx context.Context, in *admin.GetTaskRequest, opts ...grpc.CallOption) (*admin.GetTaskResponse, error)

GetTask provides a mock function with given fields: ctx, in, opts

func (*AgentServiceClient) OnCreateTask 

func (_m *AgentServiceClient) OnCreateTask(ctx context.Context, in *admin.CreateTaskRequest, opts ...grpc.CallOption) *AgentServiceClient_CreateTask

func (*AgentServiceClient) OnCreateTaskMatch 

func (_m *AgentServiceClient) OnCreateTaskMatch(matchers ...interface{}) *AgentServiceClient_CreateTask

func (*AgentServiceClient) OnDeleteTask 

func (_m *AgentServiceClient) OnDeleteTask(ctx context.Context, in *admin.DeleteTaskRequest, opts ...grpc.CallOption) *AgentServiceClient_DeleteTask

func (*AgentServiceClient) OnDeleteTaskMatch 

func (_m *AgentServiceClient) OnDeleteTaskMatch(matchers ...interface{}) *AgentServiceClient_DeleteTask

func (*AgentServiceClient) OnGetTask 

func (_m *AgentServiceClient) OnGetTask(ctx context.Context, in *admin.GetTaskRequest, opts ...grpc.CallOption) *AgentServiceClient_GetTask

func (*AgentServiceClient) OnGetTaskMatch 

func (_m *AgentServiceClient) OnGetTaskMatch(matchers ...interface{}) *AgentServiceClient_GetTask

type AgentServiceClient_CreateTask 

type AgentServiceClient_CreateTask struct {
	*mock.Call
}

func (AgentServiceClient_CreateTask) Return 

func (_m AgentServiceClient_CreateTask) Return(_a0 *admin.CreateTaskResponse, _a1 error) *AgentServiceClient_CreateTask

type AgentServiceClient_DeleteTask 

type AgentServiceClient_DeleteTask struct {
	*mock.Call
}

func (AgentServiceClient_DeleteTask) Return 

func (_m AgentServiceClient_DeleteTask) Return(_a0 *admin.DeleteTaskResponse, _a1 error) *AgentServiceClient_DeleteTask

type AgentServiceClient_GetTask 

type AgentServiceClient_GetTask struct {
	*mock.Call
}

func (AgentServiceClient_GetTask) Return 

func (_m AgentServiceClient_GetTask) Return(_a0 *admin.GetTaskResponse, _a1 error) *AgentServiceClient_GetTask

type AgentServiceServer 

type AgentServiceServer struct {
	mock.Mock
}

AgentServiceServer is an autogenerated mock type for the AgentServiceServer type

func (*AgentServiceServer) CreateTask 

func (_m *AgentServiceServer) CreateTask(_a0 context.Context, _a1 *admin.CreateTaskRequest) (*admin.CreateTaskResponse, error)

CreateTask provides a mock function with given fields: _a0, _a1

func (*AgentServiceServer) DeleteTask 

func (_m *AgentServiceServer) DeleteTask(_a0 context.Context, _a1 *admin.DeleteTaskRequest) (*admin.DeleteTaskResponse, error)

DeleteTask provides a mock function with given fields: _a0, _a1

func (*AgentServiceServer) GetTask 

func (_m *AgentServiceServer) GetTask(_a0 context.Context, _a1 *admin.GetTaskRequest) (*admin.GetTaskResponse, error)

GetTask provides a mock function with given fields: _a0, _a1

func (*AgentServiceServer) OnCreateTask 

func (_m *AgentServiceServer) OnCreateTask(_a0 context.Context, _a1 *admin.CreateTaskRequest) *AgentServiceServer_CreateTask

func (*AgentServiceServer) OnCreateTaskMatch 

func (_m *AgentServiceServer) OnCreateTaskMatch(matchers ...interface{}) *AgentServiceServer_CreateTask

func (*AgentServiceServer) OnDeleteTask 

func (_m *AgentServiceServer) OnDeleteTask(_a0 context.Context, _a1 *admin.DeleteTaskRequest) *AgentServiceServer_DeleteTask

func (*AgentServiceServer) OnDeleteTaskMatch 

func (_m *AgentServiceServer) OnDeleteTaskMatch(matchers ...interface{}) *AgentServiceServer_DeleteTask

func (*AgentServiceServer) OnGetTask 

func (_m *AgentServiceServer) OnGetTask(_a0 context.Context, _a1 *admin.GetTaskRequest) *AgentServiceServer_GetTask

func (*AgentServiceServer) OnGetTaskMatch 

func (_m *AgentServiceServer) OnGetTaskMatch(matchers ...interface{}) *AgentServiceServer_GetTask

type AgentServiceServer_CreateTask 

type AgentServiceServer_CreateTask struct {
	*mock.Call
}

func (AgentServiceServer_CreateTask) Return 

func (_m AgentServiceServer_CreateTask) Return(_a0 *admin.CreateTaskResponse, _a1 error) *AgentServiceServer_CreateTask

type AgentServiceServer_DeleteTask 

type AgentServiceServer_DeleteTask struct {
	*mock.Call
}

func (AgentServiceServer_DeleteTask) Return 

func (_m AgentServiceServer_DeleteTask) Return(_a0 *admin.DeleteTaskResponse, _a1 error) *AgentServiceServer_DeleteTask

type AgentServiceServer_GetTask 

type AgentServiceServer_GetTask struct {
	*mock.Call
}

func (AgentServiceServer_GetTask) Return 

func (_m AgentServiceServer_GetTask) Return(_a0 *admin.GetTaskResponse, _a1 error) *AgentServiceServer_GetTask

type AsyncAgentServiceClient 

type AsyncAgentServiceClient struct {
	mock.Mock
}

AsyncAgentServiceClient is an autogenerated mock type for the AsyncAgentServiceClient type

func (*AsyncAgentServiceClient) CreateTask 

func (_m *AsyncAgentServiceClient) CreateTask(ctx context.Context, in *admin.CreateTaskRequest, opts ...grpc.CallOption) (*admin.CreateTaskResponse, error)

CreateTask provides a mock function with given fields: ctx, in, opts

func (*AsyncAgentServiceClient) DeleteTask 

func (_m *AsyncAgentServiceClient) DeleteTask(ctx context.Context, in *admin.DeleteTaskRequest, opts ...grpc.CallOption) (*admin.DeleteTaskResponse, error)

DeleteTask provides a mock function with given fields: ctx, in, opts

func (*AsyncAgentServiceClient) GetTask 

func (_m *AsyncAgentServiceClient) GetTask(ctx context.Context, in *admin.GetTaskRequest, opts ...grpc.CallOption) (*admin.GetTaskResponse, error)

GetTask provides a mock function with given fields: ctx, in, opts

func (*AsyncAgentServiceClient) GetTaskLogs added in v1.10.7 

func (_m *AsyncAgentServiceClient) GetTaskLogs(ctx context.Context, in *admin.GetTaskLogsRequest, opts ...grpc.CallOption) (service.AsyncAgentService_GetTaskLogsClient, error)

GetTaskLogs provides a mock function with given fields: ctx, in, opts

func (*AsyncAgentServiceClient) GetTaskMetrics added in v1.10.7 

func (_m *AsyncAgentServiceClient) GetTaskMetrics(ctx context.Context, in *admin.GetTaskMetricsRequest, opts ...grpc.CallOption) (*admin.GetTaskMetricsResponse, error)

GetTaskMetrics provides a mock function with given fields: ctx, in, opts

func (*AsyncAgentServiceClient) OnCreateTask 

func (_m *AsyncAgentServiceClient) OnCreateTask(ctx context.Context, in *admin.CreateTaskRequest, opts ...grpc.CallOption) *AsyncAgentServiceClient_CreateTask

func (*AsyncAgentServiceClient) OnCreateTaskMatch 

func (_m *AsyncAgentServiceClient) OnCreateTaskMatch(matchers ...interface{}) *AsyncAgentServiceClient_CreateTask

func (*AsyncAgentServiceClient) OnDeleteTask 

func (_m *AsyncAgentServiceClient) OnDeleteTask(ctx context.Context, in *admin.DeleteTaskRequest, opts ...grpc.CallOption) *AsyncAgentServiceClient_DeleteTask

func (*AsyncAgentServiceClient) OnDeleteTaskMatch 

func (_m *AsyncAgentServiceClient) OnDeleteTaskMatch(matchers ...interface{}) *AsyncAgentServiceClient_DeleteTask

func (*AsyncAgentServiceClient) OnGetTask 

func (_m *AsyncAgentServiceClient) OnGetTask(ctx context.Context, in *admin.GetTaskRequest, opts ...grpc.CallOption) *AsyncAgentServiceClient_GetTask

func (*AsyncAgentServiceClient) OnGetTaskLogs added in v1.10.7 

func (_m *AsyncAgentServiceClient) OnGetTaskLogs(ctx context.Context, in *admin.GetTaskLogsRequest, opts ...grpc.CallOption) *AsyncAgentServiceClient_GetTaskLogs

func (*AsyncAgentServiceClient) OnGetTaskLogsMatch added in v1.10.7 

func (_m *AsyncAgentServiceClient) OnGetTaskLogsMatch(matchers ...interface{}) *AsyncAgentServiceClient_GetTaskLogs

func (*AsyncAgentServiceClient) OnGetTaskMatch 

func (_m *AsyncAgentServiceClient) OnGetTaskMatch(matchers ...interface{}) *AsyncAgentServiceClient_GetTask

func (*AsyncAgentServiceClient) OnGetTaskMetrics added in v1.10.7 

func (_m *AsyncAgentServiceClient) OnGetTaskMetrics(ctx context.Context, in *admin.GetTaskMetricsRequest, opts ...grpc.CallOption) *AsyncAgentServiceClient_GetTaskMetrics

func (*AsyncAgentServiceClient) OnGetTaskMetricsMatch added in v1.10.7 

func (_m *AsyncAgentServiceClient) OnGetTaskMetricsMatch(matchers ...interface{}) *AsyncAgentServiceClient_GetTaskMetrics

type AsyncAgentServiceClient_CreateTask 

type AsyncAgentServiceClient_CreateTask struct {
	*mock.Call
}

func (AsyncAgentServiceClient_CreateTask) Return 

func (_m AsyncAgentServiceClient_CreateTask) Return(_a0 *admin.CreateTaskResponse, _a1 error) *AsyncAgentServiceClient_CreateTask

type AsyncAgentServiceClient_DeleteTask 

type AsyncAgentServiceClient_DeleteTask struct {
	*mock.Call
}

func (AsyncAgentServiceClient_DeleteTask) Return 

func (_m AsyncAgentServiceClient_DeleteTask) Return(_a0 *admin.DeleteTaskResponse, _a1 error) *AsyncAgentServiceClient_DeleteTask

type AsyncAgentServiceClient_GetTask 

type AsyncAgentServiceClient_GetTask struct {
	*mock.Call
}

func (AsyncAgentServiceClient_GetTask) Return 

func (_m AsyncAgentServiceClient_GetTask) Return(_a0 *admin.GetTaskResponse, _a1 error) *AsyncAgentServiceClient_GetTask

type AsyncAgentServiceClient_GetTaskLogs added in v1.10.7 

type AsyncAgentServiceClient_GetTaskLogs struct {
	*mock.Call
}

func (AsyncAgentServiceClient_GetTaskLogs) Return added in v1.10.7 

func (_m AsyncAgentServiceClient_GetTaskLogs) Return(_a0 service.AsyncAgentService_GetTaskLogsClient, _a1 error) *AsyncAgentServiceClient_GetTaskLogs

type AsyncAgentServiceClient_GetTaskMetrics added in v1.10.7 

type AsyncAgentServiceClient_GetTaskMetrics struct {
	*mock.Call
}

func (AsyncAgentServiceClient_GetTaskMetrics) Return added in v1.10.7 

func (_m AsyncAgentServiceClient_GetTaskMetrics) Return(_a0 *admin.GetTaskMetricsResponse, _a1 error) *AsyncAgentServiceClient_GetTaskMetrics

type AsyncAgentServiceServer 

type AsyncAgentServiceServer struct {
	mock.Mock
}

AsyncAgentServiceServer is an autogenerated mock type for the AsyncAgentServiceServer type

func (*AsyncAgentServiceServer) CreateTask 

func (_m *AsyncAgentServiceServer) CreateTask(_a0 context.Context, _a1 *admin.CreateTaskRequest) (*admin.CreateTaskResponse, error)

CreateTask provides a mock function with given fields: _a0, _a1

func (*AsyncAgentServiceServer) DeleteTask 

func (_m *AsyncAgentServiceServer) DeleteTask(_a0 context.Context, _a1 *admin.DeleteTaskRequest) (*admin.DeleteTaskResponse, error)

DeleteTask provides a mock function with given fields: _a0, _a1

func (*AsyncAgentServiceServer) GetTask 

func (_m *AsyncAgentServiceServer) GetTask(_a0 context.Context, _a1 *admin.GetTaskRequest) (*admin.GetTaskResponse, error)

GetTask provides a mock function with given fields: _a0, _a1

func (*AsyncAgentServiceServer) GetTaskLogs added in v1.10.7 

func (_m *AsyncAgentServiceServer) GetTaskLogs(_a0 *admin.GetTaskLogsRequest, _a1 service.AsyncAgentService_GetTaskLogsServer) error

GetTaskLogs provides a mock function with given fields: _a0, _a1

func (*AsyncAgentServiceServer) GetTaskMetrics added in v1.10.7 

func (_m *AsyncAgentServiceServer) GetTaskMetrics(_a0 context.Context, _a1 *admin.GetTaskMetricsRequest) (*admin.GetTaskMetricsResponse, error)

GetTaskMetrics provides a mock function with given fields: _a0, _a1

func (*AsyncAgentServiceServer) OnCreateTask 

func (_m *AsyncAgentServiceServer) OnCreateTask(_a0 context.Context, _a1 *admin.CreateTaskRequest) *AsyncAgentServiceServer_CreateTask

func (*AsyncAgentServiceServer) OnCreateTaskMatch 

func (_m *AsyncAgentServiceServer) OnCreateTaskMatch(matchers ...interface{}) *AsyncAgentServiceServer_CreateTask

func (*AsyncAgentServiceServer) OnDeleteTask 

func (_m *AsyncAgentServiceServer) OnDeleteTask(_a0 context.Context, _a1 *admin.DeleteTaskRequest) *AsyncAgentServiceServer_DeleteTask

func (*AsyncAgentServiceServer) OnDeleteTaskMatch 

func (_m *AsyncAgentServiceServer) OnDeleteTaskMatch(matchers ...interface{}) *AsyncAgentServiceServer_DeleteTask

func (*AsyncAgentServiceServer) OnGetTask 

func (_m *AsyncAgentServiceServer) OnGetTask(_a0 context.Context, _a1 *admin.GetTaskRequest) *AsyncAgentServiceServer_GetTask

func (*AsyncAgentServiceServer) OnGetTaskLogs added in v1.10.7 

func (_m *AsyncAgentServiceServer) OnGetTaskLogs(_a0 *admin.GetTaskLogsRequest, _a1 service.AsyncAgentService_GetTaskLogsServer) *AsyncAgentServiceServer_GetTaskLogs

func (*AsyncAgentServiceServer) OnGetTaskLogsMatch added in v1.10.7 

func (_m *AsyncAgentServiceServer) OnGetTaskLogsMatch(matchers ...interface{}) *AsyncAgentServiceServer_GetTaskLogs

func (*AsyncAgentServiceServer) OnGetTaskMatch 

func (_m *AsyncAgentServiceServer) OnGetTaskMatch(matchers ...interface{}) *AsyncAgentServiceServer_GetTask

func (*AsyncAgentServiceServer) OnGetTaskMetrics added in v1.10.7 

func (_m *AsyncAgentServiceServer) OnGetTaskMetrics(_a0 context.Context, _a1 *admin.GetTaskMetricsRequest) *AsyncAgentServiceServer_GetTaskMetrics

func (*AsyncAgentServiceServer) OnGetTaskMetricsMatch added in v1.10.7 

func (_m *AsyncAgentServiceServer) OnGetTaskMetricsMatch(matchers ...interface{}) *AsyncAgentServiceServer_GetTaskMetrics

type AsyncAgentServiceServer_CreateTask 

type AsyncAgentServiceServer_CreateTask struct {
	*mock.Call
}

func (AsyncAgentServiceServer_CreateTask) Return 

func (_m AsyncAgentServiceServer_CreateTask) Return(_a0 *admin.CreateTaskResponse, _a1 error) *AsyncAgentServiceServer_CreateTask

type AsyncAgentServiceServer_DeleteTask 

type AsyncAgentServiceServer_DeleteTask struct {
	*mock.Call
}

func (AsyncAgentServiceServer_DeleteTask) Return 

func (_m AsyncAgentServiceServer_DeleteTask) Return(_a0 *admin.DeleteTaskResponse, _a1 error) *AsyncAgentServiceServer_DeleteTask

type AsyncAgentServiceServer_GetTask 

type AsyncAgentServiceServer_GetTask struct {
	*mock.Call
}

func (AsyncAgentServiceServer_GetTask) Return 

func (_m AsyncAgentServiceServer_GetTask) Return(_a0 *admin.GetTaskResponse, _a1 error) *AsyncAgentServiceServer_GetTask

type AsyncAgentServiceServer_GetTaskLogs added in v1.10.7 

type AsyncAgentServiceServer_GetTaskLogs struct {
	*mock.Call
}

func (AsyncAgentServiceServer_GetTaskLogs) Return added in v1.10.7 

func (_m AsyncAgentServiceServer_GetTaskLogs) Return(_a0 error) *AsyncAgentServiceServer_GetTaskLogs

type AsyncAgentServiceServer_GetTaskMetrics added in v1.10.7 

type AsyncAgentServiceServer_GetTaskMetrics struct {
	*mock.Call
}

func (AsyncAgentServiceServer_GetTaskMetrics) Return added in v1.10.7 

func (_m AsyncAgentServiceServer_GetTaskMetrics) Return(_a0 *admin.GetTaskMetricsResponse, _a1 error) *AsyncAgentServiceServer_GetTaskMetrics

type AsyncAgentService_CreateTaskClient added in v1.11.0 

type AsyncAgentService_CreateTaskClient struct {
	mock.Mock
}

AsyncAgentService_CreateTaskClient is an autogenerated mock type for the AsyncAgentService_CreateTaskClient type

func (*AsyncAgentService_CreateTaskClient) CloseAndRecv added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) CloseAndRecv() (*admin.CreateTaskResponse, error)

CloseAndRecv provides a mock function with given fields:

func (*AsyncAgentService_CreateTaskClient) CloseSend added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) CloseSend() error

CloseSend provides a mock function with given fields:

func (*AsyncAgentService_CreateTaskClient) Context added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) Context() context.Context

Context provides a mock function with given fields:

func (*AsyncAgentService_CreateTaskClient) Header added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) Header() (metadata.MD, error)

Header provides a mock function with given fields:

func (*AsyncAgentService_CreateTaskClient) OnCloseAndRecv added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) OnCloseAndRecv() *AsyncAgentService_CreateTaskClient_CloseAndRecv

func (*AsyncAgentService_CreateTaskClient) OnCloseAndRecvMatch added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) OnCloseAndRecvMatch(matchers ...interface{}) *AsyncAgentService_CreateTaskClient_CloseAndRecv

func (*AsyncAgentService_CreateTaskClient) OnCloseSend added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) OnCloseSend() *AsyncAgentService_CreateTaskClient_CloseSend

func (*AsyncAgentService_CreateTaskClient) OnCloseSendMatch added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) OnCloseSendMatch(matchers ...interface{}) *AsyncAgentService_CreateTaskClient_CloseSend

func (*AsyncAgentService_CreateTaskClient) OnContext added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) OnContext() *AsyncAgentService_CreateTaskClient_Context

func (*AsyncAgentService_CreateTaskClient) OnContextMatch added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) OnContextMatch(matchers ...interface{}) *AsyncAgentService_CreateTaskClient_Context

func (*AsyncAgentService_CreateTaskClient) OnHeader added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) OnHeader() *AsyncAgentService_CreateTaskClient_Header

func (*AsyncAgentService_CreateTaskClient) OnHeaderMatch added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) OnHeaderMatch(matchers ...interface{}) *AsyncAgentService_CreateTaskClient_Header

func (*AsyncAgentService_CreateTaskClient) OnRecvMsg added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) OnRecvMsg(m interface{}) *AsyncAgentService_CreateTaskClient_RecvMsg

func (*AsyncAgentService_CreateTaskClient) OnRecvMsgMatch added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) OnRecvMsgMatch(matchers ...interface{}) *AsyncAgentService_CreateTaskClient_RecvMsg

func (*AsyncAgentService_CreateTaskClient) OnSend added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) OnSend(_a0 *admin.CreateTaskRequest) *AsyncAgentService_CreateTaskClient_Send

func (*AsyncAgentService_CreateTaskClient) OnSendMatch added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) OnSendMatch(matchers ...interface{}) *AsyncAgentService_CreateTaskClient_Send

func (*AsyncAgentService_CreateTaskClient) OnSendMsg added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) OnSendMsg(m interface{}) *AsyncAgentService_CreateTaskClient_SendMsg

func (*AsyncAgentService_CreateTaskClient) OnSendMsgMatch added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) OnSendMsgMatch(matchers ...interface{}) *AsyncAgentService_CreateTaskClient_SendMsg

func (*AsyncAgentService_CreateTaskClient) OnTrailer added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) OnTrailer() *AsyncAgentService_CreateTaskClient_Trailer

func (*AsyncAgentService_CreateTaskClient) OnTrailerMatch added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) OnTrailerMatch(matchers ...interface{}) *AsyncAgentService_CreateTaskClient_Trailer

func (*AsyncAgentService_CreateTaskClient) RecvMsg added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*AsyncAgentService_CreateTaskClient) Send added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) Send(_a0 *admin.CreateTaskRequest) error

Send provides a mock function with given fields: _a0

func (*AsyncAgentService_CreateTaskClient) SendMsg added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*AsyncAgentService_CreateTaskClient) Trailer added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskClient) Trailer() metadata.MD

Trailer provides a mock function with given fields:

type AsyncAgentService_CreateTaskClient_CloseAndRecv added in v1.11.0 

type AsyncAgentService_CreateTaskClient_CloseAndRecv struct {
	*mock.Call
}

func (AsyncAgentService_CreateTaskClient_CloseAndRecv) Return added in v1.11.0 

func (_m AsyncAgentService_CreateTaskClient_CloseAndRecv) Return(_a0 *admin.CreateTaskResponse, _a1 error) *AsyncAgentService_CreateTaskClient_CloseAndRecv

type AsyncAgentService_CreateTaskClient_CloseSend added in v1.11.0 

type AsyncAgentService_CreateTaskClient_CloseSend struct {
	*mock.Call
}

func (AsyncAgentService_CreateTaskClient_CloseSend) Return added in v1.11.0 

func (_m AsyncAgentService_CreateTaskClient_CloseSend) Return(_a0 error) *AsyncAgentService_CreateTaskClient_CloseSend

type AsyncAgentService_CreateTaskClient_Context added in v1.11.0 

type AsyncAgentService_CreateTaskClient_Context struct {
	*mock.Call
}

func (AsyncAgentService_CreateTaskClient_Context) Return added in v1.11.0 

func (_m AsyncAgentService_CreateTaskClient_Context) Return(_a0 context.Context) *AsyncAgentService_CreateTaskClient_Context

type AsyncAgentService_CreateTaskClient_Header added in v1.11.0 

type AsyncAgentService_CreateTaskClient_Header struct {
	*mock.Call
}

func (AsyncAgentService_CreateTaskClient_Header) Return added in v1.11.0 

func (_m AsyncAgentService_CreateTaskClient_Header) Return(_a0 metadata.MD, _a1 error) *AsyncAgentService_CreateTaskClient_Header

type AsyncAgentService_CreateTaskClient_RecvMsg added in v1.11.0 

type AsyncAgentService_CreateTaskClient_RecvMsg struct {
	*mock.Call
}

func (AsyncAgentService_CreateTaskClient_RecvMsg) Return added in v1.11.0 

func (_m AsyncAgentService_CreateTaskClient_RecvMsg) Return(_a0 error) *AsyncAgentService_CreateTaskClient_RecvMsg

type AsyncAgentService_CreateTaskClient_Send added in v1.11.0 

type AsyncAgentService_CreateTaskClient_Send struct {
	*mock.Call
}

func (AsyncAgentService_CreateTaskClient_Send) Return added in v1.11.0 

func (_m AsyncAgentService_CreateTaskClient_Send) Return(_a0 error) *AsyncAgentService_CreateTaskClient_Send

type AsyncAgentService_CreateTaskClient_SendMsg added in v1.11.0 

type AsyncAgentService_CreateTaskClient_SendMsg struct {
	*mock.Call
}

func (AsyncAgentService_CreateTaskClient_SendMsg) Return added in v1.11.0 

func (_m AsyncAgentService_CreateTaskClient_SendMsg) Return(_a0 error) *AsyncAgentService_CreateTaskClient_SendMsg

type AsyncAgentService_CreateTaskClient_Trailer added in v1.11.0 

type AsyncAgentService_CreateTaskClient_Trailer struct {
	*mock.Call
}

func (AsyncAgentService_CreateTaskClient_Trailer) Return added in v1.11.0 

func (_m AsyncAgentService_CreateTaskClient_Trailer) Return(_a0 metadata.MD) *AsyncAgentService_CreateTaskClient_Trailer

type AsyncAgentService_CreateTaskServer added in v1.11.0 

type AsyncAgentService_CreateTaskServer struct {
	mock.Mock
}

AsyncAgentService_CreateTaskServer is an autogenerated mock type for the AsyncAgentService_CreateTaskServer type

func (*AsyncAgentService_CreateTaskServer) Context added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) Context() context.Context

Context provides a mock function with given fields:

func (*AsyncAgentService_CreateTaskServer) OnContext added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) OnContext() *AsyncAgentService_CreateTaskServer_Context

func (*AsyncAgentService_CreateTaskServer) OnContextMatch added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) OnContextMatch(matchers ...interface{}) *AsyncAgentService_CreateTaskServer_Context

func (*AsyncAgentService_CreateTaskServer) OnRecv added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) OnRecv() *AsyncAgentService_CreateTaskServer_Recv

func (*AsyncAgentService_CreateTaskServer) OnRecvMatch added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) OnRecvMatch(matchers ...interface{}) *AsyncAgentService_CreateTaskServer_Recv

func (*AsyncAgentService_CreateTaskServer) OnRecvMsg added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) OnRecvMsg(m interface{}) *AsyncAgentService_CreateTaskServer_RecvMsg

func (*AsyncAgentService_CreateTaskServer) OnRecvMsgMatch added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) OnRecvMsgMatch(matchers ...interface{}) *AsyncAgentService_CreateTaskServer_RecvMsg

func (*AsyncAgentService_CreateTaskServer) OnSendAndClose added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) OnSendAndClose(_a0 *admin.CreateTaskResponse) *AsyncAgentService_CreateTaskServer_SendAndClose

func (*AsyncAgentService_CreateTaskServer) OnSendAndCloseMatch added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) OnSendAndCloseMatch(matchers ...interface{}) *AsyncAgentService_CreateTaskServer_SendAndClose

func (*AsyncAgentService_CreateTaskServer) OnSendHeader added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) OnSendHeader(_a0 metadata.MD) *AsyncAgentService_CreateTaskServer_SendHeader

func (*AsyncAgentService_CreateTaskServer) OnSendHeaderMatch added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) OnSendHeaderMatch(matchers ...interface{}) *AsyncAgentService_CreateTaskServer_SendHeader

func (*AsyncAgentService_CreateTaskServer) OnSendMsg added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) OnSendMsg(m interface{}) *AsyncAgentService_CreateTaskServer_SendMsg

func (*AsyncAgentService_CreateTaskServer) OnSendMsgMatch added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) OnSendMsgMatch(matchers ...interface{}) *AsyncAgentService_CreateTaskServer_SendMsg

func (*AsyncAgentService_CreateTaskServer) OnSetHeader added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) OnSetHeader(_a0 metadata.MD) *AsyncAgentService_CreateTaskServer_SetHeader

func (*AsyncAgentService_CreateTaskServer) OnSetHeaderMatch added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) OnSetHeaderMatch(matchers ...interface{}) *AsyncAgentService_CreateTaskServer_SetHeader

func (*AsyncAgentService_CreateTaskServer) Recv added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) Recv() (*admin.CreateTaskRequest, error)

Recv provides a mock function with given fields:

func (*AsyncAgentService_CreateTaskServer) RecvMsg added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*AsyncAgentService_CreateTaskServer) SendAndClose added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) SendAndClose(_a0 *admin.CreateTaskResponse) error

SendAndClose provides a mock function with given fields: _a0

func (*AsyncAgentService_CreateTaskServer) SendHeader added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) SendHeader(_a0 metadata.MD) error

SendHeader provides a mock function with given fields: _a0

func (*AsyncAgentService_CreateTaskServer) SendMsg added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*AsyncAgentService_CreateTaskServer) SetHeader added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) SetHeader(_a0 metadata.MD) error

SetHeader provides a mock function with given fields: _a0

func (*AsyncAgentService_CreateTaskServer) SetTrailer added in v1.11.0 

func (_m *AsyncAgentService_CreateTaskServer) SetTrailer(_a0 metadata.MD)

SetTrailer provides a mock function with given fields: _a0

type AsyncAgentService_CreateTaskServer_Context added in v1.11.0 

type AsyncAgentService_CreateTaskServer_Context struct {
	*mock.Call
}

func (AsyncAgentService_CreateTaskServer_Context) Return added in v1.11.0 

func (_m AsyncAgentService_CreateTaskServer_Context) Return(_a0 context.Context) *AsyncAgentService_CreateTaskServer_Context

type AsyncAgentService_CreateTaskServer_Recv added in v1.11.0 

type AsyncAgentService_CreateTaskServer_Recv struct {
	*mock.Call
}

func (AsyncAgentService_CreateTaskServer_Recv) Return added in v1.11.0 

func (_m AsyncAgentService_CreateTaskServer_Recv) Return(_a0 *admin.CreateTaskRequest, _a1 error) *AsyncAgentService_CreateTaskServer_Recv

type AsyncAgentService_CreateTaskServer_RecvMsg added in v1.11.0 

type AsyncAgentService_CreateTaskServer_RecvMsg struct {
	*mock.Call
}

func (AsyncAgentService_CreateTaskServer_RecvMsg) Return added in v1.11.0 

func (_m AsyncAgentService_CreateTaskServer_RecvMsg) Return(_a0 error) *AsyncAgentService_CreateTaskServer_RecvMsg

type AsyncAgentService_CreateTaskServer_SendAndClose added in v1.11.0 

type AsyncAgentService_CreateTaskServer_SendAndClose struct {
	*mock.Call
}

func (AsyncAgentService_CreateTaskServer_SendAndClose) Return added in v1.11.0 

func (_m AsyncAgentService_CreateTaskServer_SendAndClose) Return(_a0 error) *AsyncAgentService_CreateTaskServer_SendAndClose

type AsyncAgentService_CreateTaskServer_SendHeader added in v1.11.0 

type AsyncAgentService_CreateTaskServer_SendHeader struct {
	*mock.Call
}

func (AsyncAgentService_CreateTaskServer_SendHeader) Return added in v1.11.0 

func (_m AsyncAgentService_CreateTaskServer_SendHeader) Return(_a0 error) *AsyncAgentService_CreateTaskServer_SendHeader

type AsyncAgentService_CreateTaskServer_SendMsg added in v1.11.0 

type AsyncAgentService_CreateTaskServer_SendMsg struct {
	*mock.Call
}

func (AsyncAgentService_CreateTaskServer_SendMsg) Return added in v1.11.0 

func (_m AsyncAgentService_CreateTaskServer_SendMsg) Return(_a0 error) *AsyncAgentService_CreateTaskServer_SendMsg

type AsyncAgentService_CreateTaskServer_SetHeader added in v1.11.0 

type AsyncAgentService_CreateTaskServer_SetHeader struct {
	*mock.Call
}

func (AsyncAgentService_CreateTaskServer_SetHeader) Return added in v1.11.0 

func (_m AsyncAgentService_CreateTaskServer_SetHeader) Return(_a0 error) *AsyncAgentService_CreateTaskServer_SetHeader

type AsyncAgentService_ExecuteTaskSyncClient added in v1.11.0 

type AsyncAgentService_ExecuteTaskSyncClient struct {
	mock.Mock
}

AsyncAgentService_ExecuteTaskSyncClient is an autogenerated mock type for the AsyncAgentService_ExecuteTaskSyncClient type

func (*AsyncAgentService_ExecuteTaskSyncClient) CloseSend added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) CloseSend() error

CloseSend provides a mock function with given fields:

func (*AsyncAgentService_ExecuteTaskSyncClient) Context added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) Context() context.Context

Context provides a mock function with given fields:

func (*AsyncAgentService_ExecuteTaskSyncClient) Header added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) Header() (metadata.MD, error)

Header provides a mock function with given fields:

func (*AsyncAgentService_ExecuteTaskSyncClient) OnCloseSend added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) OnCloseSend() *AsyncAgentService_ExecuteTaskSyncClient_CloseSend

func (*AsyncAgentService_ExecuteTaskSyncClient) OnCloseSendMatch added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) OnCloseSendMatch(matchers ...interface{}) *AsyncAgentService_ExecuteTaskSyncClient_CloseSend

func (*AsyncAgentService_ExecuteTaskSyncClient) OnContext added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) OnContext() *AsyncAgentService_ExecuteTaskSyncClient_Context

func (*AsyncAgentService_ExecuteTaskSyncClient) OnContextMatch added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) OnContextMatch(matchers ...interface{}) *AsyncAgentService_ExecuteTaskSyncClient_Context

func (*AsyncAgentService_ExecuteTaskSyncClient) OnHeader added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) OnHeader() *AsyncAgentService_ExecuteTaskSyncClient_Header

func (*AsyncAgentService_ExecuteTaskSyncClient) OnHeaderMatch added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) OnHeaderMatch(matchers ...interface{}) *AsyncAgentService_ExecuteTaskSyncClient_Header

func (*AsyncAgentService_ExecuteTaskSyncClient) OnRecv added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) OnRecv() *AsyncAgentService_ExecuteTaskSyncClient_Recv

func (*AsyncAgentService_ExecuteTaskSyncClient) OnRecvMatch added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) OnRecvMatch(matchers ...interface{}) *AsyncAgentService_ExecuteTaskSyncClient_Recv

func (*AsyncAgentService_ExecuteTaskSyncClient) OnRecvMsg added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) OnRecvMsg(m interface{}) *AsyncAgentService_ExecuteTaskSyncClient_RecvMsg

func (*AsyncAgentService_ExecuteTaskSyncClient) OnRecvMsgMatch added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) OnRecvMsgMatch(matchers ...interface{}) *AsyncAgentService_ExecuteTaskSyncClient_RecvMsg

func (*AsyncAgentService_ExecuteTaskSyncClient) OnSend added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) OnSend(_a0 *admin.ExecuteTaskSyncRequest) *AsyncAgentService_ExecuteTaskSyncClient_Send

func (*AsyncAgentService_ExecuteTaskSyncClient) OnSendMatch added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) OnSendMatch(matchers ...interface{}) *AsyncAgentService_ExecuteTaskSyncClient_Send

func (*AsyncAgentService_ExecuteTaskSyncClient) OnSendMsg added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) OnSendMsg(m interface{}) *AsyncAgentService_ExecuteTaskSyncClient_SendMsg

func (*AsyncAgentService_ExecuteTaskSyncClient) OnSendMsgMatch added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) OnSendMsgMatch(matchers ...interface{}) *AsyncAgentService_ExecuteTaskSyncClient_SendMsg

func (*AsyncAgentService_ExecuteTaskSyncClient) OnTrailer added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) OnTrailer() *AsyncAgentService_ExecuteTaskSyncClient_Trailer

func (*AsyncAgentService_ExecuteTaskSyncClient) OnTrailerMatch added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) OnTrailerMatch(matchers ...interface{}) *AsyncAgentService_ExecuteTaskSyncClient_Trailer

func (*AsyncAgentService_ExecuteTaskSyncClient) Recv added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) Recv() (*admin.ExecuteTaskSyncResponse, error)

Recv provides a mock function with given fields:

func (*AsyncAgentService_ExecuteTaskSyncClient) RecvMsg added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*AsyncAgentService_ExecuteTaskSyncClient) Send added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) Send(_a0 *admin.ExecuteTaskSyncRequest) error

Send provides a mock function with given fields: _a0

func (*AsyncAgentService_ExecuteTaskSyncClient) SendMsg added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*AsyncAgentService_ExecuteTaskSyncClient) Trailer added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncClient) Trailer() metadata.MD

Trailer provides a mock function with given fields:

type AsyncAgentService_ExecuteTaskSyncClient_CloseSend added in v1.11.0 

type AsyncAgentService_ExecuteTaskSyncClient_CloseSend struct {
	*mock.Call
}

func (AsyncAgentService_ExecuteTaskSyncClient_CloseSend) Return added in v1.11.0 

func (_m AsyncAgentService_ExecuteTaskSyncClient_CloseSend) Return(_a0 error) *AsyncAgentService_ExecuteTaskSyncClient_CloseSend

type AsyncAgentService_ExecuteTaskSyncClient_Context added in v1.11.0 

type AsyncAgentService_ExecuteTaskSyncClient_Context struct {
	*mock.Call
}

func (AsyncAgentService_ExecuteTaskSyncClient_Context) Return added in v1.11.0 

func (_m AsyncAgentService_ExecuteTaskSyncClient_Context) Return(_a0 context.Context) *AsyncAgentService_ExecuteTaskSyncClient_Context

type AsyncAgentService_ExecuteTaskSyncClient_Header added in v1.11.0 

type AsyncAgentService_ExecuteTaskSyncClient_Header struct {
	*mock.Call
}

func (AsyncAgentService_ExecuteTaskSyncClient_Header) Return added in v1.11.0 

func (_m AsyncAgentService_ExecuteTaskSyncClient_Header) Return(_a0 metadata.MD, _a1 error) *AsyncAgentService_ExecuteTaskSyncClient_Header

type AsyncAgentService_ExecuteTaskSyncClient_Recv added in v1.11.0 

type AsyncAgentService_ExecuteTaskSyncClient_Recv struct {
	*mock.Call
}

func (AsyncAgentService_ExecuteTaskSyncClient_Recv) Return added in v1.11.0 

func (_m AsyncAgentService_ExecuteTaskSyncClient_Recv) Return(_a0 *admin.ExecuteTaskSyncResponse, _a1 error) *AsyncAgentService_ExecuteTaskSyncClient_Recv

type AsyncAgentService_ExecuteTaskSyncClient_RecvMsg added in v1.11.0 

type AsyncAgentService_ExecuteTaskSyncClient_RecvMsg struct {
	*mock.Call
}

func (AsyncAgentService_ExecuteTaskSyncClient_RecvMsg) Return added in v1.11.0 

func (_m AsyncAgentService_ExecuteTaskSyncClient_RecvMsg) Return(_a0 error) *AsyncAgentService_ExecuteTaskSyncClient_RecvMsg

type AsyncAgentService_ExecuteTaskSyncClient_Send added in v1.11.0 

type AsyncAgentService_ExecuteTaskSyncClient_Send struct {
	*mock.Call
}

func (AsyncAgentService_ExecuteTaskSyncClient_Send) Return added in v1.11.0 

func (_m AsyncAgentService_ExecuteTaskSyncClient_Send) Return(_a0 error) *AsyncAgentService_ExecuteTaskSyncClient_Send

type AsyncAgentService_ExecuteTaskSyncClient_SendMsg added in v1.11.0 

type AsyncAgentService_ExecuteTaskSyncClient_SendMsg struct {
	*mock.Call
}

func (AsyncAgentService_ExecuteTaskSyncClient_SendMsg) Return added in v1.11.0 

func (_m AsyncAgentService_ExecuteTaskSyncClient_SendMsg) Return(_a0 error) *AsyncAgentService_ExecuteTaskSyncClient_SendMsg

type AsyncAgentService_ExecuteTaskSyncClient_Trailer added in v1.11.0 

type AsyncAgentService_ExecuteTaskSyncClient_Trailer struct {
	*mock.Call
}

func (AsyncAgentService_ExecuteTaskSyncClient_Trailer) Return added in v1.11.0 

func (_m AsyncAgentService_ExecuteTaskSyncClient_Trailer) Return(_a0 metadata.MD) *AsyncAgentService_ExecuteTaskSyncClient_Trailer

type AsyncAgentService_ExecuteTaskSyncServer added in v1.11.0 

type AsyncAgentService_ExecuteTaskSyncServer struct {
	mock.Mock
}

AsyncAgentService_ExecuteTaskSyncServer is an autogenerated mock type for the AsyncAgentService_ExecuteTaskSyncServer type

func (*AsyncAgentService_ExecuteTaskSyncServer) Context added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) Context() context.Context

Context provides a mock function with given fields:

func (*AsyncAgentService_ExecuteTaskSyncServer) OnContext added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) OnContext() *AsyncAgentService_ExecuteTaskSyncServer_Context

func (*AsyncAgentService_ExecuteTaskSyncServer) OnContextMatch added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) OnContextMatch(matchers ...interface{}) *AsyncAgentService_ExecuteTaskSyncServer_Context

func (*AsyncAgentService_ExecuteTaskSyncServer) OnRecv added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) OnRecv() *AsyncAgentService_ExecuteTaskSyncServer_Recv

func (*AsyncAgentService_ExecuteTaskSyncServer) OnRecvMatch added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) OnRecvMatch(matchers ...interface{}) *AsyncAgentService_ExecuteTaskSyncServer_Recv

func (*AsyncAgentService_ExecuteTaskSyncServer) OnRecvMsg added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) OnRecvMsg(m interface{}) *AsyncAgentService_ExecuteTaskSyncServer_RecvMsg

func (*AsyncAgentService_ExecuteTaskSyncServer) OnRecvMsgMatch added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) OnRecvMsgMatch(matchers ...interface{}) *AsyncAgentService_ExecuteTaskSyncServer_RecvMsg

func (*AsyncAgentService_ExecuteTaskSyncServer) OnSend added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) OnSend(_a0 *admin.ExecuteTaskSyncResponse) *AsyncAgentService_ExecuteTaskSyncServer_Send

func (*AsyncAgentService_ExecuteTaskSyncServer) OnSendHeader added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) OnSendHeader(_a0 metadata.MD) *AsyncAgentService_ExecuteTaskSyncServer_SendHeader

func (*AsyncAgentService_ExecuteTaskSyncServer) OnSendHeaderMatch added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) OnSendHeaderMatch(matchers ...interface{}) *AsyncAgentService_ExecuteTaskSyncServer_SendHeader

func (*AsyncAgentService_ExecuteTaskSyncServer) OnSendMatch added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) OnSendMatch(matchers ...interface{}) *AsyncAgentService_ExecuteTaskSyncServer_Send

func (*AsyncAgentService_ExecuteTaskSyncServer) OnSendMsg added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) OnSendMsg(m interface{}) *AsyncAgentService_ExecuteTaskSyncServer_SendMsg

func (*AsyncAgentService_ExecuteTaskSyncServer) OnSendMsgMatch added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) OnSendMsgMatch(matchers ...interface{}) *AsyncAgentService_ExecuteTaskSyncServer_SendMsg

func (*AsyncAgentService_ExecuteTaskSyncServer) OnSetHeader added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) OnSetHeader(_a0 metadata.MD) *AsyncAgentService_ExecuteTaskSyncServer_SetHeader

func (*AsyncAgentService_ExecuteTaskSyncServer) OnSetHeaderMatch added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) OnSetHeaderMatch(matchers ...interface{}) *AsyncAgentService_ExecuteTaskSyncServer_SetHeader

func (*AsyncAgentService_ExecuteTaskSyncServer) Recv added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) Recv() (*admin.ExecuteTaskSyncRequest, error)

Recv provides a mock function with given fields:

func (*AsyncAgentService_ExecuteTaskSyncServer) RecvMsg added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*AsyncAgentService_ExecuteTaskSyncServer) Send added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) Send(_a0 *admin.ExecuteTaskSyncResponse) error

Send provides a mock function with given fields: _a0

func (*AsyncAgentService_ExecuteTaskSyncServer) SendHeader added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) SendHeader(_a0 metadata.MD) error

SendHeader provides a mock function with given fields: _a0

func (*AsyncAgentService_ExecuteTaskSyncServer) SendMsg added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*AsyncAgentService_ExecuteTaskSyncServer) SetHeader added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) SetHeader(_a0 metadata.MD) error

SetHeader provides a mock function with given fields: _a0

func (*AsyncAgentService_ExecuteTaskSyncServer) SetTrailer added in v1.11.0 

func (_m *AsyncAgentService_ExecuteTaskSyncServer) SetTrailer(_a0 metadata.MD)

SetTrailer provides a mock function with given fields: _a0

type AsyncAgentService_ExecuteTaskSyncServer_Context added in v1.11.0 

type AsyncAgentService_ExecuteTaskSyncServer_Context struct {
	*mock.Call
}

func (AsyncAgentService_ExecuteTaskSyncServer_Context) Return added in v1.11.0 

func (_m AsyncAgentService_ExecuteTaskSyncServer_Context) Return(_a0 context.Context) *AsyncAgentService_ExecuteTaskSyncServer_Context

type AsyncAgentService_ExecuteTaskSyncServer_Recv added in v1.11.0 

type AsyncAgentService_ExecuteTaskSyncServer_Recv struct {
	*mock.Call
}

func (AsyncAgentService_ExecuteTaskSyncServer_Recv) Return added in v1.11.0 

func (_m AsyncAgentService_ExecuteTaskSyncServer_Recv) Return(_a0 *admin.ExecuteTaskSyncRequest, _a1 error) *AsyncAgentService_ExecuteTaskSyncServer_Recv

type AsyncAgentService_ExecuteTaskSyncServer_RecvMsg added in v1.11.0 

type AsyncAgentService_ExecuteTaskSyncServer_RecvMsg struct {
	*mock.Call
}

func (AsyncAgentService_ExecuteTaskSyncServer_RecvMsg) Return added in v1.11.0 

func (_m AsyncAgentService_ExecuteTaskSyncServer_RecvMsg) Return(_a0 error) *AsyncAgentService_ExecuteTaskSyncServer_RecvMsg

type AsyncAgentService_ExecuteTaskSyncServer_Send added in v1.11.0 

type AsyncAgentService_ExecuteTaskSyncServer_Send struct {
	*mock.Call
}

func (AsyncAgentService_ExecuteTaskSyncServer_Send) Return added in v1.11.0 

func (_m AsyncAgentService_ExecuteTaskSyncServer_Send) Return(_a0 error) *AsyncAgentService_ExecuteTaskSyncServer_Send

type AsyncAgentService_ExecuteTaskSyncServer_SendHeader added in v1.11.0 

type AsyncAgentService_ExecuteTaskSyncServer_SendHeader struct {
	*mock.Call
}

func (AsyncAgentService_ExecuteTaskSyncServer_SendHeader) Return added in v1.11.0 

func (_m AsyncAgentService_ExecuteTaskSyncServer_SendHeader) Return(_a0 error) *AsyncAgentService_ExecuteTaskSyncServer_SendHeader

type AsyncAgentService_ExecuteTaskSyncServer_SendMsg added in v1.11.0 

type AsyncAgentService_ExecuteTaskSyncServer_SendMsg struct {
	*mock.Call
}

func (AsyncAgentService_ExecuteTaskSyncServer_SendMsg) Return added in v1.11.0 

func (_m AsyncAgentService_ExecuteTaskSyncServer_SendMsg) Return(_a0 error) *AsyncAgentService_ExecuteTaskSyncServer_SendMsg

type AsyncAgentService_ExecuteTaskSyncServer_SetHeader added in v1.11.0 

type AsyncAgentService_ExecuteTaskSyncServer_SetHeader struct {
	*mock.Call
}

func (AsyncAgentService_ExecuteTaskSyncServer_SetHeader) Return added in v1.11.0 

func (_m AsyncAgentService_ExecuteTaskSyncServer_SetHeader) Return(_a0 error) *AsyncAgentService_ExecuteTaskSyncServer_SetHeader

type AsyncAgentService_GetTaskClient added in v1.11.0 

type AsyncAgentService_GetTaskClient struct {
	mock.Mock
}

AsyncAgentService_GetTaskClient is an autogenerated mock type for the AsyncAgentService_GetTaskClient type

func (*AsyncAgentService_GetTaskClient) CloseSend added in v1.11.0 

func (_m *AsyncAgentService_GetTaskClient) CloseSend() error

CloseSend provides a mock function with given fields:

func (*AsyncAgentService_GetTaskClient) Context added in v1.11.0 

func (_m *AsyncAgentService_GetTaskClient) Context() context.Context

Context provides a mock function with given fields:

func (*AsyncAgentService_GetTaskClient) Header added in v1.11.0 

func (_m *AsyncAgentService_GetTaskClient) Header() (metadata.MD, error)

Header provides a mock function with given fields:

func (*AsyncAgentService_GetTaskClient) OnCloseSend added in v1.11.0 

func (_m *AsyncAgentService_GetTaskClient) OnCloseSend() *AsyncAgentService_GetTaskClient_CloseSend

func (*AsyncAgentService_GetTaskClient) OnCloseSendMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskClient) OnCloseSendMatch(matchers ...interface{}) *AsyncAgentService_GetTaskClient_CloseSend

func (*AsyncAgentService_GetTaskClient) OnContext added in v1.11.0 

func (_m *AsyncAgentService_GetTaskClient) OnContext() *AsyncAgentService_GetTaskClient_Context

func (*AsyncAgentService_GetTaskClient) OnContextMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskClient) OnContextMatch(matchers ...interface{}) *AsyncAgentService_GetTaskClient_Context

func (*AsyncAgentService_GetTaskClient) OnHeader added in v1.11.0 

func (_m *AsyncAgentService_GetTaskClient) OnHeader() *AsyncAgentService_GetTaskClient_Header

func (*AsyncAgentService_GetTaskClient) OnHeaderMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskClient) OnHeaderMatch(matchers ...interface{}) *AsyncAgentService_GetTaskClient_Header

func (*AsyncAgentService_GetTaskClient) OnRecv added in v1.11.0 

func (_m *AsyncAgentService_GetTaskClient) OnRecv() *AsyncAgentService_GetTaskClient_Recv

func (*AsyncAgentService_GetTaskClient) OnRecvMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskClient) OnRecvMatch(matchers ...interface{}) *AsyncAgentService_GetTaskClient_Recv

func (*AsyncAgentService_GetTaskClient) OnRecvMsg added in v1.11.0 

func (_m *AsyncAgentService_GetTaskClient) OnRecvMsg(m interface{}) *AsyncAgentService_GetTaskClient_RecvMsg

func (*AsyncAgentService_GetTaskClient) OnRecvMsgMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskClient) OnRecvMsgMatch(matchers ...interface{}) *AsyncAgentService_GetTaskClient_RecvMsg

func (*AsyncAgentService_GetTaskClient) OnSendMsg added in v1.11.0 

func (_m *AsyncAgentService_GetTaskClient) OnSendMsg(m interface{}) *AsyncAgentService_GetTaskClient_SendMsg

func (*AsyncAgentService_GetTaskClient) OnSendMsgMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskClient) OnSendMsgMatch(matchers ...interface{}) *AsyncAgentService_GetTaskClient_SendMsg

func (*AsyncAgentService_GetTaskClient) OnTrailer added in v1.11.0 

func (_m *AsyncAgentService_GetTaskClient) OnTrailer() *AsyncAgentService_GetTaskClient_Trailer

func (*AsyncAgentService_GetTaskClient) OnTrailerMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskClient) OnTrailerMatch(matchers ...interface{}) *AsyncAgentService_GetTaskClient_Trailer

func (*AsyncAgentService_GetTaskClient) Recv added in v1.11.0 

func (_m *AsyncAgentService_GetTaskClient) Recv() (*admin.GetTaskResponse, error)

Recv provides a mock function with given fields:

func (*AsyncAgentService_GetTaskClient) RecvMsg added in v1.11.0 

func (_m *AsyncAgentService_GetTaskClient) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*AsyncAgentService_GetTaskClient) SendMsg added in v1.11.0 

func (_m *AsyncAgentService_GetTaskClient) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*AsyncAgentService_GetTaskClient) Trailer added in v1.11.0 

func (_m *AsyncAgentService_GetTaskClient) Trailer() metadata.MD

Trailer provides a mock function with given fields:

type AsyncAgentService_GetTaskClient_CloseSend added in v1.11.0 

type AsyncAgentService_GetTaskClient_CloseSend struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskClient_CloseSend) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskClient_CloseSend) Return(_a0 error) *AsyncAgentService_GetTaskClient_CloseSend

type AsyncAgentService_GetTaskClient_Context added in v1.11.0 

type AsyncAgentService_GetTaskClient_Context struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskClient_Context) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskClient_Context) Return(_a0 context.Context) *AsyncAgentService_GetTaskClient_Context

type AsyncAgentService_GetTaskClient_Header added in v1.11.0 

type AsyncAgentService_GetTaskClient_Header struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskClient_Header) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskClient_Header) Return(_a0 metadata.MD, _a1 error) *AsyncAgentService_GetTaskClient_Header

type AsyncAgentService_GetTaskClient_Recv added in v1.11.0 

type AsyncAgentService_GetTaskClient_Recv struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskClient_Recv) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskClient_Recv) Return(_a0 *admin.GetTaskResponse, _a1 error) *AsyncAgentService_GetTaskClient_Recv

type AsyncAgentService_GetTaskClient_RecvMsg added in v1.11.0 

type AsyncAgentService_GetTaskClient_RecvMsg struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskClient_RecvMsg) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskClient_RecvMsg) Return(_a0 error) *AsyncAgentService_GetTaskClient_RecvMsg

type AsyncAgentService_GetTaskClient_SendMsg added in v1.11.0 

type AsyncAgentService_GetTaskClient_SendMsg struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskClient_SendMsg) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskClient_SendMsg) Return(_a0 error) *AsyncAgentService_GetTaskClient_SendMsg

type AsyncAgentService_GetTaskClient_Trailer added in v1.11.0 

type AsyncAgentService_GetTaskClient_Trailer struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskClient_Trailer) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskClient_Trailer) Return(_a0 metadata.MD) *AsyncAgentService_GetTaskClient_Trailer

type AsyncAgentService_GetTaskLogsClient added in v1.11.0 

type AsyncAgentService_GetTaskLogsClient struct {
	mock.Mock
}

AsyncAgentService_GetTaskLogsClient is an autogenerated mock type for the AsyncAgentService_GetTaskLogsClient type

func (*AsyncAgentService_GetTaskLogsClient) CloseSend added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsClient) CloseSend() error

CloseSend provides a mock function with given fields:

func (*AsyncAgentService_GetTaskLogsClient) Context added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsClient) Context() context.Context

Context provides a mock function with given fields:

func (*AsyncAgentService_GetTaskLogsClient) Header added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsClient) Header() (metadata.MD, error)

Header provides a mock function with given fields:

func (*AsyncAgentService_GetTaskLogsClient) OnCloseSend added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsClient) OnCloseSend() *AsyncAgentService_GetTaskLogsClient_CloseSend

func (*AsyncAgentService_GetTaskLogsClient) OnCloseSendMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsClient) OnCloseSendMatch(matchers ...interface{}) *AsyncAgentService_GetTaskLogsClient_CloseSend

func (*AsyncAgentService_GetTaskLogsClient) OnContext added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsClient) OnContext() *AsyncAgentService_GetTaskLogsClient_Context

func (*AsyncAgentService_GetTaskLogsClient) OnContextMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsClient) OnContextMatch(matchers ...interface{}) *AsyncAgentService_GetTaskLogsClient_Context

func (*AsyncAgentService_GetTaskLogsClient) OnHeader added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsClient) OnHeader() *AsyncAgentService_GetTaskLogsClient_Header

func (*AsyncAgentService_GetTaskLogsClient) OnHeaderMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsClient) OnHeaderMatch(matchers ...interface{}) *AsyncAgentService_GetTaskLogsClient_Header

func (*AsyncAgentService_GetTaskLogsClient) OnRecv added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsClient) OnRecv() *AsyncAgentService_GetTaskLogsClient_Recv

func (*AsyncAgentService_GetTaskLogsClient) OnRecvMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsClient) OnRecvMatch(matchers ...interface{}) *AsyncAgentService_GetTaskLogsClient_Recv

func (*AsyncAgentService_GetTaskLogsClient) OnRecvMsg added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsClient) OnRecvMsg(m interface{}) *AsyncAgentService_GetTaskLogsClient_RecvMsg

func (*AsyncAgentService_GetTaskLogsClient) OnRecvMsgMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsClient) OnRecvMsgMatch(matchers ...interface{}) *AsyncAgentService_GetTaskLogsClient_RecvMsg

func (*AsyncAgentService_GetTaskLogsClient) OnSendMsg added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsClient) OnSendMsg(m interface{}) *AsyncAgentService_GetTaskLogsClient_SendMsg

func (*AsyncAgentService_GetTaskLogsClient) OnSendMsgMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsClient) OnSendMsgMatch(matchers ...interface{}) *AsyncAgentService_GetTaskLogsClient_SendMsg

func (*AsyncAgentService_GetTaskLogsClient) OnTrailer added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsClient) OnTrailer() *AsyncAgentService_GetTaskLogsClient_Trailer

func (*AsyncAgentService_GetTaskLogsClient) OnTrailerMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsClient) OnTrailerMatch(matchers ...interface{}) *AsyncAgentService_GetTaskLogsClient_Trailer

func (*AsyncAgentService_GetTaskLogsClient) Recv added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsClient) Recv() (*admin.GetTaskLogsResponse, error)

Recv provides a mock function with given fields:

func (*AsyncAgentService_GetTaskLogsClient) RecvMsg added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsClient) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*AsyncAgentService_GetTaskLogsClient) SendMsg added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsClient) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*AsyncAgentService_GetTaskLogsClient) Trailer added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsClient) Trailer() metadata.MD

Trailer provides a mock function with given fields:

type AsyncAgentService_GetTaskLogsClient_CloseSend added in v1.11.0 

type AsyncAgentService_GetTaskLogsClient_CloseSend struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskLogsClient_CloseSend) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskLogsClient_CloseSend) Return(_a0 error) *AsyncAgentService_GetTaskLogsClient_CloseSend

type AsyncAgentService_GetTaskLogsClient_Context added in v1.11.0 

type AsyncAgentService_GetTaskLogsClient_Context struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskLogsClient_Context) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskLogsClient_Context) Return(_a0 context.Context) *AsyncAgentService_GetTaskLogsClient_Context

type AsyncAgentService_GetTaskLogsClient_Header added in v1.11.0 

type AsyncAgentService_GetTaskLogsClient_Header struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskLogsClient_Header) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskLogsClient_Header) Return(_a0 metadata.MD, _a1 error) *AsyncAgentService_GetTaskLogsClient_Header

type AsyncAgentService_GetTaskLogsClient_Recv added in v1.11.0 

type AsyncAgentService_GetTaskLogsClient_Recv struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskLogsClient_Recv) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskLogsClient_Recv) Return(_a0 *admin.GetTaskLogsResponse, _a1 error) *AsyncAgentService_GetTaskLogsClient_Recv

type AsyncAgentService_GetTaskLogsClient_RecvMsg added in v1.11.0 

type AsyncAgentService_GetTaskLogsClient_RecvMsg struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskLogsClient_RecvMsg) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskLogsClient_RecvMsg) Return(_a0 error) *AsyncAgentService_GetTaskLogsClient_RecvMsg

type AsyncAgentService_GetTaskLogsClient_SendMsg added in v1.11.0 

type AsyncAgentService_GetTaskLogsClient_SendMsg struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskLogsClient_SendMsg) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskLogsClient_SendMsg) Return(_a0 error) *AsyncAgentService_GetTaskLogsClient_SendMsg

type AsyncAgentService_GetTaskLogsClient_Trailer added in v1.11.0 

type AsyncAgentService_GetTaskLogsClient_Trailer struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskLogsClient_Trailer) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskLogsClient_Trailer) Return(_a0 metadata.MD) *AsyncAgentService_GetTaskLogsClient_Trailer

type AsyncAgentService_GetTaskLogsServer added in v1.11.0 

type AsyncAgentService_GetTaskLogsServer struct {
	mock.Mock
}

AsyncAgentService_GetTaskLogsServer is an autogenerated mock type for the AsyncAgentService_GetTaskLogsServer type

func (*AsyncAgentService_GetTaskLogsServer) Context added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsServer) Context() context.Context

Context provides a mock function with given fields:

func (*AsyncAgentService_GetTaskLogsServer) OnContext added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsServer) OnContext() *AsyncAgentService_GetTaskLogsServer_Context

func (*AsyncAgentService_GetTaskLogsServer) OnContextMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsServer) OnContextMatch(matchers ...interface{}) *AsyncAgentService_GetTaskLogsServer_Context

func (*AsyncAgentService_GetTaskLogsServer) OnRecvMsg added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsServer) OnRecvMsg(m interface{}) *AsyncAgentService_GetTaskLogsServer_RecvMsg

func (*AsyncAgentService_GetTaskLogsServer) OnRecvMsgMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsServer) OnRecvMsgMatch(matchers ...interface{}) *AsyncAgentService_GetTaskLogsServer_RecvMsg

func (*AsyncAgentService_GetTaskLogsServer) OnSend added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsServer) OnSend(_a0 *admin.GetTaskLogsResponse) *AsyncAgentService_GetTaskLogsServer_Send

func (*AsyncAgentService_GetTaskLogsServer) OnSendHeader added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsServer) OnSendHeader(_a0 metadata.MD) *AsyncAgentService_GetTaskLogsServer_SendHeader

func (*AsyncAgentService_GetTaskLogsServer) OnSendHeaderMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsServer) OnSendHeaderMatch(matchers ...interface{}) *AsyncAgentService_GetTaskLogsServer_SendHeader

func (*AsyncAgentService_GetTaskLogsServer) OnSendMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsServer) OnSendMatch(matchers ...interface{}) *AsyncAgentService_GetTaskLogsServer_Send

func (*AsyncAgentService_GetTaskLogsServer) OnSendMsg added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsServer) OnSendMsg(m interface{}) *AsyncAgentService_GetTaskLogsServer_SendMsg

func (*AsyncAgentService_GetTaskLogsServer) OnSendMsgMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsServer) OnSendMsgMatch(matchers ...interface{}) *AsyncAgentService_GetTaskLogsServer_SendMsg

func (*AsyncAgentService_GetTaskLogsServer) OnSetHeader added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsServer) OnSetHeader(_a0 metadata.MD) *AsyncAgentService_GetTaskLogsServer_SetHeader

func (*AsyncAgentService_GetTaskLogsServer) OnSetHeaderMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsServer) OnSetHeaderMatch(matchers ...interface{}) *AsyncAgentService_GetTaskLogsServer_SetHeader

func (*AsyncAgentService_GetTaskLogsServer) RecvMsg added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsServer) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*AsyncAgentService_GetTaskLogsServer) Send added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsServer) Send(_a0 *admin.GetTaskLogsResponse) error

Send provides a mock function with given fields: _a0

func (*AsyncAgentService_GetTaskLogsServer) SendHeader added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsServer) SendHeader(_a0 metadata.MD) error

SendHeader provides a mock function with given fields: _a0

func (*AsyncAgentService_GetTaskLogsServer) SendMsg added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsServer) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*AsyncAgentService_GetTaskLogsServer) SetHeader added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsServer) SetHeader(_a0 metadata.MD) error

SetHeader provides a mock function with given fields: _a0

func (*AsyncAgentService_GetTaskLogsServer) SetTrailer added in v1.11.0 

func (_m *AsyncAgentService_GetTaskLogsServer) SetTrailer(_a0 metadata.MD)

SetTrailer provides a mock function with given fields: _a0

type AsyncAgentService_GetTaskLogsServer_Context added in v1.11.0 

type AsyncAgentService_GetTaskLogsServer_Context struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskLogsServer_Context) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskLogsServer_Context) Return(_a0 context.Context) *AsyncAgentService_GetTaskLogsServer_Context

type AsyncAgentService_GetTaskLogsServer_RecvMsg added in v1.11.0 

type AsyncAgentService_GetTaskLogsServer_RecvMsg struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskLogsServer_RecvMsg) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskLogsServer_RecvMsg) Return(_a0 error) *AsyncAgentService_GetTaskLogsServer_RecvMsg

type AsyncAgentService_GetTaskLogsServer_Send added in v1.11.0 

type AsyncAgentService_GetTaskLogsServer_Send struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskLogsServer_Send) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskLogsServer_Send) Return(_a0 error) *AsyncAgentService_GetTaskLogsServer_Send

type AsyncAgentService_GetTaskLogsServer_SendHeader added in v1.11.0 

type AsyncAgentService_GetTaskLogsServer_SendHeader struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskLogsServer_SendHeader) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskLogsServer_SendHeader) Return(_a0 error) *AsyncAgentService_GetTaskLogsServer_SendHeader

type AsyncAgentService_GetTaskLogsServer_SendMsg added in v1.11.0 

type AsyncAgentService_GetTaskLogsServer_SendMsg struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskLogsServer_SendMsg) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskLogsServer_SendMsg) Return(_a0 error) *AsyncAgentService_GetTaskLogsServer_SendMsg

type AsyncAgentService_GetTaskLogsServer_SetHeader added in v1.11.0 

type AsyncAgentService_GetTaskLogsServer_SetHeader struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskLogsServer_SetHeader) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskLogsServer_SetHeader) Return(_a0 error) *AsyncAgentService_GetTaskLogsServer_SetHeader

type AsyncAgentService_GetTaskServer added in v1.11.0 

type AsyncAgentService_GetTaskServer struct {
	mock.Mock
}

AsyncAgentService_GetTaskServer is an autogenerated mock type for the AsyncAgentService_GetTaskServer type

func (*AsyncAgentService_GetTaskServer) Context added in v1.11.0 

func (_m *AsyncAgentService_GetTaskServer) Context() context.Context

Context provides a mock function with given fields:

func (*AsyncAgentService_GetTaskServer) OnContext added in v1.11.0 

func (_m *AsyncAgentService_GetTaskServer) OnContext() *AsyncAgentService_GetTaskServer_Context

func (*AsyncAgentService_GetTaskServer) OnContextMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskServer) OnContextMatch(matchers ...interface{}) *AsyncAgentService_GetTaskServer_Context

func (*AsyncAgentService_GetTaskServer) OnRecvMsg added in v1.11.0 

func (_m *AsyncAgentService_GetTaskServer) OnRecvMsg(m interface{}) *AsyncAgentService_GetTaskServer_RecvMsg

func (*AsyncAgentService_GetTaskServer) OnRecvMsgMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskServer) OnRecvMsgMatch(matchers ...interface{}) *AsyncAgentService_GetTaskServer_RecvMsg

func (*AsyncAgentService_GetTaskServer) OnSend added in v1.11.0 

func (_m *AsyncAgentService_GetTaskServer) OnSend(_a0 *admin.GetTaskResponse) *AsyncAgentService_GetTaskServer_Send

func (*AsyncAgentService_GetTaskServer) OnSendHeader added in v1.11.0 

func (_m *AsyncAgentService_GetTaskServer) OnSendHeader(_a0 metadata.MD) *AsyncAgentService_GetTaskServer_SendHeader

func (*AsyncAgentService_GetTaskServer) OnSendHeaderMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskServer) OnSendHeaderMatch(matchers ...interface{}) *AsyncAgentService_GetTaskServer_SendHeader

func (*AsyncAgentService_GetTaskServer) OnSendMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskServer) OnSendMatch(matchers ...interface{}) *AsyncAgentService_GetTaskServer_Send

func (*AsyncAgentService_GetTaskServer) OnSendMsg added in v1.11.0 

func (_m *AsyncAgentService_GetTaskServer) OnSendMsg(m interface{}) *AsyncAgentService_GetTaskServer_SendMsg

func (*AsyncAgentService_GetTaskServer) OnSendMsgMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskServer) OnSendMsgMatch(matchers ...interface{}) *AsyncAgentService_GetTaskServer_SendMsg

func (*AsyncAgentService_GetTaskServer) OnSetHeader added in v1.11.0 

func (_m *AsyncAgentService_GetTaskServer) OnSetHeader(_a0 metadata.MD) *AsyncAgentService_GetTaskServer_SetHeader

func (*AsyncAgentService_GetTaskServer) OnSetHeaderMatch added in v1.11.0 

func (_m *AsyncAgentService_GetTaskServer) OnSetHeaderMatch(matchers ...interface{}) *AsyncAgentService_GetTaskServer_SetHeader

func (*AsyncAgentService_GetTaskServer) RecvMsg added in v1.11.0 

func (_m *AsyncAgentService_GetTaskServer) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*AsyncAgentService_GetTaskServer) Send added in v1.11.0 

func (_m *AsyncAgentService_GetTaskServer) Send(_a0 *admin.GetTaskResponse) error

Send provides a mock function with given fields: _a0

func (*AsyncAgentService_GetTaskServer) SendHeader added in v1.11.0 

func (_m *AsyncAgentService_GetTaskServer) SendHeader(_a0 metadata.MD) error

SendHeader provides a mock function with given fields: _a0

func (*AsyncAgentService_GetTaskServer) SendMsg added in v1.11.0 

func (_m *AsyncAgentService_GetTaskServer) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*AsyncAgentService_GetTaskServer) SetHeader added in v1.11.0 

func (_m *AsyncAgentService_GetTaskServer) SetHeader(_a0 metadata.MD) error

SetHeader provides a mock function with given fields: _a0

func (*AsyncAgentService_GetTaskServer) SetTrailer added in v1.11.0 

func (_m *AsyncAgentService_GetTaskServer) SetTrailer(_a0 metadata.MD)

SetTrailer provides a mock function with given fields: _a0

type AsyncAgentService_GetTaskServer_Context added in v1.11.0 

type AsyncAgentService_GetTaskServer_Context struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskServer_Context) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskServer_Context) Return(_a0 context.Context) *AsyncAgentService_GetTaskServer_Context

type AsyncAgentService_GetTaskServer_RecvMsg added in v1.11.0 

type AsyncAgentService_GetTaskServer_RecvMsg struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskServer_RecvMsg) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskServer_RecvMsg) Return(_a0 error) *AsyncAgentService_GetTaskServer_RecvMsg

type AsyncAgentService_GetTaskServer_Send added in v1.11.0 

type AsyncAgentService_GetTaskServer_Send struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskServer_Send) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskServer_Send) Return(_a0 error) *AsyncAgentService_GetTaskServer_Send

type AsyncAgentService_GetTaskServer_SendHeader added in v1.11.0 

type AsyncAgentService_GetTaskServer_SendHeader struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskServer_SendHeader) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskServer_SendHeader) Return(_a0 error) *AsyncAgentService_GetTaskServer_SendHeader

type AsyncAgentService_GetTaskServer_SendMsg added in v1.11.0 

type AsyncAgentService_GetTaskServer_SendMsg struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskServer_SendMsg) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskServer_SendMsg) Return(_a0 error) *AsyncAgentService_GetTaskServer_SendMsg

type AsyncAgentService_GetTaskServer_SetHeader added in v1.11.0 

type AsyncAgentService_GetTaskServer_SetHeader struct {
	*mock.Call
}

func (AsyncAgentService_GetTaskServer_SetHeader) Return added in v1.11.0 

func (_m AsyncAgentService_GetTaskServer_SetHeader) Return(_a0 error) *AsyncAgentService_GetTaskServer_SetHeader

type AuthMetadataServiceClient 

type AuthMetadataServiceClient struct {
	mock.Mock
}

AuthMetadataServiceClient is an autogenerated mock type for the AuthMetadataServiceClient type

func (*AuthMetadataServiceClient) GetOAuth2Metadata 

func (_m *AuthMetadataServiceClient) GetOAuth2Metadata(ctx context.Context, in *service.OAuth2MetadataRequest, opts ...grpc.CallOption) (*service.OAuth2MetadataResponse, error)

GetOAuth2Metadata provides a mock function with given fields: ctx, in, opts

func (*AuthMetadataServiceClient) GetPublicClientConfig 

func (_m *AuthMetadataServiceClient) GetPublicClientConfig(ctx context.Context, in *service.PublicClientAuthConfigRequest, opts ...grpc.CallOption) (*service.PublicClientAuthConfigResponse, error)

GetPublicClientConfig provides a mock function with given fields: ctx, in, opts

func (*AuthMetadataServiceClient) OnGetOAuth2Metadata 

func (_m *AuthMetadataServiceClient) OnGetOAuth2Metadata(ctx context.Context, in *service.OAuth2MetadataRequest, opts ...grpc.CallOption) *AuthMetadataServiceClient_GetOAuth2Metadata

func (*AuthMetadataServiceClient) OnGetOAuth2MetadataMatch 

func (_m *AuthMetadataServiceClient) OnGetOAuth2MetadataMatch(matchers ...interface{}) *AuthMetadataServiceClient_GetOAuth2Metadata

func (*AuthMetadataServiceClient) OnGetPublicClientConfig 

func (_m *AuthMetadataServiceClient) OnGetPublicClientConfig(ctx context.Context, in *service.PublicClientAuthConfigRequest, opts ...grpc.CallOption) *AuthMetadataServiceClient_GetPublicClientConfig

func (*AuthMetadataServiceClient) OnGetPublicClientConfigMatch 

func (_m *AuthMetadataServiceClient) OnGetPublicClientConfigMatch(matchers ...interface{}) *AuthMetadataServiceClient_GetPublicClientConfig

type AuthMetadataServiceClient_GetOAuth2Metadata 

type AuthMetadataServiceClient_GetOAuth2Metadata struct {
	*mock.Call
}

func (AuthMetadataServiceClient_GetOAuth2Metadata) Return 

func (_m AuthMetadataServiceClient_GetOAuth2Metadata) Return(_a0 *service.OAuth2MetadataResponse, _a1 error) *AuthMetadataServiceClient_GetOAuth2Metadata

type AuthMetadataServiceClient_GetPublicClientConfig 

type AuthMetadataServiceClient_GetPublicClientConfig struct {
	*mock.Call
}

func (AuthMetadataServiceClient_GetPublicClientConfig) Return 

func (_m AuthMetadataServiceClient_GetPublicClientConfig) Return(_a0 *service.PublicClientAuthConfigResponse, _a1 error) *AuthMetadataServiceClient_GetPublicClientConfig

type AuthMetadataServiceServer 

type AuthMetadataServiceServer struct {
	mock.Mock
}

AuthMetadataServiceServer is an autogenerated mock type for the AuthMetadataServiceServer type

func (*AuthMetadataServiceServer) GetOAuth2Metadata 

func (_m *AuthMetadataServiceServer) GetOAuth2Metadata(_a0 context.Context, _a1 *service.OAuth2MetadataRequest) (*service.OAuth2MetadataResponse, error)

GetOAuth2Metadata provides a mock function with given fields: _a0, _a1

func (*AuthMetadataServiceServer) GetPublicClientConfig 

func (_m *AuthMetadataServiceServer) GetPublicClientConfig(_a0 context.Context, _a1 *service.PublicClientAuthConfigRequest) (*service.PublicClientAuthConfigResponse, error)

GetPublicClientConfig provides a mock function with given fields: _a0, _a1

func (*AuthMetadataServiceServer) OnGetOAuth2Metadata 

func (_m *AuthMetadataServiceServer) OnGetOAuth2Metadata(_a0 context.Context, _a1 *service.OAuth2MetadataRequest) *AuthMetadataServiceServer_GetOAuth2Metadata

func (*AuthMetadataServiceServer) OnGetOAuth2MetadataMatch 

func (_m *AuthMetadataServiceServer) OnGetOAuth2MetadataMatch(matchers ...interface{}) *AuthMetadataServiceServer_GetOAuth2Metadata

func (*AuthMetadataServiceServer) OnGetPublicClientConfig 

func (_m *AuthMetadataServiceServer) OnGetPublicClientConfig(_a0 context.Context, _a1 *service.PublicClientAuthConfigRequest) *AuthMetadataServiceServer_GetPublicClientConfig

func (*AuthMetadataServiceServer) OnGetPublicClientConfigMatch 

func (_m *AuthMetadataServiceServer) OnGetPublicClientConfigMatch(matchers ...interface{}) *AuthMetadataServiceServer_GetPublicClientConfig

type AuthMetadataServiceServer_GetOAuth2Metadata 

type AuthMetadataServiceServer_GetOAuth2Metadata struct {
	*mock.Call
}

func (AuthMetadataServiceServer_GetOAuth2Metadata) Return 

func (_m AuthMetadataServiceServer_GetOAuth2Metadata) Return(_a0 *service.OAuth2MetadataResponse, _a1 error) *AuthMetadataServiceServer_GetOAuth2Metadata

type AuthMetadataServiceServer_GetPublicClientConfig 

type AuthMetadataServiceServer_GetPublicClientConfig struct {
	*mock.Call
}

func (AuthMetadataServiceServer_GetPublicClientConfig) Return 

func (_m AuthMetadataServiceServer_GetPublicClientConfig) Return(_a0 *service.PublicClientAuthConfigResponse, _a1 error) *AuthMetadataServiceServer_GetPublicClientConfig

type DataProxyServiceClient 

type DataProxyServiceClient struct {
	mock.Mock
}

DataProxyServiceClient is an autogenerated mock type for the DataProxyServiceClient type 

func (_m *DataProxyServiceClient) CreateDownloadLink(ctx context.Context, in *service.CreateDownloadLinkRequest, opts ...grpc.CallOption) (*service.CreateDownloadLinkResponse, error)

CreateDownloadLink provides a mock function with given fields: ctx, in, opts

func (*DataProxyServiceClient) CreateDownloadLocation 

func (_m *DataProxyServiceClient) CreateDownloadLocation(ctx context.Context, in *service.CreateDownloadLocationRequest, opts ...grpc.CallOption) (*service.CreateDownloadLocationResponse, error)

CreateDownloadLocation provides a mock function with given fields: ctx, in, opts

func (*DataProxyServiceClient) CreateUploadLocation 

func (_m *DataProxyServiceClient) CreateUploadLocation(ctx context.Context, in *service.CreateUploadLocationRequest, opts ...grpc.CallOption) (*service.CreateUploadLocationResponse, error)

CreateUploadLocation provides a mock function with given fields: ctx, in, opts

func (*DataProxyServiceClient) GetData 

func (_m *DataProxyServiceClient) GetData(ctx context.Context, in *service.GetDataRequest, opts ...grpc.CallOption) (*service.GetDataResponse, error)

GetData provides a mock function with given fields: ctx, in, opts 

func (_m *DataProxyServiceClient) OnCreateDownloadLink(ctx context.Context, in *service.CreateDownloadLinkRequest, opts ...grpc.CallOption) *DataProxyServiceClient_CreateDownloadLink

func (*DataProxyServiceClient) OnCreateDownloadLinkMatch 

func (_m *DataProxyServiceClient) OnCreateDownloadLinkMatch(matchers ...interface{}) *DataProxyServiceClient_CreateDownloadLink

func (*DataProxyServiceClient) OnCreateDownloadLocation 

func (_m *DataProxyServiceClient) OnCreateDownloadLocation(ctx context.Context, in *service.CreateDownloadLocationRequest, opts ...grpc.CallOption) *DataProxyServiceClient_CreateDownloadLocation

func (*DataProxyServiceClient) OnCreateDownloadLocationMatch 

func (_m *DataProxyServiceClient) OnCreateDownloadLocationMatch(matchers ...interface{}) *DataProxyServiceClient_CreateDownloadLocation

func (*DataProxyServiceClient) OnCreateUploadLocation 

func (_m *DataProxyServiceClient) OnCreateUploadLocation(ctx context.Context, in *service.CreateUploadLocationRequest, opts ...grpc.CallOption) *DataProxyServiceClient_CreateUploadLocation

func (*DataProxyServiceClient) OnCreateUploadLocationMatch 

func (_m *DataProxyServiceClient) OnCreateUploadLocationMatch(matchers ...interface{}) *DataProxyServiceClient_CreateUploadLocation

func (*DataProxyServiceClient) OnGetData 

func (_m *DataProxyServiceClient) OnGetData(ctx context.Context, in *service.GetDataRequest, opts ...grpc.CallOption) *DataProxyServiceClient_GetData

func (*DataProxyServiceClient) OnGetDataMatch 

func (_m *DataProxyServiceClient) OnGetDataMatch(matchers ...interface{}) *DataProxyServiceClient_GetData
type DataProxyServiceClient_CreateDownloadLink struct {
	*mock.Call
}

func (DataProxyServiceClient_CreateDownloadLink) Return 

func (_m DataProxyServiceClient_CreateDownloadLink) Return(_a0 *service.CreateDownloadLinkResponse, _a1 error) *DataProxyServiceClient_CreateDownloadLink

type DataProxyServiceClient_CreateDownloadLocation 

type DataProxyServiceClient_CreateDownloadLocation struct {
	*mock.Call
}

func (DataProxyServiceClient_CreateDownloadLocation) Return 

func (_m DataProxyServiceClient_CreateDownloadLocation) Return(_a0 *service.CreateDownloadLocationResponse, _a1 error) *DataProxyServiceClient_CreateDownloadLocation

type DataProxyServiceClient_CreateUploadLocation 

type DataProxyServiceClient_CreateUploadLocation struct {
	*mock.Call
}

func (DataProxyServiceClient_CreateUploadLocation) Return 

func (_m DataProxyServiceClient_CreateUploadLocation) Return(_a0 *service.CreateUploadLocationResponse, _a1 error) *DataProxyServiceClient_CreateUploadLocation

type DataProxyServiceClient_GetData 

type DataProxyServiceClient_GetData struct {
	*mock.Call
}

func (DataProxyServiceClient_GetData) Return 

func (_m DataProxyServiceClient_GetData) Return(_a0 *service.GetDataResponse, _a1 error) *DataProxyServiceClient_GetData

type DataProxyServiceServer 

type DataProxyServiceServer struct {
	mock.Mock
}

DataProxyServiceServer is an autogenerated mock type for the DataProxyServiceServer type 

func (_m *DataProxyServiceServer) CreateDownloadLink(_a0 context.Context, _a1 *service.CreateDownloadLinkRequest) (*service.CreateDownloadLinkResponse, error)

CreateDownloadLink provides a mock function with given fields: _a0, _a1

func (*DataProxyServiceServer) CreateDownloadLocation 

func (_m *DataProxyServiceServer) CreateDownloadLocation(_a0 context.Context, _a1 *service.CreateDownloadLocationRequest) (*service.CreateDownloadLocationResponse, error)

CreateDownloadLocation provides a mock function with given fields: _a0, _a1

func (*DataProxyServiceServer) CreateUploadLocation 

func (_m *DataProxyServiceServer) CreateUploadLocation(_a0 context.Context, _a1 *service.CreateUploadLocationRequest) (*service.CreateUploadLocationResponse, error)

CreateUploadLocation provides a mock function with given fields: _a0, _a1

func (*DataProxyServiceServer) GetData 

func (_m *DataProxyServiceServer) GetData(_a0 context.Context, _a1 *service.GetDataRequest) (*service.GetDataResponse, error)

GetData provides a mock function with given fields: _a0, _a1 

func (_m *DataProxyServiceServer) OnCreateDownloadLink(_a0 context.Context, _a1 *service.CreateDownloadLinkRequest) *DataProxyServiceServer_CreateDownloadLink

func (*DataProxyServiceServer) OnCreateDownloadLinkMatch 

func (_m *DataProxyServiceServer) OnCreateDownloadLinkMatch(matchers ...interface{}) *DataProxyServiceServer_CreateDownloadLink

func (*DataProxyServiceServer) OnCreateDownloadLocation 

func (_m *DataProxyServiceServer) OnCreateDownloadLocation(_a0 context.Context, _a1 *service.CreateDownloadLocationRequest) *DataProxyServiceServer_CreateDownloadLocation

func (*DataProxyServiceServer) OnCreateDownloadLocationMatch 

func (_m *DataProxyServiceServer) OnCreateDownloadLocationMatch(matchers ...interface{}) *DataProxyServiceServer_CreateDownloadLocation

func (*DataProxyServiceServer) OnCreateUploadLocation 

func (_m *DataProxyServiceServer) OnCreateUploadLocation(_a0 context.Context, _a1 *service.CreateUploadLocationRequest) *DataProxyServiceServer_CreateUploadLocation

func (*DataProxyServiceServer) OnCreateUploadLocationMatch 

func (_m *DataProxyServiceServer) OnCreateUploadLocationMatch(matchers ...interface{}) *DataProxyServiceServer_CreateUploadLocation

func (*DataProxyServiceServer) OnGetData 

func (_m *DataProxyServiceServer) OnGetData(_a0 context.Context, _a1 *service.GetDataRequest) *DataProxyServiceServer_GetData

func (*DataProxyServiceServer) OnGetDataMatch 

func (_m *DataProxyServiceServer) OnGetDataMatch(matchers ...interface{}) *DataProxyServiceServer_GetData
type DataProxyServiceServer_CreateDownloadLink struct {
	*mock.Call
}

func (DataProxyServiceServer_CreateDownloadLink) Return 

func (_m DataProxyServiceServer_CreateDownloadLink) Return(_a0 *service.CreateDownloadLinkResponse, _a1 error) *DataProxyServiceServer_CreateDownloadLink

type DataProxyServiceServer_CreateDownloadLocation 

type DataProxyServiceServer_CreateDownloadLocation struct {
	*mock.Call
}

func (DataProxyServiceServer_CreateDownloadLocation) Return 

func (_m DataProxyServiceServer_CreateDownloadLocation) Return(_a0 *service.CreateDownloadLocationResponse, _a1 error) *DataProxyServiceServer_CreateDownloadLocation

type DataProxyServiceServer_CreateUploadLocation 

type DataProxyServiceServer_CreateUploadLocation struct {
	*mock.Call
}

func (DataProxyServiceServer_CreateUploadLocation) Return 

func (_m DataProxyServiceServer_CreateUploadLocation) Return(_a0 *service.CreateUploadLocationResponse, _a1 error) *DataProxyServiceServer_CreateUploadLocation

type DataProxyServiceServer_GetData 

type DataProxyServiceServer_GetData struct {
	*mock.Call
}

func (DataProxyServiceServer_GetData) Return 

func (_m DataProxyServiceServer_GetData) Return(_a0 *service.GetDataResponse, _a1 error) *DataProxyServiceServer_GetData

type ExternalPluginServiceClient 

type ExternalPluginServiceClient struct {
	mock.Mock
}

ExternalPluginServiceClient is an autogenerated mock type for the ExternalPluginServiceClient type

func (*ExternalPluginServiceClient) CreateTask 

func (_m *ExternalPluginServiceClient) CreateTask(ctx context.Context, in *service.TaskCreateRequest, opts ...grpc.CallOption) (*service.TaskCreateResponse, error)

CreateTask provides a mock function with given fields: ctx, in, opts

func (*ExternalPluginServiceClient) DeleteTask 

func (_m *ExternalPluginServiceClient) DeleteTask(ctx context.Context, in *service.TaskDeleteRequest, opts ...grpc.CallOption) (*service.TaskDeleteResponse, error)

DeleteTask provides a mock function with given fields: ctx, in, opts

func (*ExternalPluginServiceClient) GetTask 

func (_m *ExternalPluginServiceClient) GetTask(ctx context.Context, in *service.TaskGetRequest, opts ...grpc.CallOption) (*service.TaskGetResponse, error)

GetTask provides a mock function with given fields: ctx, in, opts

func (*ExternalPluginServiceClient) OnCreateTask 

func (_m *ExternalPluginServiceClient) OnCreateTask(ctx context.Context, in *service.TaskCreateRequest, opts ...grpc.CallOption) *ExternalPluginServiceClient_CreateTask

func (*ExternalPluginServiceClient) OnCreateTaskMatch 

func (_m *ExternalPluginServiceClient) OnCreateTaskMatch(matchers ...interface{}) *ExternalPluginServiceClient_CreateTask

func (*ExternalPluginServiceClient) OnDeleteTask 

func (_m *ExternalPluginServiceClient) OnDeleteTask(ctx context.Context, in *service.TaskDeleteRequest, opts ...grpc.CallOption) *ExternalPluginServiceClient_DeleteTask

func (*ExternalPluginServiceClient) OnDeleteTaskMatch 

func (_m *ExternalPluginServiceClient) OnDeleteTaskMatch(matchers ...interface{}) *ExternalPluginServiceClient_DeleteTask

func (*ExternalPluginServiceClient) OnGetTask 

func (_m *ExternalPluginServiceClient) OnGetTask(ctx context.Context, in *service.TaskGetRequest, opts ...grpc.CallOption) *ExternalPluginServiceClient_GetTask

func (*ExternalPluginServiceClient) OnGetTaskMatch 

func (_m *ExternalPluginServiceClient) OnGetTaskMatch(matchers ...interface{}) *ExternalPluginServiceClient_GetTask

type ExternalPluginServiceClient_CreateTask 

type ExternalPluginServiceClient_CreateTask struct {
	*mock.Call
}

func (ExternalPluginServiceClient_CreateTask) Return 

func (_m ExternalPluginServiceClient_CreateTask) Return(_a0 *service.TaskCreateResponse, _a1 error) *ExternalPluginServiceClient_CreateTask

type ExternalPluginServiceClient_DeleteTask 

type ExternalPluginServiceClient_DeleteTask struct {
	*mock.Call
}

func (ExternalPluginServiceClient_DeleteTask) Return 

func (_m ExternalPluginServiceClient_DeleteTask) Return(_a0 *service.TaskDeleteResponse, _a1 error) *ExternalPluginServiceClient_DeleteTask

type ExternalPluginServiceClient_GetTask 

type ExternalPluginServiceClient_GetTask struct {
	*mock.Call
}

func (ExternalPluginServiceClient_GetTask) Return 

func (_m ExternalPluginServiceClient_GetTask) Return(_a0 *service.TaskGetResponse, _a1 error) *ExternalPluginServiceClient_GetTask

type ExternalPluginServiceServer 

type ExternalPluginServiceServer struct {
	mock.Mock
}

ExternalPluginServiceServer is an autogenerated mock type for the ExternalPluginServiceServer type

func (*ExternalPluginServiceServer) CreateTask 

func (_m *ExternalPluginServiceServer) CreateTask(_a0 context.Context, _a1 *service.TaskCreateRequest) (*service.TaskCreateResponse, error)

CreateTask provides a mock function with given fields: _a0, _a1

func (*ExternalPluginServiceServer) DeleteTask 

func (_m *ExternalPluginServiceServer) DeleteTask(_a0 context.Context, _a1 *service.TaskDeleteRequest) (*service.TaskDeleteResponse, error)

DeleteTask provides a mock function with given fields: _a0, _a1

func (*ExternalPluginServiceServer) GetTask 

func (_m *ExternalPluginServiceServer) GetTask(_a0 context.Context, _a1 *service.TaskGetRequest) (*service.TaskGetResponse, error)

GetTask provides a mock function with given fields: _a0, _a1

func (*ExternalPluginServiceServer) OnCreateTask 

func (_m *ExternalPluginServiceServer) OnCreateTask(_a0 context.Context, _a1 *service.TaskCreateRequest) *ExternalPluginServiceServer_CreateTask

func (*ExternalPluginServiceServer) OnCreateTaskMatch 

func (_m *ExternalPluginServiceServer) OnCreateTaskMatch(matchers ...interface{}) *ExternalPluginServiceServer_CreateTask

func (*ExternalPluginServiceServer) OnDeleteTask 

func (_m *ExternalPluginServiceServer) OnDeleteTask(_a0 context.Context, _a1 *service.TaskDeleteRequest) *ExternalPluginServiceServer_DeleteTask

func (*ExternalPluginServiceServer) OnDeleteTaskMatch 

func (_m *ExternalPluginServiceServer) OnDeleteTaskMatch(matchers ...interface{}) *ExternalPluginServiceServer_DeleteTask

func (*ExternalPluginServiceServer) OnGetTask 

func (_m *ExternalPluginServiceServer) OnGetTask(_a0 context.Context, _a1 *service.TaskGetRequest) *ExternalPluginServiceServer_GetTask

func (*ExternalPluginServiceServer) OnGetTaskMatch 

func (_m *ExternalPluginServiceServer) OnGetTaskMatch(matchers ...interface{}) *ExternalPluginServiceServer_GetTask

type ExternalPluginServiceServer_CreateTask 

type ExternalPluginServiceServer_CreateTask struct {
	*mock.Call
}

func (ExternalPluginServiceServer_CreateTask) Return 

func (_m ExternalPluginServiceServer_CreateTask) Return(_a0 *service.TaskCreateResponse, _a1 error) *ExternalPluginServiceServer_CreateTask

type ExternalPluginServiceServer_DeleteTask 

type ExternalPluginServiceServer_DeleteTask struct {
	*mock.Call
}

func (ExternalPluginServiceServer_DeleteTask) Return 

func (_m ExternalPluginServiceServer_DeleteTask) Return(_a0 *service.TaskDeleteResponse, _a1 error) *ExternalPluginServiceServer_DeleteTask

type ExternalPluginServiceServer_GetTask 

type ExternalPluginServiceServer_GetTask struct {
	*mock.Call
}

func (ExternalPluginServiceServer_GetTask) Return 

func (_m ExternalPluginServiceServer_GetTask) Return(_a0 *service.TaskGetResponse, _a1 error) *ExternalPluginServiceServer_GetTask

type IdentityServiceClient 

type IdentityServiceClient struct {
	mock.Mock
}

IdentityServiceClient is an autogenerated mock type for the IdentityServiceClient type

func (*IdentityServiceClient) OnUserInfo 

func (_m *IdentityServiceClient) OnUserInfo(ctx context.Context, in *service.UserInfoRequest, opts ...grpc.CallOption) *IdentityServiceClient_UserInfo

func (*IdentityServiceClient) OnUserInfoMatch 

func (_m *IdentityServiceClient) OnUserInfoMatch(matchers ...interface{}) *IdentityServiceClient_UserInfo

func (*IdentityServiceClient) UserInfo 

func (_m *IdentityServiceClient) UserInfo(ctx context.Context, in *service.UserInfoRequest, opts ...grpc.CallOption) (*service.UserInfoResponse, error)

UserInfo provides a mock function with given fields: ctx, in, opts

type IdentityServiceClient_UserInfo 

type IdentityServiceClient_UserInfo struct {
	*mock.Call
}

func (IdentityServiceClient_UserInfo) Return 

func (_m IdentityServiceClient_UserInfo) Return(_a0 *service.UserInfoResponse, _a1 error) *IdentityServiceClient_UserInfo

type IdentityServiceServer 

type IdentityServiceServer struct {
	mock.Mock
}

IdentityServiceServer is an autogenerated mock type for the IdentityServiceServer type

func (*IdentityServiceServer) OnUserInfo 

func (_m *IdentityServiceServer) OnUserInfo(_a0 context.Context, _a1 *service.UserInfoRequest) *IdentityServiceServer_UserInfo

func (*IdentityServiceServer) OnUserInfoMatch 

func (_m *IdentityServiceServer) OnUserInfoMatch(matchers ...interface{}) *IdentityServiceServer_UserInfo

func (*IdentityServiceServer) UserInfo 

func (_m *IdentityServiceServer) UserInfo(_a0 context.Context, _a1 *service.UserInfoRequest) (*service.UserInfoResponse, error)

UserInfo provides a mock function with given fields: _a0, _a1

type IdentityServiceServer_UserInfo 

type IdentityServiceServer_UserInfo struct {
	*mock.Call
}

func (IdentityServiceServer_UserInfo) Return 

func (_m IdentityServiceServer_UserInfo) Return(_a0 *service.UserInfoResponse, _a1 error) *IdentityServiceServer_UserInfo

type SignalServiceClient 

type SignalServiceClient struct {
	mock.Mock
}

SignalServiceClient is an autogenerated mock type for the SignalServiceClient type

func (*SignalServiceClient) GetOrCreateSignal 

func (_m *SignalServiceClient) GetOrCreateSignal(ctx context.Context, in *admin.SignalGetOrCreateRequest, opts ...grpc.CallOption) (*admin.Signal, error)

GetOrCreateSignal provides a mock function with given fields: ctx, in, opts

func (*SignalServiceClient) ListSignals 

func (_m *SignalServiceClient) ListSignals(ctx context.Context, in *admin.SignalListRequest, opts ...grpc.CallOption) (*admin.SignalList, error)

ListSignals provides a mock function with given fields: ctx, in, opts

func (*SignalServiceClient) OnGetOrCreateSignal 

func (_m *SignalServiceClient) OnGetOrCreateSignal(ctx context.Context, in *admin.SignalGetOrCreateRequest, opts ...grpc.CallOption) *SignalServiceClient_GetOrCreateSignal

func (*SignalServiceClient) OnGetOrCreateSignalMatch 

func (_m *SignalServiceClient) OnGetOrCreateSignalMatch(matchers ...interface{}) *SignalServiceClient_GetOrCreateSignal

func (*SignalServiceClient) OnListSignals 

func (_m *SignalServiceClient) OnListSignals(ctx context.Context, in *admin.SignalListRequest, opts ...grpc.CallOption) *SignalServiceClient_ListSignals

func (*SignalServiceClient) OnListSignalsMatch 

func (_m *SignalServiceClient) OnListSignalsMatch(matchers ...interface{}) *SignalServiceClient_ListSignals

func (*SignalServiceClient) OnSetSignal 

func (_m *SignalServiceClient) OnSetSignal(ctx context.Context, in *admin.SignalSetRequest, opts ...grpc.CallOption) *SignalServiceClient_SetSignal

func (*SignalServiceClient) OnSetSignalMatch 

func (_m *SignalServiceClient) OnSetSignalMatch(matchers ...interface{}) *SignalServiceClient_SetSignal

func (*SignalServiceClient) SetSignal 

func (_m *SignalServiceClient) SetSignal(ctx context.Context, in *admin.SignalSetRequest, opts ...grpc.CallOption) (*admin.SignalSetResponse, error)

SetSignal provides a mock function with given fields: ctx, in, opts

type SignalServiceClient_GetOrCreateSignal 

type SignalServiceClient_GetOrCreateSignal struct {
	*mock.Call
}

func (SignalServiceClient_GetOrCreateSignal) Return 

func (_m SignalServiceClient_GetOrCreateSignal) Return(_a0 *admin.Signal, _a1 error) *SignalServiceClient_GetOrCreateSignal

type SignalServiceClient_ListSignals 

type SignalServiceClient_ListSignals struct {
	*mock.Call
}

func (SignalServiceClient_ListSignals) Return 

func (_m SignalServiceClient_ListSignals) Return(_a0 *admin.SignalList, _a1 error) *SignalServiceClient_ListSignals

type SignalServiceClient_SetSignal 

type SignalServiceClient_SetSignal struct {
	*mock.Call
}

func (SignalServiceClient_SetSignal) Return 

func (_m SignalServiceClient_SetSignal) Return(_a0 *admin.SignalSetResponse, _a1 error) *SignalServiceClient_SetSignal

type SignalServiceServer 

type SignalServiceServer struct {
	mock.Mock
}

SignalServiceServer is an autogenerated mock type for the SignalServiceServer type

func (*SignalServiceServer) GetOrCreateSignal 

func (_m *SignalServiceServer) GetOrCreateSignal(_a0 context.Context, _a1 *admin.SignalGetOrCreateRequest) (*admin.Signal, error)

GetOrCreateSignal provides a mock function with given fields: _a0, _a1

func (*SignalServiceServer) ListSignals 

func (_m *SignalServiceServer) ListSignals(_a0 context.Context, _a1 *admin.SignalListRequest) (*admin.SignalList, error)

ListSignals provides a mock function with given fields: _a0, _a1

func (*SignalServiceServer) OnGetOrCreateSignal 

func (_m *SignalServiceServer) OnGetOrCreateSignal(_a0 context.Context, _a1 *admin.SignalGetOrCreateRequest) *SignalServiceServer_GetOrCreateSignal

func (*SignalServiceServer) OnGetOrCreateSignalMatch 

func (_m *SignalServiceServer) OnGetOrCreateSignalMatch(matchers ...interface{}) *SignalServiceServer_GetOrCreateSignal

func (*SignalServiceServer) OnListSignals 

func (_m *SignalServiceServer) OnListSignals(_a0 context.Context, _a1 *admin.SignalListRequest) *SignalServiceServer_ListSignals

func (*SignalServiceServer) OnListSignalsMatch 

func (_m *SignalServiceServer) OnListSignalsMatch(matchers ...interface{}) *SignalServiceServer_ListSignals

func (*SignalServiceServer) OnSetSignal 

func (_m *SignalServiceServer) OnSetSignal(_a0 context.Context, _a1 *admin.SignalSetRequest) *SignalServiceServer_SetSignal

func (*SignalServiceServer) OnSetSignalMatch 

func (_m *SignalServiceServer) OnSetSignalMatch(matchers ...interface{}) *SignalServiceServer_SetSignal

func (*SignalServiceServer) SetSignal 

func (_m *SignalServiceServer) SetSignal(_a0 context.Context, _a1 *admin.SignalSetRequest) (*admin.SignalSetResponse, error)

SetSignal provides a mock function with given fields: _a0, _a1

type SignalServiceServer_GetOrCreateSignal 

type SignalServiceServer_GetOrCreateSignal struct {
	*mock.Call
}

func (SignalServiceServer_GetOrCreateSignal) Return 

func (_m SignalServiceServer_GetOrCreateSignal) Return(_a0 *admin.Signal, _a1 error) *SignalServiceServer_GetOrCreateSignal

type SignalServiceServer_ListSignals 

type SignalServiceServer_ListSignals struct {
	*mock.Call
}

func (SignalServiceServer_ListSignals) Return 

func (_m SignalServiceServer_ListSignals) Return(_a0 *admin.SignalList, _a1 error) *SignalServiceServer_ListSignals

type SignalServiceServer_SetSignal 

type SignalServiceServer_SetSignal struct {
	*mock.Call
}

func (SignalServiceServer_SetSignal) Return 

func (_m SignalServiceServer_SetSignal) Return(_a0 *admin.SignalSetResponse, _a1 error) *SignalServiceServer_SetSignal

type SyncAgentServiceClient added in v1.11.0 

type SyncAgentServiceClient struct {
	mock.Mock
}

SyncAgentServiceClient is an autogenerated mock type for the SyncAgentServiceClient type

func (*SyncAgentServiceClient) ExecuteTaskSync added in v1.11.0 

func (_m *SyncAgentServiceClient) ExecuteTaskSync(ctx context.Context, opts ...grpc.CallOption) (service.SyncAgentService_ExecuteTaskSyncClient, error)

ExecuteTaskSync provides a mock function with given fields: ctx, opts

func (*SyncAgentServiceClient) OnExecuteTaskSync added in v1.11.0 

func (_m *SyncAgentServiceClient) OnExecuteTaskSync(ctx context.Context, opts ...grpc.CallOption) *SyncAgentServiceClient_ExecuteTaskSync

func (*SyncAgentServiceClient) OnExecuteTaskSyncMatch added in v1.11.0 

func (_m *SyncAgentServiceClient) OnExecuteTaskSyncMatch(matchers ...interface{}) *SyncAgentServiceClient_ExecuteTaskSync

type SyncAgentServiceClient_ExecuteTaskSync added in v1.11.0 

type SyncAgentServiceClient_ExecuteTaskSync struct {
	*mock.Call
}

func (SyncAgentServiceClient_ExecuteTaskSync) Return added in v1.11.0 

func (_m SyncAgentServiceClient_ExecuteTaskSync) Return(_a0 service.SyncAgentService_ExecuteTaskSyncClient, _a1 error) *SyncAgentServiceClient_ExecuteTaskSync

type SyncAgentServiceServer added in v1.11.0 

type SyncAgentServiceServer struct {
	mock.Mock
}

SyncAgentServiceServer is an autogenerated mock type for the SyncAgentServiceServer type

func (*SyncAgentServiceServer) ExecuteTaskSync added in v1.11.0 

func (_m *SyncAgentServiceServer) ExecuteTaskSync(_a0 service.SyncAgentService_ExecuteTaskSyncServer) error

ExecuteTaskSync provides a mock function with given fields: _a0

func (*SyncAgentServiceServer) OnExecuteTaskSync added in v1.11.0 

func (_m *SyncAgentServiceServer) OnExecuteTaskSync(_a0 service.SyncAgentService_ExecuteTaskSyncServer) *SyncAgentServiceServer_ExecuteTaskSync

func (*SyncAgentServiceServer) OnExecuteTaskSyncMatch added in v1.11.0 

func (_m *SyncAgentServiceServer) OnExecuteTaskSyncMatch(matchers ...interface{}) *SyncAgentServiceServer_ExecuteTaskSync

type SyncAgentServiceServer_ExecuteTaskSync added in v1.11.0 

type SyncAgentServiceServer_ExecuteTaskSync struct {
	*mock.Call
}

func (SyncAgentServiceServer_ExecuteTaskSync) Return added in v1.11.0 

func (_m SyncAgentServiceServer_ExecuteTaskSync) Return(_a0 error) *SyncAgentServiceServer_ExecuteTaskSync

type SyncAgentService_ExecuteTaskSyncClient added in v1.11.0 

type SyncAgentService_ExecuteTaskSyncClient struct {
	mock.Mock
}

SyncAgentService_ExecuteTaskSyncClient is an autogenerated mock type for the SyncAgentService_ExecuteTaskSyncClient type

func (*SyncAgentService_ExecuteTaskSyncClient) CloseSend added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) CloseSend() error

CloseSend provides a mock function with given fields:

func (*SyncAgentService_ExecuteTaskSyncClient) Context added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) Context() context.Context

Context provides a mock function with given fields:

func (*SyncAgentService_ExecuteTaskSyncClient) Header added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) Header() (metadata.MD, error)

Header provides a mock function with given fields:

func (*SyncAgentService_ExecuteTaskSyncClient) OnCloseSend added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) OnCloseSend() *SyncAgentService_ExecuteTaskSyncClient_CloseSend

func (*SyncAgentService_ExecuteTaskSyncClient) OnCloseSendMatch added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) OnCloseSendMatch(matchers ...interface{}) *SyncAgentService_ExecuteTaskSyncClient_CloseSend

func (*SyncAgentService_ExecuteTaskSyncClient) OnContext added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) OnContext() *SyncAgentService_ExecuteTaskSyncClient_Context

func (*SyncAgentService_ExecuteTaskSyncClient) OnContextMatch added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) OnContextMatch(matchers ...interface{}) *SyncAgentService_ExecuteTaskSyncClient_Context

func (*SyncAgentService_ExecuteTaskSyncClient) OnHeader added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) OnHeader() *SyncAgentService_ExecuteTaskSyncClient_Header

func (*SyncAgentService_ExecuteTaskSyncClient) OnHeaderMatch added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) OnHeaderMatch(matchers ...interface{}) *SyncAgentService_ExecuteTaskSyncClient_Header

func (*SyncAgentService_ExecuteTaskSyncClient) OnRecv added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) OnRecv() *SyncAgentService_ExecuteTaskSyncClient_Recv

func (*SyncAgentService_ExecuteTaskSyncClient) OnRecvMatch added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) OnRecvMatch(matchers ...interface{}) *SyncAgentService_ExecuteTaskSyncClient_Recv

func (*SyncAgentService_ExecuteTaskSyncClient) OnRecvMsg added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) OnRecvMsg(m interface{}) *SyncAgentService_ExecuteTaskSyncClient_RecvMsg

func (*SyncAgentService_ExecuteTaskSyncClient) OnRecvMsgMatch added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) OnRecvMsgMatch(matchers ...interface{}) *SyncAgentService_ExecuteTaskSyncClient_RecvMsg

func (*SyncAgentService_ExecuteTaskSyncClient) OnSend added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) OnSend(_a0 *admin.ExecuteTaskSyncRequest) *SyncAgentService_ExecuteTaskSyncClient_Send

func (*SyncAgentService_ExecuteTaskSyncClient) OnSendMatch added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) OnSendMatch(matchers ...interface{}) *SyncAgentService_ExecuteTaskSyncClient_Send

func (*SyncAgentService_ExecuteTaskSyncClient) OnSendMsg added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) OnSendMsg(m interface{}) *SyncAgentService_ExecuteTaskSyncClient_SendMsg

func (*SyncAgentService_ExecuteTaskSyncClient) OnSendMsgMatch added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) OnSendMsgMatch(matchers ...interface{}) *SyncAgentService_ExecuteTaskSyncClient_SendMsg

func (*SyncAgentService_ExecuteTaskSyncClient) OnTrailer added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) OnTrailer() *SyncAgentService_ExecuteTaskSyncClient_Trailer

func (*SyncAgentService_ExecuteTaskSyncClient) OnTrailerMatch added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) OnTrailerMatch(matchers ...interface{}) *SyncAgentService_ExecuteTaskSyncClient_Trailer

func (*SyncAgentService_ExecuteTaskSyncClient) Recv added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) Recv() (*admin.ExecuteTaskSyncResponse, error)

Recv provides a mock function with given fields:

func (*SyncAgentService_ExecuteTaskSyncClient) RecvMsg added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*SyncAgentService_ExecuteTaskSyncClient) Send added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) Send(_a0 *admin.ExecuteTaskSyncRequest) error

Send provides a mock function with given fields: _a0

func (*SyncAgentService_ExecuteTaskSyncClient) SendMsg added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*SyncAgentService_ExecuteTaskSyncClient) Trailer added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncClient) Trailer() metadata.MD

Trailer provides a mock function with given fields:

type SyncAgentService_ExecuteTaskSyncClient_CloseSend added in v1.11.0 

type SyncAgentService_ExecuteTaskSyncClient_CloseSend struct {
	*mock.Call
}

func (SyncAgentService_ExecuteTaskSyncClient_CloseSend) Return added in v1.11.0 

func (_m SyncAgentService_ExecuteTaskSyncClient_CloseSend) Return(_a0 error) *SyncAgentService_ExecuteTaskSyncClient_CloseSend

type SyncAgentService_ExecuteTaskSyncClient_Context added in v1.11.0 

type SyncAgentService_ExecuteTaskSyncClient_Context struct {
	*mock.Call
}

func (SyncAgentService_ExecuteTaskSyncClient_Context) Return added in v1.11.0 

func (_m SyncAgentService_ExecuteTaskSyncClient_Context) Return(_a0 context.Context) *SyncAgentService_ExecuteTaskSyncClient_Context

type SyncAgentService_ExecuteTaskSyncClient_Header added in v1.11.0 

type SyncAgentService_ExecuteTaskSyncClient_Header struct {
	*mock.Call
}

func (SyncAgentService_ExecuteTaskSyncClient_Header) Return added in v1.11.0 

func (_m SyncAgentService_ExecuteTaskSyncClient_Header) Return(_a0 metadata.MD, _a1 error) *SyncAgentService_ExecuteTaskSyncClient_Header

type SyncAgentService_ExecuteTaskSyncClient_Recv added in v1.11.0 

type SyncAgentService_ExecuteTaskSyncClient_Recv struct {
	*mock.Call
}

func (SyncAgentService_ExecuteTaskSyncClient_Recv) Return added in v1.11.0 

func (_m SyncAgentService_ExecuteTaskSyncClient_Recv) Return(_a0 *admin.ExecuteTaskSyncResponse, _a1 error) *SyncAgentService_ExecuteTaskSyncClient_Recv

type SyncAgentService_ExecuteTaskSyncClient_RecvMsg added in v1.11.0 

type SyncAgentService_ExecuteTaskSyncClient_RecvMsg struct {
	*mock.Call
}

func (SyncAgentService_ExecuteTaskSyncClient_RecvMsg) Return added in v1.11.0 

func (_m SyncAgentService_ExecuteTaskSyncClient_RecvMsg) Return(_a0 error) *SyncAgentService_ExecuteTaskSyncClient_RecvMsg

type SyncAgentService_ExecuteTaskSyncClient_Send added in v1.11.0 

type SyncAgentService_ExecuteTaskSyncClient_Send struct {
	*mock.Call
}

func (SyncAgentService_ExecuteTaskSyncClient_Send) Return added in v1.11.0 

func (_m SyncAgentService_ExecuteTaskSyncClient_Send) Return(_a0 error) *SyncAgentService_ExecuteTaskSyncClient_Send

type SyncAgentService_ExecuteTaskSyncClient_SendMsg added in v1.11.0 

type SyncAgentService_ExecuteTaskSyncClient_SendMsg struct {
	*mock.Call
}

func (SyncAgentService_ExecuteTaskSyncClient_SendMsg) Return added in v1.11.0 

func (_m SyncAgentService_ExecuteTaskSyncClient_SendMsg) Return(_a0 error) *SyncAgentService_ExecuteTaskSyncClient_SendMsg

type SyncAgentService_ExecuteTaskSyncClient_Trailer added in v1.11.0 

type SyncAgentService_ExecuteTaskSyncClient_Trailer struct {
	*mock.Call
}

func (SyncAgentService_ExecuteTaskSyncClient_Trailer) Return added in v1.11.0 

func (_m SyncAgentService_ExecuteTaskSyncClient_Trailer) Return(_a0 metadata.MD) *SyncAgentService_ExecuteTaskSyncClient_Trailer

type SyncAgentService_ExecuteTaskSyncServer added in v1.11.0 

type SyncAgentService_ExecuteTaskSyncServer struct {
	mock.Mock
}

SyncAgentService_ExecuteTaskSyncServer is an autogenerated mock type for the SyncAgentService_ExecuteTaskSyncServer type

func (*SyncAgentService_ExecuteTaskSyncServer) Context added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) Context() context.Context

Context provides a mock function with given fields:

func (*SyncAgentService_ExecuteTaskSyncServer) OnContext added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) OnContext() *SyncAgentService_ExecuteTaskSyncServer_Context

func (*SyncAgentService_ExecuteTaskSyncServer) OnContextMatch added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) OnContextMatch(matchers ...interface{}) *SyncAgentService_ExecuteTaskSyncServer_Context

func (*SyncAgentService_ExecuteTaskSyncServer) OnRecv added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) OnRecv() *SyncAgentService_ExecuteTaskSyncServer_Recv

func (*SyncAgentService_ExecuteTaskSyncServer) OnRecvMatch added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) OnRecvMatch(matchers ...interface{}) *SyncAgentService_ExecuteTaskSyncServer_Recv

func (*SyncAgentService_ExecuteTaskSyncServer) OnRecvMsg added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) OnRecvMsg(m interface{}) *SyncAgentService_ExecuteTaskSyncServer_RecvMsg

func (*SyncAgentService_ExecuteTaskSyncServer) OnRecvMsgMatch added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) OnRecvMsgMatch(matchers ...interface{}) *SyncAgentService_ExecuteTaskSyncServer_RecvMsg

func (*SyncAgentService_ExecuteTaskSyncServer) OnSend added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) OnSend(_a0 *admin.ExecuteTaskSyncResponse) *SyncAgentService_ExecuteTaskSyncServer_Send

func (*SyncAgentService_ExecuteTaskSyncServer) OnSendHeader added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) OnSendHeader(_a0 metadata.MD) *SyncAgentService_ExecuteTaskSyncServer_SendHeader

func (*SyncAgentService_ExecuteTaskSyncServer) OnSendHeaderMatch added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) OnSendHeaderMatch(matchers ...interface{}) *SyncAgentService_ExecuteTaskSyncServer_SendHeader

func (*SyncAgentService_ExecuteTaskSyncServer) OnSendMatch added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) OnSendMatch(matchers ...interface{}) *SyncAgentService_ExecuteTaskSyncServer_Send

func (*SyncAgentService_ExecuteTaskSyncServer) OnSendMsg added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) OnSendMsg(m interface{}) *SyncAgentService_ExecuteTaskSyncServer_SendMsg

func (*SyncAgentService_ExecuteTaskSyncServer) OnSendMsgMatch added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) OnSendMsgMatch(matchers ...interface{}) *SyncAgentService_ExecuteTaskSyncServer_SendMsg

func (*SyncAgentService_ExecuteTaskSyncServer) OnSetHeader added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) OnSetHeader(_a0 metadata.MD) *SyncAgentService_ExecuteTaskSyncServer_SetHeader

func (*SyncAgentService_ExecuteTaskSyncServer) OnSetHeaderMatch added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) OnSetHeaderMatch(matchers ...interface{}) *SyncAgentService_ExecuteTaskSyncServer_SetHeader

func (*SyncAgentService_ExecuteTaskSyncServer) Recv added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) Recv() (*admin.ExecuteTaskSyncRequest, error)

Recv provides a mock function with given fields:

func (*SyncAgentService_ExecuteTaskSyncServer) RecvMsg added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*SyncAgentService_ExecuteTaskSyncServer) Send added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) Send(_a0 *admin.ExecuteTaskSyncResponse) error

Send provides a mock function with given fields: _a0

func (*SyncAgentService_ExecuteTaskSyncServer) SendHeader added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) SendHeader(_a0 metadata.MD) error

SendHeader provides a mock function with given fields: _a0

func (*SyncAgentService_ExecuteTaskSyncServer) SendMsg added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*SyncAgentService_ExecuteTaskSyncServer) SetHeader added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) SetHeader(_a0 metadata.MD) error

SetHeader provides a mock function with given fields: _a0

func (*SyncAgentService_ExecuteTaskSyncServer) SetTrailer added in v1.11.0 

func (_m *SyncAgentService_ExecuteTaskSyncServer) SetTrailer(_a0 metadata.MD)

SetTrailer provides a mock function with given fields: _a0

type SyncAgentService_ExecuteTaskSyncServer_Context added in v1.11.0 

type SyncAgentService_ExecuteTaskSyncServer_Context struct {
	*mock.Call
}

func (SyncAgentService_ExecuteTaskSyncServer_Context) Return added in v1.11.0 

func (_m SyncAgentService_ExecuteTaskSyncServer_Context) Return(_a0 context.Context) *SyncAgentService_ExecuteTaskSyncServer_Context

type SyncAgentService_ExecuteTaskSyncServer_Recv added in v1.11.0 

type SyncAgentService_ExecuteTaskSyncServer_Recv struct {
	*mock.Call
}

func (SyncAgentService_ExecuteTaskSyncServer_Recv) Return added in v1.11.0 

func (_m SyncAgentService_ExecuteTaskSyncServer_Recv) Return(_a0 *admin.ExecuteTaskSyncRequest, _a1 error) *SyncAgentService_ExecuteTaskSyncServer_Recv

type SyncAgentService_ExecuteTaskSyncServer_RecvMsg added in v1.11.0 

type SyncAgentService_ExecuteTaskSyncServer_RecvMsg struct {
	*mock.Call
}

func (SyncAgentService_ExecuteTaskSyncServer_RecvMsg) Return added in v1.11.0 

func (_m SyncAgentService_ExecuteTaskSyncServer_RecvMsg) Return(_a0 error) *SyncAgentService_ExecuteTaskSyncServer_RecvMsg

type SyncAgentService_ExecuteTaskSyncServer_Send added in v1.11.0 

type SyncAgentService_ExecuteTaskSyncServer_Send struct {
	*mock.Call
}

func (SyncAgentService_ExecuteTaskSyncServer_Send) Return added in v1.11.0 

func (_m SyncAgentService_ExecuteTaskSyncServer_Send) Return(_a0 error) *SyncAgentService_ExecuteTaskSyncServer_Send

type SyncAgentService_ExecuteTaskSyncServer_SendHeader added in v1.11.0 

type SyncAgentService_ExecuteTaskSyncServer_SendHeader struct {
	*mock.Call
}

func (SyncAgentService_ExecuteTaskSyncServer_SendHeader) Return added in v1.11.0 

func (_m SyncAgentService_ExecuteTaskSyncServer_SendHeader) Return(_a0 error) *SyncAgentService_ExecuteTaskSyncServer_SendHeader

type SyncAgentService_ExecuteTaskSyncServer_SendMsg added in v1.11.0 

type SyncAgentService_ExecuteTaskSyncServer_SendMsg struct {
	*mock.Call
}

func (SyncAgentService_ExecuteTaskSyncServer_SendMsg) Return added in v1.11.0 

func (_m SyncAgentService_ExecuteTaskSyncServer_SendMsg) Return(_a0 error) *SyncAgentService_ExecuteTaskSyncServer_SendMsg

type SyncAgentService_ExecuteTaskSyncServer_SetHeader added in v1.11.0 

type SyncAgentService_ExecuteTaskSyncServer_SetHeader struct {
	*mock.Call
}

func (SyncAgentService_ExecuteTaskSyncServer_SetHeader) Return added in v1.11.0 

func (_m SyncAgentService_ExecuteTaskSyncServer_SetHeader) Return(_a0 error) *SyncAgentService_ExecuteTaskSyncServer_SetHeader

type TokenSource 

type TokenSource struct {
	mock.Mock
}

TokenSource is an autogenerated mock type for the TokenSource type

func (*TokenSource) OnToken 

func (_m *TokenSource) OnToken() *TokenSource_Token

func (*TokenSource) OnTokenMatch 

func (_m *TokenSource) OnTokenMatch(matchers ...interface{}) *TokenSource_Token

func (*TokenSource) Token 

func (_m *TokenSource) Token() (*oauth2.Token, error)

Token provides a mock function with given fields:

type TokenSource_Token 

type TokenSource_Token struct {
	*mock.Call
}

func (TokenSource_Token) Return 

func (_m TokenSource_Token) Return(_a0 *oauth2.Token, _a1 error) *TokenSource_Token

type UnsafeAdminServiceServer added in v1.10.7 

type UnsafeAdminServiceServer struct {
	mock.Mock
}

UnsafeAdminServiceServer is an autogenerated mock type for the UnsafeAdminServiceServer type

type UnsafeAgentMetadataServiceServer added in v1.10.7 

type UnsafeAgentMetadataServiceServer struct {
	mock.Mock
}

UnsafeAgentMetadataServiceServer is an autogenerated mock type for the UnsafeAgentMetadataServiceServer type

type UnsafeAsyncAgentServiceServer added in v1.10.7 

type UnsafeAsyncAgentServiceServer struct {
	mock.Mock
}

UnsafeAsyncAgentServiceServer is an autogenerated mock type for the UnsafeAsyncAgentServiceServer type

type UnsafeAuthMetadataServiceServer added in v1.10.7 

type UnsafeAuthMetadataServiceServer struct {
	mock.Mock
}

UnsafeAuthMetadataServiceServer is an autogenerated mock type for the UnsafeAuthMetadataServiceServer type

type UnsafeDataProxyServiceServer added in v1.10.7 

type UnsafeDataProxyServiceServer struct {
	mock.Mock
}

UnsafeDataProxyServiceServer is an autogenerated mock type for the UnsafeDataProxyServiceServer type

type UnsafeExternalPluginServiceServer added in v1.10.7 

type UnsafeExternalPluginServiceServer struct {
	mock.Mock
}

UnsafeExternalPluginServiceServer is an autogenerated mock type for the UnsafeExternalPluginServiceServer type

type UnsafeIdentityServiceServer added in v1.10.7 

type UnsafeIdentityServiceServer struct {
	mock.Mock
}

UnsafeIdentityServiceServer is an autogenerated mock type for the UnsafeIdentityServiceServer type

type UnsafeSignalServiceServer added in v1.10.7 

type UnsafeSignalServiceServer struct {
	mock.Mock
}

UnsafeSignalServiceServer is an autogenerated mock type for the UnsafeSignalServiceServer type

type UnsafeSyncAgentServiceServer added in v1.11.0 

type UnsafeSyncAgentServiceServer struct {
	mock.Mock
}

UnsafeSyncAgentServiceServer is an autogenerated mock type for the UnsafeSyncAgentServiceServer type

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.