arangodb erlang数据库驱动
Você não pode selecionar mais de 25 tópicos Os tópicos devem começar com uma letra ou um número, podem incluir traços ('-') e podem ter até 35 caracteres.

171 linhas
4.9 KiB

4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
3 anos atrás
4 anos atrás
3 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
4 anos atrás
  1. %% agency 管理进程的名称
  2. -define(agAgencyPoolMgr, agAgencyPoolMgr).
  3. -define(agBeamPool, agBeamPool).
  4. -define(agBeamAgency, agBeamAgency).
  5. -define(agMessageId, agMessageId).
  6. -define(agMaxMessageId, 576460752303423486).
  7. -define(AgUndef, 0). %% Wait One Chunk start
  8. -define(AgCHeader, 1). %% Wait One Chunk header
  9. -define(AgCBody, 2). %% Wait One Chunk Body
  10. -define(AgCBodyStart, 3). %% Ret Start Wait One Chunk Body
  11. -define(AgCBodyGoOn, 4). %% Ret Go On Wait One Chunk Body
  12. -define(AgCDone, 5). %% receve one Chunk done
  13. -define(AgMDone, 6). %% receve one message done
  14. %% pidFrom pid() to reply; undefiend discard; timeOut 该请求标记为过期了 discard
  15. -record(msgIdCache, {pidFrom, timerRef, chunkCnt, msgBuffer}).
  16. -define(AgMBIdx, 4).
  17. -define(AgCCIdx, 3).
  18. -define(AgTRIdx, 2).
  19. -define(AgPFIdx, 1).
  20. -define(AgHeaderSize, 24).
  21. %% 默认选项定义
  22. -define(AgDefBaseUrl, <<"http://47.108.26.175:8529">>).
  23. -define(AgDefDbName, <<"_system">>).
  24. -define(AgDefUser, <<"root">>).
  25. -define(AgDefPassWord, <<"arangodb3">>).
  26. -define(AgDefBacklogSize, 1024).
  27. -define(AgDefConnTimeout, 5000).
  28. -define(AgDefPoolSize, 16).
  29. -define(AgDefIsReConn, true).
  30. -define(AgDefReConnMin, 500).
  31. -define(AgDefReConnMax, 120000).
  32. -define(AgDefTimeout, infinity).
  33. -define(AgDefVstSize, 29976).
  34. -define(AgDefAgencySlg, poll). %% bind rand poll
  35. -define(AgDefPid, self()).
  36. -define(AgDefSocketOpts, [binary, {active, true}, {nodelay, true}, {delay_send, true}, {keepalive, true}, {recbuf, 1048576}, {send_timeout, 5000}, {send_timeout_close, true}]).
  37. -define(AgGetListKV(Key, List), agMiscUtils:getListValue(Key, List, undefined)).
  38. -define(AgGetListKV(Key, List, Default), agMiscUtils:getListValue(Key, List, Default)).
  39. -define(AgWarn(Tag, Format, Data), agMiscUtils:warnMsg(Tag, Format, Data)).
  40. -define(AgMDoDBConn, mDoDBConn).
  41. -define(AgUpgradeInfo, <<"VST/1.1\r\n\r\n">>).
  42. -record(agReq, {
  43. method :: method()
  44. , path :: path()
  45. , queryPars :: queryPars()
  46. , headers :: headers()
  47. , body :: body()
  48. , messageId :: pos_integer()
  49. , fromPid :: pid()
  50. , overTime = infinity :: timeout()
  51. , isSystem = false :: boolean()
  52. }).
  53. -record(agReqRet, {
  54. messageId :: messageId(),
  55. reply :: term()
  56. }).
  57. -record(reConnState, {
  58. min :: non_neg_integer(),
  59. max :: non_neg_integer() | infinity,
  60. current :: non_neg_integer() | undefined
  61. }).
  62. -record(srvState, {
  63. poolName :: poolName(),
  64. serverName :: serverName(),
  65. dbName :: binary(),
  66. reConnState :: undefined | reConnState(),
  67. socket :: undefined | ssl:sslsocket(),
  68. vstSize :: pos_integer(),
  69. timerRef :: undefined | reference()
  70. }).
  71. -record(cliState, {
  72. backlogSize = 0 :: integer(),
  73. revStatus = ?AgUndef :: pos_integer(),
  74. backlogNum = 0 :: integer(),
  75. messageId = 0 :: pos_integer(),
  76. chunkIdx = 0 :: pos_integer(),
  77. chunkSize = 0 :: pos_integer(),
  78. chunkBuffer = <<>> :: binary()
  79. }).
  80. -record(recvState, {
  81. revStatus = ?AgUndef :: pos_integer(),
  82. messageId = 0 :: pos_integer(),
  83. chunkCnt = -1 :: integer(),
  84. msgBuffer = <<>> :: binary(),
  85. chunkIdx = 0 :: pos_integer(),
  86. chunkSize = 0 :: pos_integer(),
  87. chunkBuffer = <<>> :: binary()
  88. }).
  89. -record(dbOpts, {
  90. host :: host(),
  91. port :: 0..65535,
  92. hostname :: hostName(),
  93. dbName :: binary(),
  94. protocol :: protocol(),
  95. poolSize :: poolSize(),
  96. user :: binary(),
  97. password :: binary(),
  98. vstSize :: pos_integer()
  99. }).
  100. -record(agencyOpts, {
  101. reconnect :: boolean(),
  102. agencySlg :: agencySlg(),
  103. backlogSize :: backlogSize(),
  104. reConnTimeMin :: pos_integer(),
  105. reConnTimeMax :: pos_integer()
  106. }).
  107. -type miRequest() :: #agReq{}.
  108. -type miRequestRet() :: #agReqRet{}.
  109. -type srvState() :: #srvState{}.
  110. -type cliState() :: #cliState{}.
  111. -type reConnState() :: #reConnState{}.
  112. -type recvState() :: #recvState{}.
  113. -type poolName() :: atom().
  114. -type poolNameOrSocket() :: atom() | socket().
  115. -type serverName() :: atom().
  116. -type protocol() :: ssl | tcp.
  117. -type method() :: binary().
  118. -type queryPars() :: map().
  119. -type headers() :: map().
  120. -type body() :: iodata() | undefined.
  121. -type path() :: binary().
  122. -type host() :: binary().
  123. -type hostName() :: string().
  124. -type poolSize() :: pos_integer().
  125. -type agencySlg() :: bind | rand | poll.
  126. -type backlogSize() :: pos_integer() | infinity.
  127. -type messageId() :: pos_integer().
  128. -type socket() :: inet:socket() | ssl:sslsocket().
  129. -type socketOpts() :: [gen_tcp:connect_option() | ssl:tls_client_option()].
  130. -type error() :: {error, term()}.
  131. -type dbCfg() ::
  132. {baseUrl, binary()} |
  133. {dbName, binary()} |
  134. {user, binary()} |
  135. {password, binary()} |
  136. {poolSize, poolSize()} |
  137. {vstSize, pos_integer()}.
  138. -type agencyCfg() ::
  139. {reconnect, boolean()} |
  140. {agencySlg, agencySlg()} |
  141. {backlogSize, backlogSize()} |
  142. {reConnTimeMin, pos_integer()} |
  143. {reConnTimeMax, pos_integer()}.
  144. -type dbCfgs() :: [dbCfg()].
  145. -type dbOpts() :: #dbOpts{}.
  146. -type agencyCfgs() :: [agencyCfg()].
  147. -type agencyOpts() :: #agencyOpts{}.