connector

Documentation

Index

• Constants
• type ConsulService
  • func CreateService(filepath string) (ConsulService, error)
• type NbAgentInfo
• type NbCheckInfo
• type NbConfig
• type NbLogger
• type NbServerInfo
• type RequestHistory

Constants

const (
	AMQP   = "AMQP"
	GET    = "GET"
	POST   = "POST"
	PUT    = "PUT"
	DELETE = "DELETE"
	HEAD   = "HEAD"
	OPTION = "OPTION"
)

Types

type ConsulService

type ConsulService interface {
	Config() *NbConfig
	Services() (map[string]*consul.AgentService, error)
	DeRegister()
	CreateDataTable(bean ...interface{}) error
	InsertRecord(bean ...interface{}) (int64, error)
	UpdateRecord(bean interface{}, conditions ...interface{}) (int64, error)
	DeleteRecord(bean interface{}) (int64, error)
	FindRecords(bean interface{}, query interface{}, args ...interface{}) error
	GetFirstRecord(bean interface{}) (bool, error)
	RegisterMessageHandler(api string, callback func([]byte) ([]byte, error)) error
	RegisterHttpHandler(api string, method string, callback func([]byte) ([]byte, error))
	StartServer(remoteShutdown bool) error
	SendRequest(method string, service string, api string, param string) error
}

func CreateService

func CreateService(filepath string) (ConsulService, error)

type NbAgentInfo

type NbAgentInfo struct {
	Autoregister bool   `default:"false"`
	Server       string `required:"true"`
	Port         uint32 `required:"true"`
	Name         string `required:"true"`
	Id           string `required:"true"`
	Username     string
	Password     string
	Tags         []string
}

type NbCheckInfo

type NbCheckInfo struct {
	Method   string
	Interval string
	Timeout  string
}

type NbConfig

type NbConfig struct {
	Service     NbAgentInfo
	Database    NbServerInfo
	Health      NbCheckInfo
	Amqp        NbServerInfo
	Application map[string]string
}

type NbLogger

type NbLogger struct {
	Destination string
}

type NbServerInfo

type NbServerInfo struct {
	Address  string
	Port     uint32
	Name     string
	Username string `default:"guest"`
	Password string `default:"guest"`
}

type RequestHistory

type RequestHistory struct {
	Id          int64     `xorm:"pk autoincr"`
	Ip          string    `xorm:"notnull default('')"`
	Service     string    `xorm:"notnull"`
	Api         string    `xorm:"notnull"`
	Param       string    `xorm:"notnull varchar(1024) default('')"`
	Result      string    `xorm:"notnull varchar(1024) default('')"`
	Method      string    `xorm:"notnull"`
	Direction   string    `xorm:"notnull"`
	RequestTime time.Time `xorm:"notnull created"`
	Version     int       `xorm:"notnull version"`
}