core

type APIClientConfiguration struct {
	Address       string
	Protocol      string
	Timeout       time.Duration
	MaxRetry      int
	WaitToRetry   time.Duration
	LoggingCol    string
	MaxConnection int
}

type APIResponse struct {
	Status    string            `json:"status"`
	Data      interface{}       `json:"data,omitempty"`
	Message   string            `json:"message"`
	ErrorCode string            `json:"errorCode,omitempty"`
	Total     int64             `json:"total,omitempty"`
	Headers   map[string]string `json:"headers,omitempty"`
}

type App struct {
	Name       string
	Server     *Server
	DBList     []*DBClient
	WorkerList []*Worker
	// contains filtered or unexported fields
}

type CallResult struct {
	RespCode     int                 `json:"respCode,omitempty" bson:"resp_code,omitempty"`
	RespHeader   map[string][]string `json:"respHeader,omitempty" bson:"resp_header,omitempty"`
	RespBody     *string             `json:"respBody,omitempty" bson:"resp_body,omitempty"`
	ResponseTime int64               `json:"responseTime,omitempty" bson:"response_time,omitempty"`
	ErrorLog     *string             `json:"errorLog,omitempty" bson:"error_log,omitempty"`
}

type ConsumeFn = func(*QueueItem) error

type DBClient struct {
	Name   string
	Config DBConfiguration
	// contains filtered or unexported fields
}

type DBConfiguration struct {
	Address            []string
	Ssl                bool
	Username           string
	Password           string
	AuthDB             string
	ReplicaSetName     string
	SecondaryPreferred bool
}

type DBModel struct {
	ColName        string
	DBName         string
	TemplateObject interface{}
	// contains filtered or unexported fields
}

type DBQueue2 struct {
	ColName string
	// contains filtered or unexported fields
}

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

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

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

type DbResponse struct {
	Status    string      `json:"status"`
	Data      interface{} `json:"data,omitempty"`
	Message   string      `json:"message"`
	ErrorCode string      `json:"errorCode,omitempty"`
	Total     int64       `json:"total,omitempty"`
}

type DbStatusEnum struct {
	Ok       string
	Error    string
	NotFound string
}

type Error struct {
	Type    string
	Message string
	Data    interface{}
}

type HTTPMethod string

type HTTPMethodEnum struct {
	Get    HTTPMethod
	Post   HTTPMethod
	Put    HTTPMethod
	Head   HTTPMethod
	Delete HTTPMethod
	Option HTTPMethod
}

type HandleFunc func(request Request) Response

type IPoll interface {
	Add(conn net.Conn) error
	Remove(conn net.Conn) error
	Wait(int64) ([]net.Conn, error)
}

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

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

type MethodEnum struct {
	GET     *MethodValue
	POST    *MethodValue
	PUT     *MethodValue
	DELETE  *MethodValue
	OPTIONS *MethodValue
}

type MethodValue struct {
	Value string
}

type OnConnectedHandler = func(session *DBSession) error

type OutboundAPIRequest struct {
	Method  string            `json:"method" bson:"method"`
	Path    string            `json:"path" bson:"path"`
	Params  map[string]string `json:"params,omitempty" bson:"params,omitempty"`
	Headers map[string]string `json:"headers,headers" bson:"headers,omitempty"`
	Content string            `json:"content,omitempty" bson:"content,omitempty"`
}

type QueueItem struct {
	Data            interface{}    `json:"data,omitempty" bson:"data,omitempty"`
	ID              *bson.ObjectId `json:"id,omitempty" bson:"_id,omitempty"`
	ProcessBy       string         `json:"processBy,omitempty" bson:"process_by,omitempty"`
	Version         string         `json:"version,omitempty" bson:"versionF,omitempty"`
	ProcessTimeMS   int            `json:"processTimeMS,omitempty" bson:"process_time_ms,omitempty"`
	CreatedTime     *time.Time     `json:"createdTime,omitempty" bson:"created_time,omitempty"`
	LastUpdatedTime *time.Time     `json:"lastUpdatedTime,omitempty" bson:"last_updated_time,omitempty"`
	LastFail        *time.Time     `json:"lastFail,omitempty" bson:"last_fail,omitempty"`
	Keys            *[]string      `json:"keys,omitempty" bson:"keys,omitempty"`
	Log             *[]string      `json:"log,omitempty" bson:"log,omitempty"`
}

type Request struct {
	Action string
	Data   interface{}
}

type RequestLogEntry struct {
	Status      string             `json:"status,omitempty" bson:"status,omitempty"`
	ReqURL      string             `json:"reqUrl,omitempty" bson:"req_url,omitempty"`
	ReqMethod   string             `json:"reqMethod,omitempty" bson:"req_method,omitempty"`
	ReqHeader   *map[string]string `json:"reqHeader,omitempty" bson:"req_header,omitempty"`
	ReqFormData *map[string]string `json:"reqFormData,omitempty" bson:"req_form_data,omitempty"`
	ReqBody     *interface{}       `json:"reqBody,omitempty" bson:"req_body,omitempty"`

	TotalTime  int64         `json:"totalTime,omitempty" bson:"total_time,omitempty"`
	RetryCount int           `json:"retryCount,omitempty" bson:"retry_count,omitempty"`
	Results    []*CallResult `json:"results,omitempty" bson:"results,omitempty"`
	ErrorLog   *string       `json:"errorLog,omitempty" bson:"error_log,omitempty"`
	Keys       *[]string     `json:"keys,omitempty" bson:"keys,omitempty"`
	Date       *time.Time    `bson:"date,omitempty" json:"date,omitempty"`
}

type Response struct {
	Status  string
	Message string
	Data    interface{}
}

type RestClient struct {
	BaseURL   *url.URL
	UserAgent string
	// contains filtered or unexported fields
}

type RestResult struct {
	Body    string `json:"body,omitempty" bson:"body,omitempty"`
	Content []byte `json:"content,omitempty" bson:"content,omitempty"`
	Code    int    `json:"code,omitempty" bson:"code,omitempty"`
}

type Server struct {
	Poll        IPoll
	PollTimeout int64
	// contains filtered or unexported fields
}

type StatusEnum struct {
	Ok           string
	Error        string
	Invalid      string
	NotFound     string
	Forbidden    string
	Existed      string
	Unauthorized string
}

type Task = func()

type Worker struct {
	Task Task
	// contains filtered or unexported fields
}