cmd

package
v0.0.0-...-c846bbc Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 28, 2024 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func SetupCLI 

func SetupCLI(version, gitCommit string) *cobra.Command

SetupCLI sets up the CLI and returns the root command with the subcommands attached.

Types

type AuthCommand 

type AuthCommand struct{}

func (*AuthCommand) Command 

func (a *AuthCommand) Command() *cobra.Command

type ChAccCmdService 

type ChAccCmdService struct{}

func (*ChAccCmdService) CreateChannelAccounts 

func (s *ChAccCmdService) CreateChannelAccounts(ctx context.Context, chAccService txSubSvc.ChannelAccountsService, count int) error

func (*ChAccCmdService) DeleteChannelAccount 

func (s *ChAccCmdService) DeleteChannelAccount(ctx context.Context, chAccService txSubSvc.ChannelAccountsService, opts txSubSvc.DeleteChannelAccountsOptions) error

func (*ChAccCmdService) EnsureChannelAccountsCount 

func (s *ChAccCmdService) EnsureChannelAccountsCount(ctx context.Context, chAccService txSubSvc.ChannelAccountsService, count int) error

func (*ChAccCmdService) VerifyChannelAccounts 

func (s *ChAccCmdService) VerifyChannelAccounts(ctx context.Context, chAccService txSubSvc.ChannelAccountsService, deleteInvalidAccounts bool) error

func (*ChAccCmdService) ViewChannelAccounts 

func (s *ChAccCmdService) ViewChannelAccounts(ctx context.Context, dbConnectionPool db.DBConnectionPool) error

type ChAccCmdServiceInterface 

type ChAccCmdServiceInterface interface {
	ViewChannelAccounts(ctx context.Context, dbConnectionPool db.DBConnectionPool) error
	CreateChannelAccounts(ctx context.Context, chAccService txSubSvc.ChannelAccountsService, count int) error
	EnsureChannelAccountsCount(ctx context.Context, chAccService txSubSvc.ChannelAccountsService, count int) error
	DeleteChannelAccount(ctx context.Context, chAccService txSubSvc.ChannelAccountsService, opts txSubSvc.DeleteChannelAccountsOptions) error
	VerifyChannelAccounts(ctx context.Context, chAccService txSubSvc.ChannelAccountsService, deleteInvalidAccounts bool) error
}

type ChannelAccountsCommand 

type ChannelAccountsCommand struct {
	// Shared:
	CrashTrackerClient  crashtracker.CrashTrackerClient
	TSSDBConnectionPool db.DBConnectionPool
	DistAccResolver     signing.DistributionAccountResolver
}

func (*ChannelAccountsCommand) Command 

func (c *ChannelAccountsCommand) Command(cmdService ChAccCmdServiceInterface) *cobra.Command

func (*ChannelAccountsCommand) CreateCommand 

func (c *ChannelAccountsCommand) CreateCommand(cmdService ChAccCmdServiceInterface) *cobra.Command

func (*ChannelAccountsCommand) DeleteCommand 

func (c *ChannelAccountsCommand) DeleteCommand(cmdService ChAccCmdServiceInterface) *cobra.Command

func (*ChannelAccountsCommand) EnsureCommand 

func (c *ChannelAccountsCommand) EnsureCommand(cmdService ChAccCmdServiceInterface) *cobra.Command

func (*ChannelAccountsCommand) VerifyCommand 

func (c *ChannelAccountsCommand) VerifyCommand(cmdService ChAccCmdServiceInterface) *cobra.Command

func (*ChannelAccountsCommand) ViewCommand 

func (c *ChannelAccountsCommand) ViewCommand(cmdService ChAccCmdServiceInterface) *cobra.Command

type IntegrationTestsCommand 

type IntegrationTestsCommand struct {
	Service integrationtests.IntegrationTestsInterface
}

func (*IntegrationTestsCommand) Command 

func (c *IntegrationTestsCommand) Command() *cobra.Command

func (*IntegrationTestsCommand) CreateIntegrationTestsDataCommand 

func (c *IntegrationTestsCommand) CreateIntegrationTestsDataCommand(integrationTestsOpts *integrationtests.IntegrationTestsOpts) *cobra.Command

func (*IntegrationTestsCommand) StartIntegrationTestsCommand 

func (c *IntegrationTestsCommand) StartIntegrationTestsCommand(integrationTestsOpts *integrationtests.IntegrationTestsOpts) *cobra.Command

type MessageCommand 

type MessageCommand struct{}

func (*MessageCommand) Command 

func (s *MessageCommand) Command(messengerService MessengerServiceInterface) *cobra.Command

type MessengerService 

type MessengerService struct{}

func (*MessengerService) GetClient 

func (m *MessengerService) GetClient(opts message.MessengerOptions) (message.MessengerClient, error)

func (*MessengerService) SendMessage 

func (m *MessengerService) SendMessage(opts message.MessengerOptions, message message.Message) error

type MessengerServiceInterface 

type MessengerServiceInterface interface {
	GetClient(opts message.MessengerOptions) (message.MessengerClient, error)
	SendMessage(opts message.MessengerOptions, message message.Message) error
}

type ServeCommand 

type ServeCommand struct{}

func (*ServeCommand) Command 

func (c *ServeCommand) Command(serverService ServerServiceInterface, monitorService monitor.MonitorServiceInterface) *cobra.Command

type ServerService 

type ServerService struct{}

func (*ServerService) GetSchedulerJobRegistrars 

func (s *ServerService) GetSchedulerJobRegistrars(
	ctx context.Context,
	serveOpts serve.ServeOptions,
	schedulerOptions scheduler.SchedulerOptions,
	apAPIService anchorplatform.AnchorPlatformAPIServiceInterface,
	tssDBConnectionPool db.DBConnectionPool,
) ([]scheduler.SchedulerJobRegisterOption, error)

func (*ServerService) SetupConsumers 

func (s *ServerService) SetupConsumers(ctx context.Context, o SetupConsumersOptions) error

func (*ServerService) StartAdminServe 

func (s *ServerService) StartAdminServe(opts serveadmin.ServeOptions, httpServer serveadmin.HTTPServerInterface)

func (*ServerService) StartMetricsServe 

func (s *ServerService) StartMetricsServe(opts serve.MetricsServeOptions, httpServer serve.HTTPServerInterface)

func (*ServerService) StartServe 

func (s *ServerService) StartServe(opts serve.ServeOptions, httpServer serve.HTTPServerInterface)

type ServerServiceInterface 

type ServerServiceInterface interface {
	StartServe(opts serve.ServeOptions, httpServer serve.HTTPServerInterface)
	StartMetricsServe(opts serve.MetricsServeOptions, httpServer serve.HTTPServerInterface)
	StartAdminServe(opts serveadmin.ServeOptions, httpServer serveadmin.HTTPServerInterface)
	GetSchedulerJobRegistrars(ctx context.Context,
		serveOpts serve.ServeOptions,
		schedulerOptions scheduler.SchedulerOptions,
		apAPIService anchorplatform.AnchorPlatformAPIServiceInterface,
		tssDBConnectionPool db.DBConnectionPool) ([]scheduler.SchedulerJobRegisterOption, error)
	SetupConsumers(ctx context.Context, o SetupConsumersOptions) error
}

type SetupConsumersOptions 

type SetupConsumersOptions struct {
	EventBrokerOptions  cmdUtils.EventBrokerOptions
	ServeOpts           serve.ServeOptions
	TSSDBConnectionPool db.DBConnectionPool
}

type TxSubmitterCommand 

type TxSubmitterCommand struct{}

func (*TxSubmitterCommand) Command 

func (c *TxSubmitterCommand) Command(submitterService TxSubmitterServiceInterface) *cobra.Command

type TxSubmitterService 

type TxSubmitterService struct{}

func (*TxSubmitterService) StartMetricsServe 

func (s *TxSubmitterService) StartMetricsServe(ctx context.Context, opts serve.MetricsServeOptions, httpServer serve.HTTPServerInterface, crashTrackerClient crashtracker.CrashTrackerClient)

func (*TxSubmitterService) StartSubmitter 

func (t *TxSubmitterService) StartSubmitter(ctx context.Context, opts txSub.SubmitterOptions)

StartSubmitter starts the Transaction Submission Service

type TxSubmitterServiceInterface 

type TxSubmitterServiceInterface interface {
	StartSubmitter(context.Context, txSub.SubmitterOptions)
	StartMetricsServe(ctx context.Context, opts serve.MetricsServeOptions, httpServer serve.HTTPServerInterface, crashTrackerClient crashtracker.CrashTrackerClient)
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.