detail

Documentation

Index

• type ObserverInfo
  • func (observer *ObserverInfo) Close()
  • func (observer *ObserverInfo) Exec()
  • func (observer *ObserverInfo) Open()

Types

type ObserverInfo

type ObserverInfo struct {
	Id             string                 `json:"id"`
	DBHost         string                 `json:"db_host"`
	DBPort         string                 `json:"db_port"`
	Database       string                 `json:"database"`
	Collection     string                 `json:"collection"`
	Conditions     map[string]interface{} `json:"conditions"`
	ParallelNumber int                    `json:"parallel_number"`
	RequestTopic   string                 `json:"request_topic"`
	DBUser         string                 `json:"db_user"`
	DBPass         string                 `json:"db_pass"`
}

func (*ObserverInfo) Close

func (observer *ObserverInfo) Close()

func (*ObserverInfo) Exec

func (observer *ObserverInfo) Exec()

func (*ObserverInfo) Open

func (observer *ObserverInfo) Open()