Documentation ¶
Index ¶
- Constants
- func DecodePageToken(tok string) (*pageToken, error)
- func Execute()
- type 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
Constants ¶
View Source
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 )
Variables ¶
This section is empty.
Functions ¶
func DecodePageToken ¶
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)
Click to show internal directories.
Click to hide internal directories.