diff --git a/host/onebox.go b/host/onebox.go index 74f80479247..66e3d40bb36 100644 --- a/host/onebox.go +++ b/host/onebox.go @@ -76,17 +76,6 @@ import ( "go.temporal.io/server/temporal" ) -// Temporal hosts all of temporal services in one process -type Temporal interface { - Start() error - Stop() - GetAdminClient() adminservice.AdminServiceClient - GetFrontendClient() workflowservice.WorkflowServiceClient - GetHistoryClient() historyservice.HistoryServiceClient - GetExecutionManager() persistence.ExecutionManager - RefreshNamespaceCache() -} - type ( temporalImpl struct { frontendService *frontend.Service @@ -168,8 +157,8 @@ type ( listenHostPort string ) -// NewTemporal returns an instance that hosts full temporal in one process -func NewTemporal(params *TemporalParams) *temporalImpl { +// newTemporal returns an instance that hosts full temporal in one process +func newTemporal(params *TemporalParams) *temporalImpl { testDCClient := newTestDCClient(dynamicconfig.NewNoopClient()) for k, v := range params.DynamicConfigOverrides { testDCClient.OverrideValue(k, v) diff --git a/host/test_cluster.go b/host/test_cluster.go index da3a183f5d3..929ea313c83 100644 --- a/host/test_cluster.go +++ b/host/test_cluster.go @@ -224,7 +224,7 @@ func NewCluster(options *TestClusterConfig, logger log.Logger) (*TestCluster, er logger.Fatal("Failed to start pprof", tag.Error(err)) } - cluster := NewTemporal(temporalParams) + cluster := newTemporal(temporalParams) if err := cluster.Start(); err != nil { return nil, err }