@@ -435,16 +435,6 @@ func GetActivityExecutionKey(iid string, taskID int32) string {
435435 return iid + "/" + strconv .FormatInt (int64 (taskID ), 10 )
436436}
437437
438- // CreateTaskHub implements protos.TaskHubSidecarServiceServer
439- func (grpcExecutor ) CreateTaskHub (context.Context , * protos.CreateTaskHubRequest ) (* protos.CreateTaskHubResponse , error ) {
440- return nil , errors .New ("unimplemented" )
441- }
442-
443- // DeleteTaskHub implements protos.TaskHubSidecarServiceServer
444- func (grpcExecutor ) DeleteTaskHub (context.Context , * protos.DeleteTaskHubRequest ) (* protos.DeleteTaskHubResponse , error ) {
445- return nil , errors .New ("unimplemented" )
446- }
447-
448438// GetInstance implements protos.TaskHubSidecarServiceServer
449439func (g * grpcExecutor ) GetInstance (ctx context.Context , req * protos.GetInstanceRequest ) (* protos.GetInstanceResponse , error ) {
450440 metadata , err := g .backend .GetOrchestrationMetadata (ctx , api .InstanceID (req .InstanceId ))
@@ -476,11 +466,6 @@ func (g *grpcExecutor) PurgeInstances(ctx context.Context, req *protos.PurgeInst
476466 return resp , nil
477467}
478468
479- // QueryInstances implements protos.TaskHubSidecarServiceServer
480- func (grpcExecutor ) QueryInstances (context.Context , * protos.QueryInstancesRequest ) (* protos.QueryInstancesResponse , error ) {
481- return nil , errors .New ("unimplemented" )
482- }
483-
484469// RaiseEvent implements protos.TaskHubSidecarServiceServer
485470func (g * grpcExecutor ) RaiseEvent (ctx context.Context , req * protos.RaiseEventRequest ) (* protos.RaiseEventResponse , error ) {
486471 e := & protos.HistoryEvent {
@@ -696,42 +681,3 @@ func createGetInstanceResponse(req *protos.GetInstanceRequest, metadata *Orchest
696681 return & protos.GetInstanceResponse {Exists : true , OrchestrationState : state }
697682}
698683
699- func (executor * grpcExecutor ) AbandonTaskActivityWorkItem (ctx context.Context , in * protos.AbandonActivityTaskRequest ) (* protos.AbandonActivityTaskResponse , error ) {
700- return nil , nil
701- }
702-
703- func (* grpcExecutor ) AbandonTaskEntityWorkItem (ctx context.Context , in * protos.AbandonEntityTaskRequest ) (* protos.AbandonEntityTaskResponse , error ) {
704- return nil , nil
705- }
706-
707- func (* grpcExecutor ) AbandonTaskOrchestratorWorkItem (ctx context.Context , in * protos.AbandonOrchestrationTaskRequest ) (* protos.AbandonOrchestrationTaskResponse , error ) {
708- return nil , nil
709- }
710-
711- func (* grpcExecutor ) CleanEntityStorage (ctx context.Context , in * protos.CleanEntityStorageRequest ) (* protos.CleanEntityStorageResponse , error ) {
712- return nil , nil
713- }
714-
715- func (* grpcExecutor ) CompleteEntityTask (ctx context.Context , in * protos.EntityBatchResult ) (* protos.CompleteTaskResponse , error ) {
716- return nil , nil
717- }
718-
719- func (* grpcExecutor ) GetEntity (ctx context.Context , in * protos.GetEntityRequest ) (* protos.GetEntityResponse , error ) {
720- return nil , nil
721- }
722-
723- func (* grpcExecutor ) QueryEntities (ctx context.Context , in * protos.QueryEntitiesRequest ) (* protos.QueryEntitiesResponse , error ) {
724- return nil , nil
725- }
726-
727- func (* grpcExecutor ) RewindInstance (ctx context.Context , in * protos.RewindInstanceRequest ) (* protos.RewindInstanceResponse , error ) {
728- return nil , nil
729- }
730-
731- func (* grpcExecutor ) SignalEntity (ctx context.Context , in * protos.SignalEntityRequest ) (* protos.SignalEntityResponse , error ) {
732- return nil , nil
733- }
734-
735- func (* grpcExecutor ) StreamInstanceHistory (in * protos.StreamInstanceHistoryRequest , srv protos.TaskHubSidecarService_StreamInstanceHistoryServer ) error {
736- return nil
737- }
0 commit comments