cmd

Documentation

Index

• Constants
• func DecodePageToken(tok string) (*pageToken, error)
• func Execute()
• type QueueConfig
  • func NewQueueConfig() *QueueConfig
  • func (qc *QueueConfig) AnalyticInbox(id string) string
  • func (qc *QueueConfig) AnalyticInboxFmt() string
  • func (qc *QueueConfig) DetectionInbox() string
  • func (qc *QueueConfig) DetectionOutbox() string
  • func (qc *QueueConfig) FuserInbox(id string) string
  • func (qc *QueueConfig) FuserInboxFmt() string
  • func (qc *QueueConfig) FusionGenInbox() string
  • func (qc *QueueConfig) FusionInbox() string
  • func (qc *QueueConfig) FusionOutbox() string
• type ServerSettings
  • func NewServerSettings() *ServerSettings
  • func (s *ServerSettings) GRPCServerOptions() ([]grpc.ServerOption, error)

Constants

const (
	DefaultGlobalQueuePrefix = ""
	DefaultAnalyticInboxFmt  = "/task/detection/analytic/%s/inbox"
	DefaultDetectionInbox    = "/task/detection/inbox"
	DefaultDetectionOutbox   = "/task/detection/outbox"
	DefaultFuserInboxFmt     = "/task/fusion/fuser/%s/inbox"
	DefaultFusionInbox       = "/task/fusion/inbox"
	DefaultFusionOutbox      = "/task/fusion/outbox"
	DefaultFusionGenInbox    = "/task/fusiongen/inbox"

	DefaultPageSize = 100
	MaxPageSize     = 250
)

Functions

func DecodePageToken

func DecodePageToken(tok string) (*pageToken, error)

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.

Types

type QueueConfig

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

func NewQueueConfig

func NewQueueConfig() *QueueConfig

func (*QueueConfig) AnalyticInbox

func (qc *QueueConfig) AnalyticInbox(id string) string

func (*QueueConfig) AnalyticInboxFmt

func (qc *QueueConfig) AnalyticInboxFmt() string

func (*QueueConfig) DetectionInbox

func (qc *QueueConfig) DetectionInbox() string

func (*QueueConfig) DetectionOutbox

func (qc *QueueConfig) DetectionOutbox() string

func (*QueueConfig) FuserInbox

func (qc *QueueConfig) FuserInbox(id string) string

func (*QueueConfig) FuserInboxFmt

func (qc *QueueConfig) FuserInboxFmt() string

func (*QueueConfig) FusionGenInbox

func (qc *QueueConfig) FusionGenInbox() string

func (*QueueConfig) FusionInbox

func (qc *QueueConfig) FusionInbox() string

func (*QueueConfig) FusionOutbox

func (qc *QueueConfig) FusionOutbox() string

type ServerSettings

type ServerSettings struct {
	TLS            bool
	VerifyClient   bool
	ClientCAFile   string
	ServerCertFile string
	ServerKeyFile  string
}

func NewServerSettings

func NewServerSettings() *ServerSettings

func (*ServerSettings) GRPCServerOptions

func (s *ServerSettings) GRPCServerOptions() ([]grpc.ServerOption, error)