Documentation
¶
Index ¶
- type Configurer
- type TemporalInterceptorPlugin
- func (pt *TemporalInterceptorPlugin) Init(cfg Configurer) error
- func (pt *TemporalInterceptorPlugin) Name() string
- func (pt *TemporalInterceptorPlugin) Serve() chan error
- func (pt *TemporalInterceptorPlugin) Stop(context.Context) error
- func (pt *TemporalInterceptorPlugin) WorkerInterceptor() interceptor.WorkerInterceptor
- type TestServer
- func NewTestServer(t *testing.T, stopCh chan struct{}, wg *sync.WaitGroup) *TestServer
- func NewTestServerLA(t *testing.T, stopCh chan struct{}, wg *sync.WaitGroup) *TestServer
- func NewTestServerTLS(t *testing.T, stopCh chan struct{}, wg *sync.WaitGroup, configName string) *TestServer
- func NewTestServerWithInterceptor(t *testing.T, stopCh chan struct{}, wg *sync.WaitGroup) *TestServer
- func NewTestServerWithMetrics(t *testing.T, stopCh chan struct{}, cfg Configurer, wg *sync.WaitGroup) *TestServer
- func NewTestServerWithOtelInterceptor(t *testing.T, stopCh chan struct{}, wg *sync.WaitGroup) *TestServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Configurer ¶
type TemporalInterceptorPlugin ¶
type TemporalInterceptorPlugin struct {
// contains filtered or unexported fields
}
func (*TemporalInterceptorPlugin) Init ¶
func (pt *TemporalInterceptorPlugin) Init(cfg Configurer) error
func (*TemporalInterceptorPlugin) Name ¶
func (pt *TemporalInterceptorPlugin) Name() string
func (*TemporalInterceptorPlugin) Serve ¶
func (pt *TemporalInterceptorPlugin) Serve() chan error
func (*TemporalInterceptorPlugin) Stop ¶
func (pt *TemporalInterceptorPlugin) Stop(context.Context) error
func (*TemporalInterceptorPlugin) WorkerInterceptor ¶
func (pt *TemporalInterceptorPlugin) WorkerInterceptor() interceptor.WorkerInterceptor
type TestServer ¶
type TestServer struct {
Client temporalClient.Client
}
func NewTestServer ¶
func NewTestServer(t *testing.T, stopCh chan struct{}, wg *sync.WaitGroup) *TestServer
func NewTestServerLA ¶
func NewTestServerLA(t *testing.T, stopCh chan struct{}, wg *sync.WaitGroup) *TestServer
func NewTestServerTLS ¶
func NewTestServerWithInterceptor ¶
func NewTestServerWithInterceptor(t *testing.T, stopCh chan struct{}, wg *sync.WaitGroup) *TestServer
func NewTestServerWithMetrics ¶
func NewTestServerWithMetrics(t *testing.T, stopCh chan struct{}, cfg Configurer, wg *sync.WaitGroup) *TestServer
func NewTestServerWithOtelInterceptor ¶
func NewTestServerWithOtelInterceptor(t *testing.T, stopCh chan struct{}, wg *sync.WaitGroup) *TestServer
func (*TestServer) AssertContainsEvent ¶
func (s *TestServer) AssertContainsEvent(client temporalClient.Client, t *testing.T, w temporalClient.WorkflowRun, assert func(*history.HistoryEvent) bool)
func (*TestServer) AssertNotContainsEvent ¶
func (s *TestServer) AssertNotContainsEvent(client temporalClient.Client, t *testing.T, w temporalClient.WorkflowRun, assert func(*history.HistoryEvent) bool)
Source Files
Click to show internal directories.
Click to hide internal directories.