goservice

type Action struct {
	Name   string
	Params interface{}
	Rest   Rest
	Handle func(*Context) (interface{}, error)
}

type Broker struct {
	Config   BrokerConfig
	Services []*Service
	Started  func(*Context)
	Stoped   func(*Context)
	// contains filtered or unexported fields
}

type BrokerConfig struct {
	NodeId            string
	TransporterConfig TransporterConfig
	LoggerConfig      Logconfig
	Metrics           string
	TraceConfig       TraceConfig
	DiscoveryConfig   DiscoveryConfig
	RequestTimeOut    int
}

type Call func(action string, params interface{}, opts ...CallOpts) (interface{}, error)

type CallOpts struct {
}

type Context struct {
	RequestId         string
	TraceParentId     string
	TraceParentRootId string
	ResponseId        string
	Params            interface{}
	Meta              interface{}
	FromService       string
	FromAction        string
	FromEvent         string
	FromNode          string
	CallingLevel      int
	Call              Call
	Service           *Service
}

type Count struct {
	Interval int           `json:"interval"`
	Samples  []CountSample `json:"samples"`
}

type CountSample struct {
	Type  string  `json:"type"`
	Count float64 `json:"count"`
}

type DiscoveryBroadcastsChannelType string

type DiscoveryConfig struct {
	Enable                   bool
	HeartbeatInterval        int
	HeartbeatTimeout         int
	CleanOfflineNodesTimeout int
	Config                   interface{}
	DiscoveryType            DiscoveryType
}

type DiscoveryPotocol int

type DiscoveryRedisConfig struct {
	Port     int
	Host     string
	Password string
	Db       int
}

type DiscoveryType int

type Event struct {
	Name   string
	Params interface{}
	Handle func(*Context)
}

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

type EventBusData struct {
	Channel string
	Handle  []reflect.Value
}

type Gateway struct {
	Gin       *gin.Engine
	GinRoutes []*gin.RouterGroup
	Services  []RegistryService

	Config  GatewayConfig
	Service *Service
	// contains filtered or unexported fields
}

type GatewayConfig struct {
	Name   string
	Host   string
	Port   int
	Routes []GatewayConfigRoute
}

type GatewayConfigRoute struct {
	Path             string
	WhileList        []string
	StaticPath       string
	StaticFolderRoot string
}

type Log struct {
	Config  Logconfig
	Extenal interface{}
}

type LogData struct {
	Type    LogType
	Message string
	Payload map[string]interface{}
	Time    int
}

type LogExternal int

type LogType int

type Logconfig struct {
	Enable   bool
	Type     LogExternal
	LogLevel LogType
}

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

type Method int

type PackageType int

type PrintSpanParent struct {
	Name         string
	Traceid      string
	Callinglevel int
	Last         bool
}

type RegistryAction struct {
	Name   string      `json:"name" mapstructure:"name"`
	Rest   Rest        `json:"rest" mapstructure:"rest"`
	Params interface{} `json:"params" mapstructure:"params"`
}

type RegistryEvent struct {
	Name   string      `json:"name" mapstructure:"name"`
	Params interface{} `json:"params" mapstructure:"params"`
}

type RegistryNode struct {
	NodeId     string   `json:"node_id" mapstructure:"node_id"`
	IP         []string `json:"ip" mapstructure:"ip"`
	LastActive int      `json:"last_active" mapstructure:"last_active"`
}

type RegistryService struct {
	Node    RegistryNode     `json:"node" mapstructure:"node"`
	Name    string           `json:"name" mapstructure:"name"`
	Actions []RegistryAction `json:"actions" mapstructure:"actions"`
	Events  []RegistryEvent  `json:"events" mapstructure:"events"`
}

type RequestTranferData struct {
	Params            interface{} `json:"params" mapstructure:"params"`
	Meta              interface{} `json:"meta" mapstructure:"meta"`
	RequestId         string      `json:"request_id" mapstructure:"request_id"`
	ResponseId        string      `json:"response_id" mapstructure:"response_id"`
	TraceParentId     string      `json:"trace_parent_id" mapstructure:"trace_parent_id"`
	TraceRootParentId string      `json:"trace_root_parent_id" mapstructure:"trace_root_parent_id"`
	CallerNodeId      string      `json:"caller_node_id" mapstructure:"caller_node_id"`
	CallerService     string      `json:"caller_service" mapstructure:"caller_service"`
	CallerAction      string      `json:"caller_action" mapstructure:"caller_action"`
	CallerEvent       string      `json:"caller_event" mapstructure:"caller_event"`
	CallingLevel      int         `json:"calling_level" mapstructure:"calling_level"`
	CalledTime        int64       `json:"called_time" mapstructure:"called_time"`
	CallToService     string      `json:"call_to_service" mapstructure:"call_to_service"`
	CallToAction      string      `json:"call_to_action" mapstructure:"call_to_action"`
	CallToEvent       string      `json:"call_to_event" mapstructure:"call_to_event"`
}

type ResponseTranferData struct {
	Data            interface{} `json:"data" mapstructure:"data"`
	Error           bool        `json:"error" mapstructure:"error"`
	ErrorMessage    string      `json:"error_message" mapstructure:"error_message"`
	ResponseId      string      `json:"response_id" mapstructure:"response_id"`
	ResponseNodeId  string      `json:"response_node_id" mapstructure:"response_node_id"`
	ResponseService string      `json:"response_service" mapstructure:"response_service"`
	ResponseAction  string      `json:"response_action" mapstructure:"response_action"`
	ResponseTime    int64       `json:"response_time" mapstructure:"response_time"`
	TraceSpans      []traceSpan `json:"trace_spans" mapstructure:"trace_spans"`
}

type Rest struct {
	Method Method `json:"method" mapstructure:"method"`
	Path   string `json:"path" mapstructure:"path"`
}

type Service struct {
	Name    string
	Actions []Action
	Events  []Event
	Started func(*Context)
	Stoped  func(*Context)
	Broker  *Broker
}

type TopicDisconnectData struct {
	Sender  RegistryNode `json:"sender" mapstructure:"sender"`
	Time    uint64       `json:"time" mapstructure:"time"`
	Arrived uint64       `json:"arrived" mapstructure:"arrived"`
}

type TopicDiscoveryData struct {
	Sender RegistryNode `json:"sender" mapstructure:"sender"`
}

type TopicHeartbeatData struct {
	Sender RegistryNode `json:"sender" mapstructure:"sender"`
	Cpu    float64      `json:"cpu" mapstructure:"cpu"`
	Ram    int          `json:"ram" mapstructure:"ram"`
}

type TopicInfoData struct {
	Sender   RegistryNode      `json:"sender" mapstructure:"sender"`
	Services []RegistryService `json:"services" mapstructure:"services"`
}

type TopicPingData struct {
	Sender RegistryNode `json:"sender" mapstructure:"sender"`
	Time   uint64       `json:"time" mapstructure:"time"`
}

type TopicPongData struct {
	Sender  RegistryNode `json:"sender" mapstructure:"sender"`
	Time    uint64       `json:"time" mapstructure:"time"`
	Arrived uint64       `json:"arrived" mapstructure:"arrived"`
}

type Trace struct {
	Exporter interface{}
	Lock     sync.RWMutex
}

type TraceConfig struct {
	Enabled             bool
	WindowTime          int
	TraceExpoter        TraceExpoter
	TraceExporterConfig interface{}
}

type TraceConsoleConfig struct {
}

type TraceExpoter int

type Transporter struct {
	Config    TransporterConfig
	Subscribe func(channel string) interface{}
	Emit      func(channel string, data interface{}) error
	Receive   func(func(string, interface{}, error), interface{})
}

type TransporterConfig struct {
	Enable          bool
	TransporterType TransporterType
	Config          interface{}
}

type TransporterRedisConfig struct {
	Port     int
	Host     string
	Password string
	Db       int
}

type TransporterType int