kubelatte-ce
Форк от sbertech/kubelatte-ce
41 строка · 925.0 Байт
1package grpc2
3import (4"context"5"github.com/stretchr/testify/mock"6"gitverse.ru/synapse/kubelatte/pkg/observability/logger/lib"7"gitverse.ru/synapse/kubelatte/pkg/sideeffect/grpc/proto"8"gitverse.ru/synapse/kubelatte/pkg/sideeffect/sideeffect"9"go.uber.org/zap"10"testing"11)
12
13var port = 868714
15func TestStartExecServer(t *testing.T) {16lib.ZapLogger = zap.NewNop()17
18sideEffector := sideeffect.NewExecutor(nil)19
20shutdown := StartExecuteServer(port, sideEffector)21shutdown()22}
23
24func TestExecutorServer_DoSideEffect(t *testing.T) {25ex := NewExecutorI(t)26ex.On("ApplySideEffect", mock.Anything, mock.Anything).Return()27s := &ExecutorServer{28ExecutorI: ex,29}30_, _ = s.DoSideEffect(context.Background(),31&proto.SideEffectInfo{32SeMode: 12,33Configs: &proto.Configs{34Kind: "",35ApiVersion: "",36ParentTag: 0,37Metadata: nil,38TriggerRef: nil,39TemplateRefs: nil,40}})41}
42