The highest tagged major version is v3.

cmd

package

v1.0.4 Latest Latest Go to latest Published: Jul 20, 2023 License: GPL-3.0 Imports: 22 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/astrolabsoftware/finkctl

Links

Open Source Insights

Documentation ¶

Overview ¶

This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.

You should have received a copy of the GNU General Public License along with this program. If not, see <http://www.gnu.org/licenses/>.

This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.

You should have received a copy of the GNU General Public License along with this program. If not, see <http://www.gnu.org/licenses/>.

Index ¶

Constants
func ExecCmd(command string) (string, string)
func Execute()
func Version() (version, sum string)
type DistributionConfig
type Raw2ScienceConfig
type S3Config
type SparkConfig
type Stream2RawConfig

Constants ¶

View Source

const DISTRIBUTION string = "distribution"

View Source

const DISTRIBUTION_BIN string = "distribute.py"

View Source

const RAW2SCIENCE string = "raw2science"

View Source

const S3 string = "s3"

View Source

const SPARK string = "spark"

View Source

const STREAM2RAW string = "stream2raw"

View Source

const ShellToUse = "bash"

Variables ¶

This section is empty.

Functions ¶

func ExecCmd ¶

func ExecCmd(command string) (string, string)

func Execute ¶

func Execute()

Execute adds all child commands to the root command and sets flags appropriately. This is called by main.main(). It only needs to happen once to the rootCmd.

func Version ¶ added in v1.0.1

func Version() (version, sum string)

Version returns the version of finkctl and its checksum.

Types ¶

type DistributionConfig ¶

type DistributionConfig struct {
	DistributionServers string `mapstructure:"distribution_servers"`
	SubstreamPrefix     string `mapstructure:"substream_prefix"`
	DistributionSchema  string `mapstructure:"distribution_schema"`
	Night               string `mapstructure:"night"`
}

type Raw2ScienceConfig ¶

type Raw2ScienceConfig struct {
	Night string `mapstructure:"night"`
}

type S3Config ¶

type S3Config struct {
	Endpoint        string `mapstructure:"endpoint"`
	AccessKeyID     string `mapstructure:"id"`
	SecretAccessKey string `mapstructure:"secret"`
	UseSSL          bool   `mapstructure:"use_ssl"`
	BucketName      string `mapstructure:"bucket"`
}

type SparkConfig ¶

type SparkConfig struct {
	ApiServerUrl      string
	Binary            string
	Image             string `mapstructure:"image"`
	Producer          string `mapstructure:"producer"`
	OnlineDataPrefix  string `mapstructure:"online_data_prefix"`
	Packages          string
	FinkTriggerUpdate string `mapstructure:"fink_trigger_update"`
	LogLevel          string `mapstructure:"log_level"`
	StorageClass      storageClass
}

type Stream2RawConfig ¶

type Stream2RawConfig struct {
	KafkaSocket         string `mapstructure:"kafka_socket"`
	KafkaTopic          string `mapstructure:"kafka_topic"`
	FinkAlertSchema     string `mapstructure:"fink_alert_schema"`
	KafkaStartingOffset string `mapstructure:"kafka_starting_offset"`
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL