validate

Documentation

Overview

Package validate contains various validation functions

Index

• Variables
• func CompositeOptionsForServer(comp *opts.Composite) error
• func ConnectionOptionsForServer(connOptions *opts.ConnectionOptions) error
• func DecodeOptionsForServer(decodeOptions *encoding.DecodeOptions) error
• func EncodeOptionsForServer(encodeOptions *encoding.EncodeOptions) error
• func ProtobufOptionsForCLI(dirs []string, rootMessage string) error
• func ReadOptionsForCLI(readOpts *opts.ReadOptions) error
• func ReadOptionsForServer(readOptions *opts.ReadOptions) error
• func RelayOptionsForCLI(relayOpts *opts.RelayOptions) error
• func RelayOptionsForServer(relayOptions *opts.RelayOptions) error
• func SamplingOptionsForServer(sampleOptions *opts.ReadSampleOptions) error
• func ServiceForServer(s *protos.Service) error
• func WriteOptionsCLI(writeOpts *opts.WriteOptions) error
• func WriteOptionsForServer(writeOpts *opts.WriteOptions) error

Variables

var (
	ErrMissingConnOpts    = errors.New("connection config cannot be nil")
	ErrMissingConnCfg     = errors.New("connection object in connection config cannot be nil")
	ErrMissingConnArgs    = errors.New("connection config args cannot be nil")
	ErrMissingClientKey   = errors.New("TLS key cannot be empty if TLS certificate is provided")
	ErrMissingClientCert  = errors.New("TLS certificate cannot be empty if TLS key is provided")
	ErrMissingDSN         = errors.New("DSN cannot be empty")
	ErrInvalidConnTimeout = errors.New("connection timeout must be greater than zero")
	ErrMissingAddress     = errors.New("address cannot be empty")

	ErrMissingMsg      = errors.New("msg cannot be nil")
	ErrMissingMsgValue = errors.New("msg.Value cannot be nil")

	ErrEmptyWriteOpts = errors.New("write options cannot be nil")

	ErrEmptyDynamicOpts = errors.New("dynamic options cannot be nil")

	ErrEmptyRelayOpts = errors.New("relay options cannot be nil")

	ErrEmptyBackendGroup = errors.New("backend group options cannot be nil")
	ErrEmptyBackendArgs  = errors.New("backend arg options cannot be nil")
)

var (
	ErrBackendNotFound = errors.New("backend not found")

	ErrMissingAuth  = errors.New("auth cannot be nil")
	ErrInvalidToken = errors.New("invalid token")

	ErrConnectionNotFound       = errors.New("connection not found")
	ErrMissingConnectionOptions = errors.New("connection options cannot be nil")
	ErrMissingConnName          = errors.New("you must provide a connection name")
	ErrMissingConnectionType    = errors.New("you must provide at least one connection of: kafka")

	ErrMissingConnectionID = errors.New("missing connection ID")
	ErrMissingReadOptions  = errors.New("missing Read options")
	ErrMissingReadType     = errors.New("you must provide at least one read argument message")

	ErrMissingName     = errors.New("name cannot be empty")
	ErrMissingService  = errors.New("service cannot be empty")
	ErrInvalidRepoURL  = errors.New("repo URL must be a valid URL or left blank")
	ErrServiceNotFound = errors.New("service does not exist")
	ErrRepoNotFound    = errors.New("repository was not found on this service")

	ErrInvalidGithubSchemaType = errors.New("only protobuf and avro schemas can be imported from github")
	ErrSchemaNotFound          = errors.New("schema does not exist")

	ErrMissingComposite  = errors.New("composite cannot be empty")
	ErrCompositeReadIDs  = errors.New("you must specify at least 2 read IDs for a composite view")
	ErrCompositeNotFound = errors.New("composite view does not exist")
)

var (
	ErrMissingServerOptions = errors.New("ServerOptions cannot be nil")
	ErrMissingAuthToken     = errors.New("AuthToken cannot be nil")
	ErrMissingEtcd          = errors.New("EtcdService cannot be nil")
	ErrMissingConfig        = errors.New("PersistentConfig cannot be nil")
)

Functions

func CompositeOptionsForServer

func CompositeOptionsForServer(comp *opts.Composite) error

func ConnectionOptionsForServer

func ConnectionOptionsForServer(connOptions *opts.ConnectionOptions) error

ConnectionOptionsForServer ensures all required parameters are passed when creating/testing/updating a connection

func DecodeOptionsForServer

func DecodeOptionsForServer(decodeOptions *encoding.DecodeOptions) error

func EncodeOptionsForServer

func EncodeOptionsForServer(encodeOptions *encoding.EncodeOptions) error

func ProtobufOptionsForCLI

func ProtobufOptionsForCLI(dirs []string, rootMessage string) error

func ReadOptionsForCLI

func ReadOptionsForCLI(readOpts *opts.ReadOptions) error

func ReadOptionsForServer

func ReadOptionsForServer(readOptions *opts.ReadOptions) error

func RelayOptionsForCLI

func RelayOptionsForCLI(relayOpts *opts.RelayOptions) error

func RelayOptionsForServer

func RelayOptionsForServer(relayOptions *opts.RelayOptions) error

TODO: Implement

func SamplingOptionsForServer

func SamplingOptionsForServer(sampleOptions *opts.ReadSampleOptions) error

func ServiceForServer

func ServiceForServer(s *protos.Service) error

func WriteOptionsCLI

func WriteOptionsCLI(writeOpts *opts.WriteOptions) error

func WriteOptionsForServer

func WriteOptionsForServer(writeOpts *opts.WriteOptions) error