cmd

Documentation

Index

• func SetupCLI(version, gitCommit string) *cobra.Command
• type AuthCommand
  • func (a *AuthCommand) Command() *cobra.Command
• type ChannelAccountsCommand
  • func (c *ChannelAccountsCommand) Command() *cobra.Command
  • func (c *ChannelAccountsCommand) CreateCommand(toolOpts *txSubSvc.ChannelAccountServiceOptions) *cobra.Command
  • func (c *ChannelAccountsCommand) DeleteCommand(toolOpts *txSubSvc.ChannelAccountServiceOptions) *cobra.Command
  • func (c *ChannelAccountsCommand) EnsureCommand(toolOpts *txSubSvc.ChannelAccountServiceOptions) *cobra.Command
  • func (c *ChannelAccountsCommand) VerifyCommand(toolOpts *txSubSvc.ChannelAccountServiceOptions) *cobra.Command
  • func (c *ChannelAccountsCommand) ViewCommand() *cobra.Command
• type DatabaseCommand
  • func (c *DatabaseCommand) Command() *cobra.Command
• type IntegrationTestsCommand
  • func (c *IntegrationTestsCommand) Command() *cobra.Command
  • func (c *IntegrationTestsCommand) CreateIntegrationTestsDataCommand(integrationTestsOpts *integrationtests.IntegrationTestsOpts) *cobra.Command
  • func (c *IntegrationTestsCommand) StartIntegrationTestsCommand(integrationTestsOpts *integrationtests.IntegrationTestsOpts) *cobra.Command
• type MessageCommand
  • func (s *MessageCommand) Command(messengerService MessengerServiceInterface) *cobra.Command
• type MessengerService
  • func (m *MessengerService) GetClient(opts message.MessengerOptions) (message.MessengerClient, error)
  • func (m *MessengerService) SendMessage(opts message.MessengerOptions, message message.Message) error
• type MessengerServiceInterface
• type ServeCommand
  • func (c *ServeCommand) Command(serverService ServerServiceInterface, ...) *cobra.Command
• type ServerService
  • func (s *ServerService) GetSchedulerJobRegistrars(ctx context.Context, serveOpts serve.ServeOptions, ...) ([]scheduler.SchedulerJobRegisterOption, error)
  • func (s *ServerService) StartMetricsServe(opts serve.MetricsServeOptions, httpServer serve.HTTPServerInterface)
  • func (s *ServerService) StartServe(opts serve.ServeOptions, httpServer serve.HTTPServerInterface)
• type ServerServiceInterface
• type TxSubmitterCommand
  • func (c *TxSubmitterCommand) Command(submitterService TxSubmitterServiceInterface) *cobra.Command
• type TxSubmitterService
  • func (s *TxSubmitterService) StartMetricsServe(ctx context.Context, opts serve.MetricsServeOptions, ...)
  • func (t *TxSubmitterService) StartSubmitter(ctx context.Context, opts txSub.SubmitterOptions)
• type TxSubmitterServiceInterface

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 ChannelAccountsCommand

type ChannelAccountsCommand struct {
	Service            txSubSvc.ChannelAccountsServiceInterface
	CrashTrackerClient crashtracker.CrashTrackerClient
}

func (*ChannelAccountsCommand) Command

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

func (*ChannelAccountsCommand) CreateCommand

func (c *ChannelAccountsCommand) CreateCommand(toolOpts *txSubSvc.ChannelAccountServiceOptions) *cobra.Command

func (*ChannelAccountsCommand) DeleteCommand

func (c *ChannelAccountsCommand) DeleteCommand(toolOpts *txSubSvc.ChannelAccountServiceOptions) *cobra.Command

func (*ChannelAccountsCommand) EnsureCommand

func (c *ChannelAccountsCommand) EnsureCommand(toolOpts *txSubSvc.ChannelAccountServiceOptions) *cobra.Command

func (*ChannelAccountsCommand) VerifyCommand

func (c *ChannelAccountsCommand) VerifyCommand(toolOpts *txSubSvc.ChannelAccountServiceOptions) *cobra.Command

func (*ChannelAccountsCommand) ViewCommand

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

type DatabaseCommand

type DatabaseCommand struct{}

func (*DatabaseCommand) Command

func (c *DatabaseCommand) Command() *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) ([]scheduler.SchedulerJobRegisterOption, error)

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)
	GetSchedulerJobRegistrars(ctx context.Context, serveOpts serve.ServeOptions, schedulerOptions scheduler.SchedulerOptions, apAPIService anchorplatform.AnchorPlatformAPIServiceInterface) ([]scheduler.SchedulerJobRegisterOption, error)
}

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)
}