import asyncio

from asonic import Client
from asonic.enums import Channel


async def main():
  c = Client.create(
    host="127.0.0.1",
    port=1491,
    password="SecretPassword",
    max_connections=100
  )
  await client.channel(Channel.SEARCH)
  # To make these asserts give the right result, run the 'Ingest channel' example first
  assert (await c.query('collection', 'bucket', 'quick')) == [b'user_id']
  assert (await c.suggest('collection', 'bucket', 'br', 1)) == [b'brown']

if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main())

import asyncio

from asonic import Client
from asonic.enums import Channel


async def main():
  c = Client.create(
    host="127.0.0.1",
    port=1491,
    password="SecretPassword",
    max_connections=100
  )
  await c.channel(Channel.INGEST)
  await c.push('collection', 'bucket', 'user_id', 'The quick brown fox jumps over the lazy dog')
  # Return b'OK'
  await c.pop('collection', 'bucket', 'user_id', 'The')
  # Return 1

if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main())

import asyncio

from asonic import Client
from asonic.enums import Channel, Action


async def main():
  c = Client.create(
    host="127.0.0.1",
    port=1491,
    password="SecretPassword",
  )
  await c.channel(Channel.CONTROL)
  await c.trigger(Action.CONSOLIDATE)
  # Return b'OK'

if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main())