kafka_nervous

Documentation

Index

• Constants
• func GenerateRequestTopic(guid string) string
• func GenerateResponseTopic(guid string) string
• func NewNervous(ctx context.Context, configAddress string, guid string) (Ng.Controller, error)
• func NewNervousMessage() Ng.Message
• func ReadJsonFile(address string) (map[string]interface{}, error)
• type BaseInfo
• type MethodInfo
  • func (m *MethodInfo) FromJson(jsonStr string) error
  • func (m *MethodInfo) ToJson() (string, error)
• type ReturnInfo
  • func (r *ReturnInfo) FromJson(jsonStr string) error
  • func (r *ReturnInfo) ToJson() (string, error)

Constants

const RequestTopicPrefix = "REQ"

const ResponseTopicPrefix = "RES"

const TryInterval = 500

const TryTime = 5

Functions

func GenerateRequestTopic

func GenerateRequestTopic(guid string) string

func GenerateResponseTopic

func GenerateResponseTopic(guid string) string

func NewNervous

func NewNervous(ctx context.Context, configAddress string, guid string) (Ng.Controller, error)

初始化总线 @param 上下文，配置文件目录，全局id @return 总线指针，错误

func NewNervousMessage

func NewNervousMessage() Ng.Message

func ReadJsonFile

func ReadJsonFile(address string) (map[string]interface{}, error)

Types

type BaseInfo

type BaseInfo struct {
	SourceGuid string `json:"source_guid"`
	TargetGuid string `json:"target_guid"`
}

type MethodInfo

type MethodInfo struct {
	BaseInfo
	RegisterName string        `json:"register_name"`
	ParamArray   []interface{} `json:"param_array"`
}

func (*MethodInfo) FromJson

func (m *MethodInfo) FromJson(jsonStr string) error

func (*MethodInfo) ToJson

func (m *MethodInfo) ToJson() (string, error)

type ReturnInfo

type ReturnInfo struct {
	BaseInfo
	Status      int         `json:"status"`
	ReturnValue interface{} `json:"return_value"`
}

func (*ReturnInfo) FromJson

func (r *ReturnInfo) FromJson(jsonStr string) error

func (*ReturnInfo) ToJson

func (r *ReturnInfo) ToJson() (string, error)