using System;
using System.Collections.Generic;
using System.Threading.Tasks;

namespace Pole.Core.Abstractions
{
    public interface IObserverUnit<PrimaryKey> : IGrainID
    {
        /// <summary>
        /// 获取所有监听者分组
        /// </summary>
        /// <returns></returns>
        List<string> GetGroups();
        Task<long[]> GetAndSaveVersion(PrimaryKey primaryKey, long srcVersion);
        /// <summary>
        /// 重置Grain
        /// </summary>
        /// <param name="primaryKey">重置Grain</param>
        /// <returns></returns>
        Task Reset(PrimaryKey primaryKey);
        List<Func<byte[], Task>> GetEventHandlers(string observerGroup);
        List<Func<byte[], Task>> GetAllEventHandlers();
        List<Func<List<byte[]>, Task>> GetBatchEventHandlers(string observerGroup);
        List<Func<List<byte[]>, Task>> GetAllBatchEventHandlers();
    }
}