Documentation ¶
Index ¶
- type Consumer
- func (_m *Consumer) Close()
- func (_m *Consumer) IsClosed() bool
- func (_m *Consumer) Subscribe(queueName string, exchangeName string, exchangeType string, ...) error
- func (_m *Consumer) SubscribeToQueue(queueName string, consumerName string, ...) error
- func (_m *Consumer) SubscribeToServiceQueue(serviceName string, exchangeName string, routingKeys []msgbus.RoutingKey, ...) error
- func (_m *Consumer) SubscribeWithArgs(queueName string, exchangeName string, exchangeType string, ...) error
- type Db
- func (_m *Db) Connect() error
- func (_m *Db) ExecuteInTransaction(dbOperation func(*gorm.DB) *gorm.DB, nestedFuncs ...func() error) error
- func (_m *Db) ExecuteInTransaction2(dbOperation func(*gorm.DB) *gorm.DB, nestedFuncs ...func(*gorm.DB) error) error
- func (_m *Db) GetGormDb() *gorm.DB
- func (_m *Db) Init(model ...interface{}) error
- type DbConfig
- type EventNotificationServiceClient
- type EventNotificationServiceServer
- type Generator
- type GitClient
- func (_m *GitClient) BranchCheckout(branch string) error
- func (_m *GitClient) CloneGitRepo() error
- func (_m *GitClient) CreateTempDir() bool
- func (_m *GitClient) GetFilesPath(key string) ([]string, error)
- func (_m *GitClient) ReadFileJSON(path string) ([]byte, error)
- func (_m *GitClient) ReadFileYML(path string) ([]byte, error)
- func (_m *GitClient) RemoveTempDir() bool
- func (_m *GitClient) SetupDir() bool
- type HealthCheckerInterface
- type HealthClient
- type HealthServer
- type Health_WatchClient
- func (_m *Health_WatchClient) CloseSend() error
- func (_m *Health_WatchClient) Context() context.Context
- func (_m *Health_WatchClient) Header() (metadata.MD, error)
- func (_m *Health_WatchClient) Recv() (*health.HealthCheckResponse, error)
- func (_m *Health_WatchClient) RecvMsg(m interface{}) error
- func (_m *Health_WatchClient) SendMsg(m interface{}) error
- func (_m *Health_WatchClient) Trailer() metadata.MD
- type Health_WatchServer
- func (_m *Health_WatchServer) Context() context.Context
- func (_m *Health_WatchServer) RecvMsg(m interface{}) error
- func (_m *Health_WatchServer) Send(_a0 *health.HealthCheckResponse) error
- func (_m *Health_WatchServer) SendHeader(_a0 metadata.MD) error
- func (_m *Health_WatchServer) SendMsg(m interface{}) error
- func (_m *Health_WatchServer) SetHeader(_a0 metadata.MD) error
- func (_m *Health_WatchServer) SetTrailer(_a0 metadata.MD)
- type IMsgBus
- func (_m *IMsgBus) Close()
- func (_m *IMsgBus) ConnectToBroker(connectionString string)
- func (_m *IMsgBus) Publish(body []byte, queueName string, exchangeName string, ...) error
- func (_m *IMsgBus) PublishOnQueue(body []byte, queueName string, initQueue bool) error
- func (_m *IMsgBus) Subscribe(queueName string, exchangeName string, exchangeType string, ...) error
- func (_m *IMsgBus) SubscribeToQueue(queueName string, consumerName string, ...) error
- type MailerClient
- type MsgBusServiceClient
- type MsgBusShovelProvider
- func (_m *MsgBusShovelProvider) AddShovel(name string, s *msgbus.Shovel) error
- func (_m *MsgBusShovelProvider) CreateShovel(name string, s *msgbus.Shovel) error
- func (_m *MsgBusShovelProvider) GetShovel(name string) (*msgbus.Shovel, error)
- func (_m *MsgBusShovelProvider) RemoveShovel(name string) error
- func (_m *MsgBusShovelProvider) RestartShovel(name string) error
- type MsgClientServiceClient
- func (_m *MsgClientServiceClient) CreateShovel(ctx context.Context, in *msgclient.CreateShovelRequest, ...) (*msgclient.CreateShovelResponse, error)
- func (_m *MsgClientServiceClient) PublishMsg(ctx context.Context, in *msgclient.PublishMsgRequest, opts ...grpc.CallOption) (*msgclient.PublishMsgResponse, error)
- func (_m *MsgClientServiceClient) RegisterService(ctx context.Context, in *msgclient.RegisterServiceReq, opts ...grpc.CallOption) (*msgclient.RegisterServiceResp, error)
- func (_m *MsgClientServiceClient) RemoveShovel(ctx context.Context, in *msgclient.RemoveShovelRequest, ...) (*msgclient.RemoveShovelResponse, error)
- func (_m *MsgClientServiceClient) StartMsgBusHandler(ctx context.Context, in *msgclient.StartMsgBusHandlerReq, ...) (*msgclient.StartMsgBusHandlerResp, error)
- func (_m *MsgClientServiceClient) StopMsgBusHandler(ctx context.Context, in *msgclient.StopMsgBusHandlerReq, ...) (*msgclient.StopMsgBusHandlerResp, error)
- func (_m *MsgClientServiceClient) UnregisterService(ctx context.Context, in *msgclient.UnregisterServiceReq, ...) (*msgclient.UnregisterServiceResp, error)
- type MsgClientServiceServer
- func (_m *MsgClientServiceServer) CreateShovel(_a0 context.Context, _a1 *msgclient.CreateShovelRequest) (*msgclient.CreateShovelResponse, error)
- func (_m *MsgClientServiceServer) PublishMsg(_a0 context.Context, _a1 *msgclient.PublishMsgRequest) (*msgclient.PublishMsgResponse, error)
- func (_m *MsgClientServiceServer) RegisterService(_a0 context.Context, _a1 *msgclient.RegisterServiceReq) (*msgclient.RegisterServiceResp, error)
- func (_m *MsgClientServiceServer) RemoveShovel(_a0 context.Context, _a1 *msgclient.RemoveShovelRequest) (*msgclient.RemoveShovelResponse, error)
- func (_m *MsgClientServiceServer) StartMsgBusHandler(_a0 context.Context, _a1 *msgclient.StartMsgBusHandlerReq) (*msgclient.StartMsgBusHandlerResp, error)
- func (_m *MsgClientServiceServer) StopMsgBusHandler(_a0 context.Context, _a1 *msgclient.StopMsgBusHandlerReq) (*msgclient.StopMsgBusHandlerResp, error)
- func (_m *MsgClientServiceServer) UnregisterService(_a0 context.Context, _a1 *msgclient.UnregisterServiceReq) (*msgclient.UnregisterServiceResp, error)
- type NetworkClient
- type NodeClient
- func (_m *NodeClient) Add(_a0 registry.AddNodeRequest) (*registry.NodeInfo, error)
- func (_m *NodeClient) AddToSite(_a0 string, _a1 registry.AddToSiteRequest) error
- func (_m *NodeClient) Attach(_a0 string, _a1 registry.AttachNodesRequest) error
- func (_m *NodeClient) Delete(_a0 string) error
- func (_m *NodeClient) Detach(_a0 string) error
- func (_m *NodeClient) Get(_a0 string) (*registry.NodeInfo, error)
- func (_m *NodeClient) RemoveFromSite(_a0 string) error
- type OperatorClient
- func (_m *OperatorClient) ActivateSim(iccid string) error
- func (_m *OperatorClient) BindSim(iccid string) (*operator.OperatorSimInfo, error)
- func (_m *OperatorClient) DeactivateSim(iccid string) error
- func (_m *OperatorClient) GetSimInfo(iccid string) (*operator.OperatorSimInfo, error)
- func (_m *OperatorClient) GetUsages(iccid string, cdrType string, from string, to string, region string) (map[string]interface{}, map[string]interface{}, error)
- func (_m *OperatorClient) TerminateSim(iccid string) error
- type Option
- type OrgClient
- type PackageClient
- type Publisher
- func (_m *Publisher) Close()
- func (_m *Publisher) DeclareQueue(queueName string, durable bool) (*amqp.Queue, error)
- func (_m *Publisher) IsClosed() bool
- func (_m *Publisher) Publish(body []byte, queueName string, exchangeName string, ...) error
- func (_m *Publisher) PublishOnExchange(exchange string, routingKey string, body interface{}) error
- func (_m *Publisher) PublishOnQueue(msg []byte, queueName string, initQueue bool) error
- type QPub
- type SimClient
- type SubscriberClient
- type UnsafeEventNotificationServiceServer
- type UnsafeHealthServer
- type UnsafeMsgClientServiceServer
- type UserClient
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
Consumer is an autogenerated mock type for the Consumer type
func NewConsumer ¶
NewConsumer creates a new instance of Consumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*Consumer) Close ¶
func (_m *Consumer) Close()
Close provides a mock function with given fields:
func (*Consumer) Subscribe ¶
func (_m *Consumer) Subscribe(queueName string, exchangeName string, exchangeType string, routingKeys []msgbus.RoutingKey, consumerName string, handlerFunc func(amqp.Delivery, chan<- bool)) error
Subscribe provides a mock function with given fields: queueName, exchangeName, exchangeType, routingKeys, consumerName, handlerFunc
func (*Consumer) SubscribeToQueue ¶
func (_m *Consumer) SubscribeToQueue(queueName string, consumerName string, handlerFunc func(amqp.Delivery, chan<- bool)) error
SubscribeToQueue provides a mock function with given fields: queueName, consumerName, handlerFunc
func (*Consumer) SubscribeToServiceQueue ¶
func (_m *Consumer) SubscribeToServiceQueue(serviceName string, exchangeName string, routingKeys []msgbus.RoutingKey, consumerId string, handlerFunc func(amqp.Delivery, chan<- bool)) error
SubscribeToServiceQueue provides a mock function with given fields: serviceName, exchangeName, routingKeys, consumerId, handlerFunc
func (*Consumer) SubscribeWithArgs ¶
func (_m *Consumer) SubscribeWithArgs(queueName string, exchangeName string, exchangeType string, routingKeys []msgbus.RoutingKey, consumerName string, queueArgs map[string]interface{}, handlerFunc func(amqp.Delivery, chan<- bool)) error
SubscribeWithArgs provides a mock function with given fields: queueName, exchangeName, exchangeType, routingKeys, consumerName, queueArgs, handlerFunc
type Db ¶
Db is an autogenerated mock type for the Db type
func NewDb ¶
NewDb creates a new instance of Db. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*Db) ExecuteInTransaction ¶
func (_m *Db) ExecuteInTransaction(dbOperation func(*gorm.DB) *gorm.DB, nestedFuncs ...func() error) error
ExecuteInTransaction provides a mock function with given fields: dbOperation, nestedFuncs
func (*Db) ExecuteInTransaction2 ¶
func (_m *Db) ExecuteInTransaction2(dbOperation func(*gorm.DB) *gorm.DB, nestedFuncs ...func(*gorm.DB) error) error
ExecuteInTransaction2 provides a mock function with given fields: dbOperation, nestedFuncs
type DbConfig ¶
DbConfig is an autogenerated mock type for the DbConfig type
func NewDbConfig ¶
NewDbConfig creates a new instance of DbConfig. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*DbConfig) ChangeDbName ¶
ChangeDbName provides a mock function with given fields: name
func (*DbConfig) GetConnString ¶
GetConnString provides a mock function with given fields:
type EventNotificationServiceClient ¶
EventNotificationServiceClient is an autogenerated mock type for the EventNotificationServiceClient type
func NewEventNotificationServiceClient ¶
func NewEventNotificationServiceClient(t interface { mock.TestingT Cleanup(func()) }) *EventNotificationServiceClient
NewEventNotificationServiceClient creates a new instance of EventNotificationServiceClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*EventNotificationServiceClient) EventNotification ¶
func (_m *EventNotificationServiceClient) EventNotification(ctx context.Context, in *events.Event, opts ...grpc.CallOption) (*events.EventResponse, error)
EventNotification provides a mock function with given fields: ctx, in, opts
type EventNotificationServiceServer ¶
EventNotificationServiceServer is an autogenerated mock type for the EventNotificationServiceServer type
func NewEventNotificationServiceServer ¶
func NewEventNotificationServiceServer(t interface { mock.TestingT Cleanup(func()) }) *EventNotificationServiceServer
NewEventNotificationServiceServer creates a new instance of EventNotificationServiceServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*EventNotificationServiceServer) EventNotification ¶
func (_m *EventNotificationServiceServer) EventNotification(_a0 context.Context, _a1 *events.Event) (*events.EventResponse, error)
EventNotification provides a mock function with given fields: _a0, _a1
type Generator ¶
Generator is an autogenerated mock type for the Generator type
func NewGenerator ¶
NewGenerator creates a new instance of Generator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
type GitClient ¶
GitClient is an autogenerated mock type for the GitClient type
func NewGitClient ¶
NewGitClient creates a new instance of GitClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*GitClient) BranchCheckout ¶
BranchCheckout provides a mock function with given fields: branch
func (*GitClient) CloneGitRepo ¶
CloneGitRepo provides a mock function with given fields:
func (*GitClient) CreateTempDir ¶
CreateTempDir provides a mock function with given fields:
func (*GitClient) GetFilesPath ¶
GetFilesPath provides a mock function with given fields: key
func (*GitClient) ReadFileJSON ¶
ReadFileJSON provides a mock function with given fields: path
func (*GitClient) ReadFileYML ¶
ReadFileYML provides a mock function with given fields: path
func (*GitClient) RemoveTempDir ¶
RemoveTempDir provides a mock function with given fields:
type HealthCheckerInterface ¶
HealthCheckerInterface is an autogenerated mock type for the HealthCheckerInterface type
func NewHealthCheckerInterface ¶
func NewHealthCheckerInterface(t interface { mock.TestingT Cleanup(func()) }) *HealthCheckerInterface
NewHealthCheckerInterface creates a new instance of HealthCheckerInterface. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*HealthCheckerInterface) Check ¶
func (_m *HealthCheckerInterface) Check(ctx context.Context, request *health.HealthCheckRequest) (*health.HealthCheckResponse, error)
Check provides a mock function with given fields: ctx, request
func (*HealthCheckerInterface) Watch ¶
func (_m *HealthCheckerInterface) Watch(request *health.HealthCheckRequest, server health.Health_WatchServer) error
Watch provides a mock function with given fields: request, server
type HealthClient ¶
HealthClient is an autogenerated mock type for the HealthClient type
func NewHealthClient ¶
func NewHealthClient(t interface { mock.TestingT Cleanup(func()) }) *HealthClient
NewHealthClient creates a new instance of HealthClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*HealthClient) Check ¶
func (_m *HealthClient) Check(ctx context.Context, in *health.HealthCheckRequest, opts ...grpc.CallOption) (*health.HealthCheckResponse, error)
Check provides a mock function with given fields: ctx, in, opts
func (*HealthClient) Watch ¶
func (_m *HealthClient) Watch(ctx context.Context, in *health.HealthCheckRequest, opts ...grpc.CallOption) (health.Health_WatchClient, error)
Watch provides a mock function with given fields: ctx, in, opts
type HealthServer ¶
HealthServer is an autogenerated mock type for the HealthServer type
func NewHealthServer ¶
func NewHealthServer(t interface { mock.TestingT Cleanup(func()) }) *HealthServer
NewHealthServer creates a new instance of HealthServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*HealthServer) Check ¶
func (_m *HealthServer) Check(_a0 context.Context, _a1 *health.HealthCheckRequest) (*health.HealthCheckResponse, error)
Check provides a mock function with given fields: _a0, _a1
func (*HealthServer) Watch ¶
func (_m *HealthServer) Watch(_a0 *health.HealthCheckRequest, _a1 health.Health_WatchServer) error
Watch provides a mock function with given fields: _a0, _a1
type Health_WatchClient ¶
Health_WatchClient is an autogenerated mock type for the Health_WatchClient type
func NewHealth_WatchClient ¶
func NewHealth_WatchClient(t interface { mock.TestingT Cleanup(func()) }) *Health_WatchClient
NewHealth_WatchClient creates a new instance of Health_WatchClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*Health_WatchClient) CloseSend ¶
func (_m *Health_WatchClient) CloseSend() error
CloseSend provides a mock function with given fields:
func (*Health_WatchClient) Context ¶
func (_m *Health_WatchClient) Context() context.Context
Context provides a mock function with given fields:
func (*Health_WatchClient) Header ¶
func (_m *Health_WatchClient) Header() (metadata.MD, error)
Header provides a mock function with given fields:
func (*Health_WatchClient) Recv ¶
func (_m *Health_WatchClient) Recv() (*health.HealthCheckResponse, error)
Recv provides a mock function with given fields:
func (*Health_WatchClient) RecvMsg ¶
func (_m *Health_WatchClient) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*Health_WatchClient) SendMsg ¶
func (_m *Health_WatchClient) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*Health_WatchClient) Trailer ¶
func (_m *Health_WatchClient) Trailer() metadata.MD
Trailer provides a mock function with given fields:
type Health_WatchServer ¶
Health_WatchServer is an autogenerated mock type for the Health_WatchServer type
func NewHealth_WatchServer ¶
func NewHealth_WatchServer(t interface { mock.TestingT Cleanup(func()) }) *Health_WatchServer
NewHealth_WatchServer creates a new instance of Health_WatchServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*Health_WatchServer) Context ¶
func (_m *Health_WatchServer) Context() context.Context
Context provides a mock function with given fields:
func (*Health_WatchServer) RecvMsg ¶
func (_m *Health_WatchServer) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*Health_WatchServer) Send ¶
func (_m *Health_WatchServer) Send(_a0 *health.HealthCheckResponse) error
Send provides a mock function with given fields: _a0
func (*Health_WatchServer) SendHeader ¶
func (_m *Health_WatchServer) SendHeader(_a0 metadata.MD) error
SendHeader provides a mock function with given fields: _a0
func (*Health_WatchServer) SendMsg ¶
func (_m *Health_WatchServer) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*Health_WatchServer) SetHeader ¶
func (_m *Health_WatchServer) SetHeader(_a0 metadata.MD) error
SetHeader provides a mock function with given fields: _a0
func (*Health_WatchServer) SetTrailer ¶
func (_m *Health_WatchServer) SetTrailer(_a0 metadata.MD)
SetTrailer provides a mock function with given fields: _a0
type IMsgBus ¶
IMsgBus is an autogenerated mock type for the IMsgBus type
func NewIMsgBus ¶
NewIMsgBus creates a new instance of IMsgBus. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*IMsgBus) Close ¶
func (_m *IMsgBus) Close()
Close provides a mock function with given fields:
func (*IMsgBus) ConnectToBroker ¶
ConnectToBroker provides a mock function with given fields: connectionString
func (*IMsgBus) Publish ¶
func (_m *IMsgBus) Publish(body []byte, queueName string, exchangeName string, routingKey msgbus.RoutingKey, exchangeType string) error
Publish provides a mock function with given fields: body, queueName, exchangeName, routingKey, exchangeType
func (*IMsgBus) PublishOnQueue ¶
PublishOnQueue provides a mock function with given fields: body, queueName, initQueue
func (*IMsgBus) Subscribe ¶
func (_m *IMsgBus) Subscribe(queueName string, exchangeName string, exchangeType string, routingKeys []msgbus.RoutingKey, consumerName string, handlerFunc func(amqp.Delivery, chan<- bool)) error
Subscribe provides a mock function with given fields: queueName, exchangeName, exchangeType, routingKeys, consumerName, handlerFunc
type MailerClient ¶
MailerClient is an autogenerated mock type for the MailerClient type
func NewMailerClient ¶
func NewMailerClient(t interface { mock.TestingT Cleanup(func()) }) *MailerClient
NewMailerClient creates a new instance of MailerClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MailerClient) SendEmail ¶
func (_m *MailerClient) SendEmail(body notification.SendEmailReq) error
SendEmail provides a mock function with given fields: body
type MsgBusServiceClient ¶
MsgBusServiceClient is an autogenerated mock type for the MsgBusServiceClient type
func NewMsgBusServiceClient ¶
func NewMsgBusServiceClient(t interface { mock.TestingT Cleanup(func()) }) *MsgBusServiceClient
NewMsgBusServiceClient creates a new instance of MsgBusServiceClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MsgBusServiceClient) PublishRequest ¶
func (_m *MsgBusServiceClient) PublishRequest(route string, msg protoreflect.ProtoMessage) error
PublishRequest provides a mock function with given fields: route, msg
func (*MsgBusServiceClient) Register ¶
func (_m *MsgBusServiceClient) Register() error
Register provides a mock function with given fields:
func (*MsgBusServiceClient) Start ¶
func (_m *MsgBusServiceClient) Start() error
Start provides a mock function with given fields:
func (*MsgBusServiceClient) Stop ¶
func (_m *MsgBusServiceClient) Stop() error
Stop provides a mock function with given fields:
type MsgBusShovelProvider ¶
MsgBusShovelProvider is an autogenerated mock type for the MsgBusShovelProvider type
func NewMsgBusShovelProvider ¶
func NewMsgBusShovelProvider(t interface { mock.TestingT Cleanup(func()) }) *MsgBusShovelProvider
NewMsgBusShovelProvider creates a new instance of MsgBusShovelProvider. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MsgBusShovelProvider) AddShovel ¶
func (_m *MsgBusShovelProvider) AddShovel(name string, s *msgbus.Shovel) error
AddShovel provides a mock function with given fields: name, s
func (*MsgBusShovelProvider) CreateShovel ¶
func (_m *MsgBusShovelProvider) CreateShovel(name string, s *msgbus.Shovel) error
CreateShovel provides a mock function with given fields: name, s
func (*MsgBusShovelProvider) GetShovel ¶
func (_m *MsgBusShovelProvider) GetShovel(name string) (*msgbus.Shovel, error)
GetShovel provides a mock function with given fields: name
func (*MsgBusShovelProvider) RemoveShovel ¶
func (_m *MsgBusShovelProvider) RemoveShovel(name string) error
RemoveShovel provides a mock function with given fields: name
func (*MsgBusShovelProvider) RestartShovel ¶
func (_m *MsgBusShovelProvider) RestartShovel(name string) error
RestartShovel provides a mock function with given fields: name
type MsgClientServiceClient ¶
MsgClientServiceClient is an autogenerated mock type for the MsgClientServiceClient type
func NewMsgClientServiceClient ¶
func NewMsgClientServiceClient(t interface { mock.TestingT Cleanup(func()) }) *MsgClientServiceClient
NewMsgClientServiceClient creates a new instance of MsgClientServiceClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MsgClientServiceClient) CreateShovel ¶
func (_m *MsgClientServiceClient) CreateShovel(ctx context.Context, in *msgclient.CreateShovelRequest, opts ...grpc.CallOption) (*msgclient.CreateShovelResponse, error)
CreateShovel provides a mock function with given fields: ctx, in, opts
func (*MsgClientServiceClient) PublishMsg ¶
func (_m *MsgClientServiceClient) PublishMsg(ctx context.Context, in *msgclient.PublishMsgRequest, opts ...grpc.CallOption) (*msgclient.PublishMsgResponse, error)
PublishMsg provides a mock function with given fields: ctx, in, opts
func (*MsgClientServiceClient) RegisterService ¶
func (_m *MsgClientServiceClient) RegisterService(ctx context.Context, in *msgclient.RegisterServiceReq, opts ...grpc.CallOption) (*msgclient.RegisterServiceResp, error)
RegisterService provides a mock function with given fields: ctx, in, opts
func (*MsgClientServiceClient) RemoveShovel ¶
func (_m *MsgClientServiceClient) RemoveShovel(ctx context.Context, in *msgclient.RemoveShovelRequest, opts ...grpc.CallOption) (*msgclient.RemoveShovelResponse, error)
RemoveShovel provides a mock function with given fields: ctx, in, opts
func (*MsgClientServiceClient) StartMsgBusHandler ¶
func (_m *MsgClientServiceClient) StartMsgBusHandler(ctx context.Context, in *msgclient.StartMsgBusHandlerReq, opts ...grpc.CallOption) (*msgclient.StartMsgBusHandlerResp, error)
StartMsgBusHandler provides a mock function with given fields: ctx, in, opts
func (*MsgClientServiceClient) StopMsgBusHandler ¶
func (_m *MsgClientServiceClient) StopMsgBusHandler(ctx context.Context, in *msgclient.StopMsgBusHandlerReq, opts ...grpc.CallOption) (*msgclient.StopMsgBusHandlerResp, error)
StopMsgBusHandler provides a mock function with given fields: ctx, in, opts
func (*MsgClientServiceClient) UnregisterService ¶
func (_m *MsgClientServiceClient) UnregisterService(ctx context.Context, in *msgclient.UnregisterServiceReq, opts ...grpc.CallOption) (*msgclient.UnregisterServiceResp, error)
UnregisterService provides a mock function with given fields: ctx, in, opts
type MsgClientServiceServer ¶
MsgClientServiceServer is an autogenerated mock type for the MsgClientServiceServer type
func NewMsgClientServiceServer ¶
func NewMsgClientServiceServer(t interface { mock.TestingT Cleanup(func()) }) *MsgClientServiceServer
NewMsgClientServiceServer creates a new instance of MsgClientServiceServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MsgClientServiceServer) CreateShovel ¶
func (_m *MsgClientServiceServer) CreateShovel(_a0 context.Context, _a1 *msgclient.CreateShovelRequest) (*msgclient.CreateShovelResponse, error)
CreateShovel provides a mock function with given fields: _a0, _a1
func (*MsgClientServiceServer) PublishMsg ¶
func (_m *MsgClientServiceServer) PublishMsg(_a0 context.Context, _a1 *msgclient.PublishMsgRequest) (*msgclient.PublishMsgResponse, error)
PublishMsg provides a mock function with given fields: _a0, _a1
func (*MsgClientServiceServer) RegisterService ¶
func (_m *MsgClientServiceServer) RegisterService(_a0 context.Context, _a1 *msgclient.RegisterServiceReq) (*msgclient.RegisterServiceResp, error)
RegisterService provides a mock function with given fields: _a0, _a1
func (*MsgClientServiceServer) RemoveShovel ¶
func (_m *MsgClientServiceServer) RemoveShovel(_a0 context.Context, _a1 *msgclient.RemoveShovelRequest) (*msgclient.RemoveShovelResponse, error)
RemoveShovel provides a mock function with given fields: _a0, _a1
func (*MsgClientServiceServer) StartMsgBusHandler ¶
func (_m *MsgClientServiceServer) StartMsgBusHandler(_a0 context.Context, _a1 *msgclient.StartMsgBusHandlerReq) (*msgclient.StartMsgBusHandlerResp, error)
StartMsgBusHandler provides a mock function with given fields: _a0, _a1
func (*MsgClientServiceServer) StopMsgBusHandler ¶
func (_m *MsgClientServiceServer) StopMsgBusHandler(_a0 context.Context, _a1 *msgclient.StopMsgBusHandlerReq) (*msgclient.StopMsgBusHandlerResp, error)
StopMsgBusHandler provides a mock function with given fields: _a0, _a1
func (*MsgClientServiceServer) UnregisterService ¶
func (_m *MsgClientServiceServer) UnregisterService(_a0 context.Context, _a1 *msgclient.UnregisterServiceReq) (*msgclient.UnregisterServiceResp, error)
UnregisterService provides a mock function with given fields: _a0, _a1
type NetworkClient ¶
NetworkClient is an autogenerated mock type for the NetworkClient type
func NewNetworkClient ¶
func NewNetworkClient(t interface { mock.TestingT Cleanup(func()) }) *NetworkClient
NewNetworkClient creates a new instance of NetworkClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*NetworkClient) Add ¶
func (_m *NetworkClient) Add(req registry.AddNetworkRequest) (*registry.NetworkInfo, error)
Add provides a mock function with given fields: req
func (*NetworkClient) Get ¶
func (_m *NetworkClient) Get(Id string) (*registry.NetworkInfo, error)
Get provides a mock function with given fields: Id
type NodeClient ¶
NodeClient is an autogenerated mock type for the NodeClient type
func NewNodeClient ¶
func NewNodeClient(t interface { mock.TestingT Cleanup(func()) }) *NodeClient
NewNodeClient creates a new instance of NodeClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*NodeClient) Add ¶
func (_m *NodeClient) Add(_a0 registry.AddNodeRequest) (*registry.NodeInfo, error)
Add provides a mock function with given fields: _a0
func (*NodeClient) AddToSite ¶
func (_m *NodeClient) AddToSite(_a0 string, _a1 registry.AddToSiteRequest) error
AddToSite provides a mock function with given fields: _a0, _a1
func (*NodeClient) Attach ¶
func (_m *NodeClient) Attach(_a0 string, _a1 registry.AttachNodesRequest) error
Attach provides a mock function with given fields: _a0, _a1
func (*NodeClient) Delete ¶
func (_m *NodeClient) Delete(_a0 string) error
Delete provides a mock function with given fields: _a0
func (*NodeClient) Detach ¶
func (_m *NodeClient) Detach(_a0 string) error
Detach provides a mock function with given fields: _a0
func (*NodeClient) Get ¶
func (_m *NodeClient) Get(_a0 string) (*registry.NodeInfo, error)
Get provides a mock function with given fields: _a0
func (*NodeClient) RemoveFromSite ¶
func (_m *NodeClient) RemoveFromSite(_a0 string) error
RemoveFromSite provides a mock function with given fields: _a0
type OperatorClient ¶
OperatorClient is an autogenerated mock type for the OperatorClient type
func NewOperatorClient ¶
func NewOperatorClient(t interface { mock.TestingT Cleanup(func()) }) *OperatorClient
NewOperatorClient creates a new instance of OperatorClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*OperatorClient) ActivateSim ¶
func (_m *OperatorClient) ActivateSim(iccid string) error
ActivateSim provides a mock function with given fields: iccid
func (*OperatorClient) BindSim ¶
func (_m *OperatorClient) BindSim(iccid string) (*operator.OperatorSimInfo, error)
BindSim provides a mock function with given fields: iccid
func (*OperatorClient) DeactivateSim ¶
func (_m *OperatorClient) DeactivateSim(iccid string) error
DeactivateSim provides a mock function with given fields: iccid
func (*OperatorClient) GetSimInfo ¶
func (_m *OperatorClient) GetSimInfo(iccid string) (*operator.OperatorSimInfo, error)
GetSimInfo provides a mock function with given fields: iccid
func (*OperatorClient) GetUsages ¶
func (_m *OperatorClient) GetUsages(iccid string, cdrType string, from string, to string, region string) (map[string]interface{}, map[string]interface{}, error)
GetUsages provides a mock function with given fields: iccid, cdrType, from, to, region
func (*OperatorClient) TerminateSim ¶
func (_m *OperatorClient) TerminateSim(iccid string) error
TerminateSim provides a mock function with given fields: iccid
type Option ¶
Option is an autogenerated mock type for the Option type
type OrgClient ¶
OrgClient is an autogenerated mock type for the OrgClient type
func NewOrgClient ¶
NewOrgClient creates a new instance of OrgClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
type PackageClient ¶
PackageClient is an autogenerated mock type for the PackageClient type
func NewPackageClient ¶
func NewPackageClient(t interface { mock.TestingT Cleanup(func()) }) *PackageClient
NewPackageClient creates a new instance of PackageClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*PackageClient) Add ¶
func (_m *PackageClient) Add(req dataplan.AddPackageRequest) (*dataplan.PackageInfo, error)
Add provides a mock function with given fields: req
func (*PackageClient) Get ¶
func (_m *PackageClient) Get(Id string) (*dataplan.PackageInfo, error)
Get provides a mock function with given fields: Id
type Publisher ¶
Publisher is an autogenerated mock type for the Publisher type
func NewPublisher ¶
NewPublisher creates a new instance of Publisher. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*Publisher) Close ¶
func (_m *Publisher) Close()
Close provides a mock function with given fields:
func (*Publisher) DeclareQueue ¶
DeclareQueue provides a mock function with given fields: queueName, durable
func (*Publisher) Publish ¶
func (_m *Publisher) Publish(body []byte, queueName string, exchangeName string, routingKey msgbus.RoutingKey, exchangeType string) error
Publish provides a mock function with given fields: body, queueName, exchangeName, routingKey, exchangeType
func (*Publisher) PublishOnExchange ¶
PublishOnExchange provides a mock function with given fields: exchange, routingKey, body
type QPub ¶
QPub is an autogenerated mock type for the QPub type
func NewQPub ¶
NewQPub creates a new instance of QPub. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*QPub) PublishProto ¶
func (_m *QPub) PublishProto(payload protoreflect.ProtoMessage, routingKey string) error
PublishProto provides a mock function with given fields: payload, routingKey
func (*QPub) PublishToQueue ¶
PublishToQueue provides a mock function with given fields: queueName, payload
type SimClient ¶
SimClient is an autogenerated mock type for the SimClient type
func NewSimClient ¶
NewSimClient creates a new instance of SimClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*SimClient) Add ¶
func (_m *SimClient) Add(req subscriber.AddSimRequest) (*subscriber.SimInfo, error)
Add provides a mock function with given fields: req
type SubscriberClient ¶
SubscriberClient is an autogenerated mock type for the SubscriberClient type
func NewSubscriberClient ¶
func NewSubscriberClient(t interface { mock.TestingT Cleanup(func()) }) *SubscriberClient
NewSubscriberClient creates a new instance of SubscriberClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*SubscriberClient) Add ¶
func (_m *SubscriberClient) Add(req subscriber.AddSubscriberRequest) (*subscriber.SubscriberInfo, error)
Add provides a mock function with given fields: req
func (*SubscriberClient) Get ¶
func (_m *SubscriberClient) Get(Id string) (*subscriber.SubscriberInfo, error)
Get provides a mock function with given fields: Id
type UnsafeEventNotificationServiceServer ¶
UnsafeEventNotificationServiceServer is an autogenerated mock type for the UnsafeEventNotificationServiceServer type
func NewUnsafeEventNotificationServiceServer ¶
func NewUnsafeEventNotificationServiceServer(t interface { mock.TestingT Cleanup(func()) }) *UnsafeEventNotificationServiceServer
NewUnsafeEventNotificationServiceServer creates a new instance of UnsafeEventNotificationServiceServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
type UnsafeHealthServer ¶
UnsafeHealthServer is an autogenerated mock type for the UnsafeHealthServer type
func NewUnsafeHealthServer ¶
func NewUnsafeHealthServer(t interface { mock.TestingT Cleanup(func()) }) *UnsafeHealthServer
NewUnsafeHealthServer creates a new instance of UnsafeHealthServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
type UnsafeMsgClientServiceServer ¶
UnsafeMsgClientServiceServer is an autogenerated mock type for the UnsafeMsgClientServiceServer type
func NewUnsafeMsgClientServiceServer ¶
func NewUnsafeMsgClientServiceServer(t interface { mock.TestingT Cleanup(func()) }) *UnsafeMsgClientServiceServer
NewUnsafeMsgClientServiceServer creates a new instance of UnsafeMsgClientServiceServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
type UserClient ¶
UserClient is an autogenerated mock type for the UserClient type
func NewUserClient ¶
func NewUserClient(t interface { mock.TestingT Cleanup(func()) }) *UserClient
NewUserClient creates a new instance of UserClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*UserClient) GetByEmail ¶
func (_m *UserClient) GetByEmail(email string) (*nucleus.UserInfo, error)
GetByEmail provides a mock function with given fields: email
Source Files ¶
- Consumer.go
- Db.go
- DbConfig.go
- EventNotificationServiceClient.go
- EventNotificationServiceServer.go
- Generator.go
- GitClient.go
- HealthCheckerInterface.go
- HealthClient.go
- HealthServer.go
- Health_WatchClient.go
- Health_WatchServer.go
- IMsgBus.go
- MailerClient.go
- MsgBusServiceClient.go
- MsgBusShovelProvider.go
- MsgClientServiceClient.go
- MsgClientServiceServer.go
- NetworkClient.go
- NodeClient.go
- OperatorClient.go
- Option.go
- OrgClient.go
- PackageClient.go
- Publisher.go
- QPub.go
- SimClient.go
- SubscriberClient.go
- UnsafeEventNotificationServiceServer.go
- UnsafeHealthServer.go
- UnsafeMsgClientServiceServer.go
- UserClient.go