monitor

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

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

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

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

type ConfigFile struct {
	Database struct {
		Url    string `yaml:"url"`
		Filter struct {
			Name    string `yaml:"name"`
			Account string `yaml:"account"`
		} `yaml:"filter"`
	} `yaml:"database"`

	Server struct {
		Addr string `yaml:"addr"`
	} `yaml:"server"`

	Session struct {
		WriteWait          string `yaml:"writeWait"`
		PongWait           string `yaml:"pongWait"`
		MaxEventsInMessage int    `yaml:"maxEventsInMessage"`
	} `yaml:"session"`

	Upgrader struct {
		ReadBufferSize  int `yaml:"readBufferSize"`
		WriteBufferSize int `yaml:"writeBufferSize"`
	} `yaml:"upgrader"`

	Abi struct {
		Main   string         `yaml:"main"`
		Events map[int]string `yaml:"events"`
	} `yaml:"abi"`

	EventExpires   string `yaml:"eventExpires"`
	SharedDatabase struct {
		Url string `yaml:"url"`
	} `yaml:"sharedDatabase"`
}

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

type DatabaseConnect interface {
	QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row
	Query(ctx context.Context, sql string, optionsAndArgs ...interface{}) (pgx.Rows, error)
}

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

type DatabaseMock struct{}

type DatabaseMockRow struct{}

type DatabaseMockRows struct{}

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

type Event struct {
	Offset    uint64          `json:"offset"`
	Sender    string          `json:"sender"`
	CasinoID  uint64          `json:"casino_id"`
	GameID    uint64          `json:"game_id"`
	RequestID uint64          `json:"req_id"`
	EventType int             `json:"event_type"`
	Data      json.RawMessage `json:"data"`
}

type EventDataSlice []byte

type EventMessage struct {
	Offset uint64   `json:"offset"` // last event.offset
	Events []*Event `json:"events"`
}

type Queue struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type RawEvent struct {
	Offset    uint64         `json:"offset"`
	Sender    string         `json:"sender"`
	CasinoID  interface{}    `json:"casino_id"`
	GameID    interface{}    `json:"game_id"`
	RequestID interface{}    `json:"req_id"`
	EventType int            `json:"event_type"`
	Data      EventDataSlice `json:"data"`
}

type RequestMessage struct {
	ID     *string         `json:"id"`
	Method *string         `json:"method"`
	Params json.RawMessage `json:"params"`
}

type ResponseErrorMessage struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

type ResponseMessage struct {
	ID     *string               `json:"id"`
	Result json.RawMessage       `json:"result"`
	Error  *ResponseErrorMessage `json:"error"`
}

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

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

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

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

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

type Session struct {
	ID string

	sync.Mutex
	// contains filtered or unexported fields
}

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

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

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

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

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