Skip to content

Commit ba2d711

Browse files
Remove unused Temporal interface (#3761)
1 parent 86e9d32 commit ba2d711

File tree

2 files changed

+3
-14
lines changed

2 files changed

+3
-14
lines changed

host/onebox.go

+2-13
Original file line numberDiff line numberDiff line change
@@ -76,17 +76,6 @@ import (
7676
"go.temporal.io/server/temporal"
7777
)
7878

79-
// Temporal hosts all of temporal services in one process
80-
type Temporal interface {
81-
Start() error
82-
Stop()
83-
GetAdminClient() adminservice.AdminServiceClient
84-
GetFrontendClient() workflowservice.WorkflowServiceClient
85-
GetHistoryClient() historyservice.HistoryServiceClient
86-
GetExecutionManager() persistence.ExecutionManager
87-
RefreshNamespaceCache()
88-
}
89-
9079
type (
9180
temporalImpl struct {
9281
frontendService *frontend.Service
@@ -168,8 +157,8 @@ type (
168157
listenHostPort string
169158
)
170159

171-
// NewTemporal returns an instance that hosts full temporal in one process
172-
func NewTemporal(params *TemporalParams) *temporalImpl {
160+
// newTemporal returns an instance that hosts full temporal in one process
161+
func newTemporal(params *TemporalParams) *temporalImpl {
173162
testDCClient := newTestDCClient(dynamicconfig.NewNoopClient())
174163
for k, v := range params.DynamicConfigOverrides {
175164
testDCClient.OverrideValue(k, v)

host/test_cluster.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -224,7 +224,7 @@ func NewCluster(options *TestClusterConfig, logger log.Logger) (*TestCluster, er
224224
logger.Fatal("Failed to start pprof", tag.Error(err))
225225
}
226226

227-
cluster := NewTemporal(temporalParams)
227+
cluster := newTemporal(temporalParams)
228228
if err := cluster.Start(); err != nil {
229229
return nil, err
230230
}

0 commit comments

Comments
 (0)