app

Documentation

Index

• Variables
• func InitConfigFlag(cmd *cobra.Command)
• type App
  • func GetApp() *App
  • func (a *App) AddCommand(commands ...*cobra.Command)
  • func (a *App) AddGRPCService(service iface2.IGRPCService)
  • func (a *App) AddGraphQLMutation(name string, handler graphql.GQLHandler)
  • func (a *App) AddGraphQLQuery(name string, handler graphql.GQLHandler)
  • func (a *App) AddGraphQLSubscription(name string, handler graphql.GQLHandler)
  • func (a *App) AddHTTPView(pattern string, view iface2.IHTTPView)
  • func (a *App) AddTransactionProcessor(tp iface.ITransactionProcessor)
  • func (a *App) DisableDefaultCommands()
  • func (a *App) DisableDefaultGRPCServices()
  • func (a *App) DisableDefaultTransactionProcessors()
  • func (a *App) DisableDefaultViews()
  • func (a *App) EnableDefaultCommands()
  • func (a *App) EnableDefaultGRPCServices()
  • func (a *App) EnableDefaultTransactionProcessors()
  • func (a *App) EnableDefaultViews()
  • func (a *App) Execute() error
  • func (a *App) GetFlamed() *flamed.Flamed
  • func (a *App) GetFlamedContext() *context.FlamedContext
  • func (a *App) GetPasswordHashAlgorithmFactory() iface.IPasswordHashAlgorithmFactory
  • func (a *App) GetProposalReceiver() func(*pb.Proposal, pb.Status)
  • func (a *App) GetTPMap() map[string]iface.ITransactionProcessor
  • func (a *App) GetTransactionProcessorMap() map[string]iface.ITransactionProcessor
  • func (a *App) SetPasswordHashAlgorithmFactory(f iface.IPasswordHashAlgorithmFactory)
  • func (a *App) SetProposalReceiver(pr func(*pb.Proposal, pb.Status))
  • func (a *App) UpdateGlobalRequestTimeout(timeout time.Duration)

Variables

var AuthorCMD = &cobra.Command{
	Use:   "author",
	Short: "Print Flamed authors",
	Run: func(_ *cobra.Command, _ []string) {
		fmt.Printf(author)
	},
}

var ConfigCMD = &cobra.Command{
	Use:   "config",
	Short: "Manage config file",
	Run: func(cmd *cobra.Command, _ []string) {
		fmt.Println(cmd.UsageString())
	},
}

var ConfigCreateCMD = &cobra.Command{
	Use:   "create",
	Short: "Create config file",
	Run: func(cmd *cobra.Command, _ []string) {
		if len(filePath) == 0 {
			fmt.Println("file-path can not be empty")
			return
		}

		err := viper.WriteConfigAs(filePath)
		if err != nil {
			fmt.Println(err)
		}
	},
}

var RunCMD = &cobra.Command{
	Use:   "run",
	Short: "Run command",
	Run: func(cmd *cobra.Command, args []string) {
		fmt.Println(cmd.UsageString())
	},

} // Command

var RunServerCMD = &cobra.Command{
	Use:   "server",
	Short: "Run server command",
	Run: func(cmd *cobra.Command, args []string) {
		go runServerCMDPreHOOK()

		if len(viper.GetString(constant.StoragePath)) == 0 {
			fmt.Println("StoragePath can not be empty")
			return
		}

		if len(viper.GetString(constant.RaftAddress)) == 0 {
			fmt.Println("RaftAddress can not be empty")
			return
		}

		if len(viper.GetString(constant.HTTPServerAddress)) == 0 {
			fmt.Println("HTTPServerAddress can not be empty")
			return
		}

		raftStoragePath := viper.GetString(constant.StoragePath) + "/raft"

		nodeConfiguration := getNodeConfiguration(raftStoragePath)
		if viper.GetString("LogDBConfig") == "tiny" {
			nodeConfiguration.NodeConfigurationInput.LogDB = config.GetTinyMemLogDBConfig()
		} else {
			nodeConfiguration.NodeConfigurationInput.LogDB = config.GetTinyMemLogDBConfig()
		}
		err := GetApp().GetFlamed().ConfigureNode(nodeConfiguration)
		if err != nil {
			panic(err)
		}

		startCluster()

		initializeClusterDefaults()

		runServerAndWaitForShutdown()
	},
}

var VersionCMD = &cobra.Command{
	Use:   "version",
	Short: "Print Flamed version",
	Run: func(_ *cobra.Command, _ []string) {
		fmt.Println(version)
	},
}

Functions

func InitConfigFlag

func InitConfigFlag(cmd *cobra.Command)

Types

type App

type App struct {
	// contains filtered or unexported fields
}

func GetApp

func GetApp() *App

func (*App) AddCommand

func (a *App) AddCommand(commands ...*cobra.Command)

func (*App) AddGRPCService

func (a *App) AddGRPCService(service iface2.IGRPCService)

func (*App) AddGraphQLMutation

func (a *App) AddGraphQLMutation(name string, handler graphql.GQLHandler)

func (*App) AddGraphQLQuery

func (a *App) AddGraphQLQuery(name string, handler graphql.GQLHandler)

func (*App) AddGraphQLSubscription

func (a *App) AddGraphQLSubscription(name string, handler graphql.GQLHandler)

func (*App) AddHTTPView

func (a *App) AddHTTPView(pattern string, view iface2.IHTTPView)

func (*App) AddTransactionProcessor

func (a *App) AddTransactionProcessor(tp iface.ITransactionProcessor)

func (*App) DisableDefaultCommands

func (a *App) DisableDefaultCommands()

func (*App) DisableDefaultGRPCServices

func (a *App) DisableDefaultGRPCServices()

func (*App) DisableDefaultTransactionProcessors

func (a *App) DisableDefaultTransactionProcessors()

func (*App) DisableDefaultViews

func (a *App) DisableDefaultViews()

func (*App) EnableDefaultCommands

func (a *App) EnableDefaultCommands()

func (*App) EnableDefaultGRPCServices

func (a *App) EnableDefaultGRPCServices()

func (*App) EnableDefaultTransactionProcessors

func (a *App) EnableDefaultTransactionProcessors()

func (*App) EnableDefaultViews

func (a *App) EnableDefaultViews()

func (*App) Execute

func (a *App) Execute() error

func (*App) GetFlamed

func (a *App) GetFlamed() *flamed.Flamed

func (*App) GetFlamedContext

func (a *App) GetFlamedContext() *context.FlamedContext

func (*App) GetPasswordHashAlgorithmFactory

func (a *App) GetPasswordHashAlgorithmFactory() iface.IPasswordHashAlgorithmFactory

func (*App) GetProposalReceiver

func (a *App) GetProposalReceiver() func(*pb.Proposal, pb.Status)

func (*App) GetTPMap

func (a *App) GetTPMap() map[string]iface.ITransactionProcessor

func (*App) GetTransactionProcessorMap

func (a *App) GetTransactionProcessorMap() map[string]iface.ITransactionProcessor

func (*App) SetPasswordHashAlgorithmFactory

func (a *App) SetPasswordHashAlgorithmFactory(f iface.IPasswordHashAlgorithmFactory)

func (*App) SetProposalReceiver

func (a *App) SetProposalReceiver(pr func(*pb.Proposal, pb.Status))

func (*App) UpdateGlobalRequestTimeout

func (a *App) UpdateGlobalRequestTimeout(timeout time.Duration)