messagequeue

Documentation

Index

• func Subscribe(s asyncapp.AsyncMessageService, topics *TopicConfig) (err error)
• type TopicConfig

Functions

func Subscribe

func Subscribe(s asyncapp.AsyncMessageService, topics *TopicConfig) (err error)

Types

type TopicConfig

type TopicConfig struct {
	BigModelFinished     string `json:"bigmodel_finished"        required:"true"`
	InferenceStart       string `json:"inference_start"`
	InferenceError       string `json:"inference_error"`
	InferenceAsyncStart  string `json:"inference_async_start"`
	InferenceAsyncFinish string `json:"inference_async_finish"`
}