app

Documentation

Index

• func NewCmdConfig(out io.Writer, config *Config) *cobra.Command
• func NewCmdServer(logger logrus.FieldLogger, config *Config) *cobra.Command
• func NewCmdVersion(out io.Writer) *cobra.Command
• func RootCommand(out, stderr io.Writer) *cobra.Command
• func Run(out, stderr io.Writer) error
• type Config
  • func (c Config) String() string
  • func (c Config) Validate() error

Functions

func NewCmdConfig

func NewCmdConfig(out io.Writer, config *Config) *cobra.Command

func NewCmdServer

func NewCmdServer(logger logrus.FieldLogger, config *Config) *cobra.Command

func NewCmdVersion

func NewCmdVersion(out io.Writer) *cobra.Command

func RootCommand

func RootCommand(out, stderr io.Writer) *cobra.Command

func Run

func Run(out, stderr io.Writer) error

Types

type Config

type Config struct {
	Logging struct {
		Level  string `mapstructure:"level"`
		Format string `mapstructure:"format"`
	} `mapstructure:"logging"`

	Adapter struct {
		RepositoryTable       string `mapstructure:"repository_table"`
		ProcessingTable       string `mapstructure:"processing_table"`
		RegistryTable         string `mapstructure:"registry_table"`
		QueueRecvMainAddr     string `mapstructure:"queue_recv_main_addr"`
		QueueSendMainAddr     string `mapstructure:"queue_send_main_addr"`
		QueueSendErrorAddr    string `mapstructure:"queue_send_error_addr"`
		QueueSendInvalidAddr  string `mapstructure:"queue_send_invalid_addr"`
		ValidationServiceAddr string `mapstructure:"validation_service_addr"`
	} `mapstructure:"adapter"`

	AWS struct {
		S3Profile        string `mapstructure:"s3_profile"`
		S3Endpoint       string `mapstructure:"s3_endpoint"`
		DynamoDBProfile  string `mapstructure:"dynamodb_profile"`
		DynamoDBEndpoint string `mapstructure:"dynamodb_endpoint"`
		SQSProfile       string `mapstructure:"sqs_profile"`
		SQSEndpoint      string `mapstructure:"sqs_endpoint"`
		SNSProfile       string `mapstructure:"sns_profile"`
		SNSEndpoint      string `mapstructure:"sns_endpoint"`
	} `mapstructure:"aws"`
	// contains filtered or unexported fields
}

func (Config) String

func (c Config) String() string

func (Config) Validate

func (c Config) Validate() error