mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-04 02:04:03 +00:00
zeekay
40351cce6f
Goes from 135 MB binary with 1153 files importing go.temporal.io and 224
importing google.golang.org/grpc to a 10 MB native binary with ZERO of
either.
Deleted:
- tasks/, tasktests/, service/, chasm/, client/, api/, proto/, tools/
- cmd/tools/, components/, docker/
- schema/{cassandra,elasticsearch,mysql,postgresql,sqlite}/
- 40 tainted common/ subdirs + 7 top-level common files
- tests/testutils (no longer referenced after surviving deps drop common)
New cmd/tasksd (~100 lines) boots tasks.Embed (zap.Node) + http.Server.
New pkg/tasks/embed.go registers ZAP handlers for the SDK opcode surface
(0x0060-0x00A5). Workflow handlers return a 501 "not yet implemented"
envelope; native engine lands behind this contract.
Build: go build ./cmd/tasksd → 10 MB
Vet: go vet ./... → clean
Boot: tasksd --zap-port 9999 --http :7243
Probes: /healthz, /v1/tasks/health → 200
UI: /_/tasks/, / → 200 (embedded Vite bundle)
ZAP: _tasks._tcp on :9999 (mDNS disabled; direct connect)
go.mod: tidy. No go.temporal.io. No google.golang.org/grpc.
73 lines
2.7 KiB
Go
73 lines
2.7 KiB
Go
// Code generated by MockGen. DO NOT EDIT.
|
|
// Source: visibility_manager.go
|
|
//
|
|
// Generated by this command:
|
|
//
|
|
// mockgen -package chasm -source visibility_manager.go -destination visibility_manager_mock.go
|
|
//
|
|
|
|
// Package chasm is a generated GoMock package.
|
|
package chasm
|
|
|
|
import (
|
|
context "context"
|
|
reflect "reflect"
|
|
|
|
visibilityservice "go.temporal.io/server/api/visibilityservice/v1"
|
|
gomock "go.uber.org/mock/gomock"
|
|
)
|
|
|
|
// MockVisibilityManager is a mock of VisibilityManager interface.
|
|
type MockVisibilityManager struct {
|
|
ctrl *gomock.Controller
|
|
recorder *MockVisibilityManagerMockRecorder
|
|
isgomock struct{}
|
|
}
|
|
|
|
// MockVisibilityManagerMockRecorder is the mock recorder for MockVisibilityManager.
|
|
type MockVisibilityManagerMockRecorder struct {
|
|
mock *MockVisibilityManager
|
|
}
|
|
|
|
// NewMockVisibilityManager creates a new mock instance.
|
|
func NewMockVisibilityManager(ctrl *gomock.Controller) *MockVisibilityManager {
|
|
mock := &MockVisibilityManager{ctrl: ctrl}
|
|
mock.recorder = &MockVisibilityManagerMockRecorder{mock}
|
|
return mock
|
|
}
|
|
|
|
// EXPECT returns an object that allows the caller to indicate expected use.
|
|
func (m *MockVisibilityManager) EXPECT() *MockVisibilityManagerMockRecorder {
|
|
return m.recorder
|
|
}
|
|
|
|
// CountExecutions mocks base method.
|
|
func (m *MockVisibilityManager) CountExecutions(arg0 context.Context, arg1 reflect.Type, arg2 *CountExecutionsRequest) (*visibilityservice.CountChasmExecutionsResponse, error) {
|
|
m.ctrl.T.Helper()
|
|
ret := m.ctrl.Call(m, "CountExecutions", arg0, arg1, arg2)
|
|
ret0, _ := ret[0].(*visibilityservice.CountChasmExecutionsResponse)
|
|
ret1, _ := ret[1].(error)
|
|
return ret0, ret1
|
|
}
|
|
|
|
// CountExecutions indicates an expected call of CountExecutions.
|
|
func (mr *MockVisibilityManagerMockRecorder) CountExecutions(arg0, arg1, arg2 any) *gomock.Call {
|
|
mr.mock.ctrl.T.Helper()
|
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CountExecutions", reflect.TypeOf((*MockVisibilityManager)(nil).CountExecutions), arg0, arg1, arg2)
|
|
}
|
|
|
|
// ListExecutions mocks base method.
|
|
func (m *MockVisibilityManager) ListExecutions(arg0 context.Context, arg1 reflect.Type, arg2 *ListExecutionsRequest) (*visibilityservice.ListChasmExecutionsResponse, error) {
|
|
m.ctrl.T.Helper()
|
|
ret := m.ctrl.Call(m, "ListExecutions", arg0, arg1, arg2)
|
|
ret0, _ := ret[0].(*visibilityservice.ListChasmExecutionsResponse)
|
|
ret1, _ := ret[1].(error)
|
|
return ret0, ret1
|
|
}
|
|
|
|
// ListExecutions indicates an expected call of ListExecutions.
|
|
func (mr *MockVisibilityManagerMockRecorder) ListExecutions(arg0, arg1, arg2 any) *gomock.Call {
|
|
mr.mock.ctrl.T.Helper()
|
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListExecutions", reflect.TypeOf((*MockVisibilityManager)(nil).ListExecutions), arg0, arg1, arg2)
|
|
}
|