mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-04 02:04:03 +00:00
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.
211 lines
7.5 KiB
Go
211 lines
7.5 KiB
Go
// Code generated by MockGen. DO NOT EDIT.
|
|
// Source: component.go
|
|
//
|
|
// Generated by this command:
|
|
//
|
|
// mockgen -package chasm -source component.go -destination component_mock.go
|
|
//
|
|
|
|
// Package chasm is a generated GoMock package.
|
|
package chasm
|
|
|
|
import (
|
|
reflect "reflect"
|
|
|
|
gomock "go.uber.org/mock/gomock"
|
|
)
|
|
|
|
// MockComponent is a mock of Component interface.
|
|
type MockComponent struct {
|
|
ctrl *gomock.Controller
|
|
recorder *MockComponentMockRecorder
|
|
isgomock struct{}
|
|
}
|
|
|
|
// MockComponentMockRecorder is the mock recorder for MockComponent.
|
|
type MockComponentMockRecorder struct {
|
|
mock *MockComponent
|
|
}
|
|
|
|
// NewMockComponent creates a new mock instance.
|
|
func NewMockComponent(ctrl *gomock.Controller) *MockComponent {
|
|
mock := &MockComponent{ctrl: ctrl}
|
|
mock.recorder = &MockComponentMockRecorder{mock}
|
|
return mock
|
|
}
|
|
|
|
// EXPECT returns an object that allows the caller to indicate expected use.
|
|
func (m *MockComponent) EXPECT() *MockComponentMockRecorder {
|
|
return m.recorder
|
|
}
|
|
|
|
// LifecycleState mocks base method.
|
|
func (m *MockComponent) LifecycleState(arg0 Context) LifecycleState {
|
|
m.ctrl.T.Helper()
|
|
ret := m.ctrl.Call(m, "LifecycleState", arg0)
|
|
ret0, _ := ret[0].(LifecycleState)
|
|
return ret0
|
|
}
|
|
|
|
// LifecycleState indicates an expected call of LifecycleState.
|
|
func (mr *MockComponentMockRecorder) LifecycleState(arg0 any) *gomock.Call {
|
|
mr.mock.ctrl.T.Helper()
|
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "LifecycleState", reflect.TypeOf((*MockComponent)(nil).LifecycleState), arg0)
|
|
}
|
|
|
|
// mustEmbedUnimplementedComponent mocks base method.
|
|
func (m *MockComponent) mustEmbedUnimplementedComponent() {
|
|
m.ctrl.T.Helper()
|
|
m.ctrl.Call(m, "mustEmbedUnimplementedComponent")
|
|
}
|
|
|
|
// mustEmbedUnimplementedComponent indicates an expected call of mustEmbedUnimplementedComponent.
|
|
func (mr *MockComponentMockRecorder) mustEmbedUnimplementedComponent() *gomock.Call {
|
|
mr.mock.ctrl.T.Helper()
|
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "mustEmbedUnimplementedComponent", reflect.TypeOf((*MockComponent)(nil).mustEmbedUnimplementedComponent))
|
|
}
|
|
|
|
// MockTerminableComponent is a mock of TerminableComponent interface.
|
|
type MockTerminableComponent struct {
|
|
ctrl *gomock.Controller
|
|
recorder *MockTerminableComponentMockRecorder
|
|
isgomock struct{}
|
|
}
|
|
|
|
// MockTerminableComponentMockRecorder is the mock recorder for MockTerminableComponent.
|
|
type MockTerminableComponentMockRecorder struct {
|
|
mock *MockTerminableComponent
|
|
}
|
|
|
|
// NewMockTerminableComponent creates a new mock instance.
|
|
func NewMockTerminableComponent(ctrl *gomock.Controller) *MockTerminableComponent {
|
|
mock := &MockTerminableComponent{ctrl: ctrl}
|
|
mock.recorder = &MockTerminableComponentMockRecorder{mock}
|
|
return mock
|
|
}
|
|
|
|
// EXPECT returns an object that allows the caller to indicate expected use.
|
|
func (m *MockTerminableComponent) EXPECT() *MockTerminableComponentMockRecorder {
|
|
return m.recorder
|
|
}
|
|
|
|
// LifecycleState mocks base method.
|
|
func (m *MockTerminableComponent) LifecycleState(arg0 Context) LifecycleState {
|
|
m.ctrl.T.Helper()
|
|
ret := m.ctrl.Call(m, "LifecycleState", arg0)
|
|
ret0, _ := ret[0].(LifecycleState)
|
|
return ret0
|
|
}
|
|
|
|
// LifecycleState indicates an expected call of LifecycleState.
|
|
func (mr *MockTerminableComponentMockRecorder) LifecycleState(arg0 any) *gomock.Call {
|
|
mr.mock.ctrl.T.Helper()
|
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "LifecycleState", reflect.TypeOf((*MockTerminableComponent)(nil).LifecycleState), arg0)
|
|
}
|
|
|
|
// Terminate mocks base method.
|
|
func (m *MockTerminableComponent) Terminate(arg0 MutableContext, arg1 TerminateComponentRequest) (TerminateComponentResponse, error) {
|
|
m.ctrl.T.Helper()
|
|
ret := m.ctrl.Call(m, "Terminate", arg0, arg1)
|
|
ret0, _ := ret[0].(TerminateComponentResponse)
|
|
ret1, _ := ret[1].(error)
|
|
return ret0, ret1
|
|
}
|
|
|
|
// Terminate indicates an expected call of Terminate.
|
|
func (mr *MockTerminableComponentMockRecorder) Terminate(arg0, arg1 any) *gomock.Call {
|
|
mr.mock.ctrl.T.Helper()
|
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Terminate", reflect.TypeOf((*MockTerminableComponent)(nil).Terminate), arg0, arg1)
|
|
}
|
|
|
|
// mustEmbedUnimplementedComponent mocks base method.
|
|
func (m *MockTerminableComponent) mustEmbedUnimplementedComponent() {
|
|
m.ctrl.T.Helper()
|
|
m.ctrl.Call(m, "mustEmbedUnimplementedComponent")
|
|
}
|
|
|
|
// mustEmbedUnimplementedComponent indicates an expected call of mustEmbedUnimplementedComponent.
|
|
func (mr *MockTerminableComponentMockRecorder) mustEmbedUnimplementedComponent() *gomock.Call {
|
|
mr.mock.ctrl.T.Helper()
|
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "mustEmbedUnimplementedComponent", reflect.TypeOf((*MockTerminableComponent)(nil).mustEmbedUnimplementedComponent))
|
|
}
|
|
|
|
// MockRootComponent is a mock of RootComponent interface.
|
|
type MockRootComponent struct {
|
|
ctrl *gomock.Controller
|
|
recorder *MockRootComponentMockRecorder
|
|
isgomock struct{}
|
|
}
|
|
|
|
// MockRootComponentMockRecorder is the mock recorder for MockRootComponent.
|
|
type MockRootComponentMockRecorder struct {
|
|
mock *MockRootComponent
|
|
}
|
|
|
|
// NewMockRootComponent creates a new mock instance.
|
|
func NewMockRootComponent(ctrl *gomock.Controller) *MockRootComponent {
|
|
mock := &MockRootComponent{ctrl: ctrl}
|
|
mock.recorder = &MockRootComponentMockRecorder{mock}
|
|
return mock
|
|
}
|
|
|
|
// EXPECT returns an object that allows the caller to indicate expected use.
|
|
func (m *MockRootComponent) EXPECT() *MockRootComponentMockRecorder {
|
|
return m.recorder
|
|
}
|
|
|
|
// ContextMetadata mocks base method.
|
|
func (m *MockRootComponent) ContextMetadata(arg0 Context) map[string]string {
|
|
m.ctrl.T.Helper()
|
|
ret := m.ctrl.Call(m, "ContextMetadata", arg0)
|
|
ret0, _ := ret[0].(map[string]string)
|
|
return ret0
|
|
}
|
|
|
|
// ContextMetadata indicates an expected call of ContextMetadata.
|
|
func (mr *MockRootComponentMockRecorder) ContextMetadata(arg0 any) *gomock.Call {
|
|
mr.mock.ctrl.T.Helper()
|
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ContextMetadata", reflect.TypeOf((*MockRootComponent)(nil).ContextMetadata), arg0)
|
|
}
|
|
|
|
// LifecycleState mocks base method.
|
|
func (m *MockRootComponent) LifecycleState(arg0 Context) LifecycleState {
|
|
m.ctrl.T.Helper()
|
|
ret := m.ctrl.Call(m, "LifecycleState", arg0)
|
|
ret0, _ := ret[0].(LifecycleState)
|
|
return ret0
|
|
}
|
|
|
|
// LifecycleState indicates an expected call of LifecycleState.
|
|
func (mr *MockRootComponentMockRecorder) LifecycleState(arg0 any) *gomock.Call {
|
|
mr.mock.ctrl.T.Helper()
|
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "LifecycleState", reflect.TypeOf((*MockRootComponent)(nil).LifecycleState), arg0)
|
|
}
|
|
|
|
// Terminate mocks base method.
|
|
func (m *MockRootComponent) Terminate(arg0 MutableContext, arg1 TerminateComponentRequest) (TerminateComponentResponse, error) {
|
|
m.ctrl.T.Helper()
|
|
ret := m.ctrl.Call(m, "Terminate", arg0, arg1)
|
|
ret0, _ := ret[0].(TerminateComponentResponse)
|
|
ret1, _ := ret[1].(error)
|
|
return ret0, ret1
|
|
}
|
|
|
|
// Terminate indicates an expected call of Terminate.
|
|
func (mr *MockRootComponentMockRecorder) Terminate(arg0, arg1 any) *gomock.Call {
|
|
mr.mock.ctrl.T.Helper()
|
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Terminate", reflect.TypeOf((*MockRootComponent)(nil).Terminate), arg0, arg1)
|
|
}
|
|
|
|
// mustEmbedUnimplementedComponent mocks base method.
|
|
func (m *MockRootComponent) mustEmbedUnimplementedComponent() {
|
|
m.ctrl.T.Helper()
|
|
m.ctrl.Call(m, "mustEmbedUnimplementedComponent")
|
|
}
|
|
|
|
// mustEmbedUnimplementedComponent indicates an expected call of mustEmbedUnimplementedComponent.
|
|
func (mr *MockRootComponentMockRecorder) mustEmbedUnimplementedComponent() *gomock.Call {
|
|
mr.mock.ctrl.T.Helper()
|
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "mustEmbedUnimplementedComponent", reflect.TypeOf((*MockRootComponent)(nil).mustEmbedUnimplementedComponent))
|
|
}
|