seqdb

type Client interface {
	GetAggregation(context.Context, *seqapi.GetAggregationRequest) (*seqapi.GetAggregationResponse, error)
	GetEvent(context.Context, *seqapi.GetEventRequest) (*seqapi.GetEventResponse, error)
	GetFields(context.Context, *seqapi.GetFieldsRequest) (*seqapi.GetFieldsResponse, error)
	GetHistogram(context.Context, *seqapi.GetHistogramRequest) (*seqapi.GetHistogramResponse, error)
	Search(context.Context, *seqapi.SearchRequest) (*seqapi.SearchResponse, error)
	Status(context.Context, *seqapi.StatusRequest) (*seqapi.StatusResponse, error)
	Export(context.Context, *seqapi.ExportRequest, *httputil.ChunkedWriter) error
	StartAsyncSearch(context.Context, *seqapi.StartAsyncSearchRequest) (*seqapi.StartAsyncSearchResponse, error)
	FetchAsyncSearchResult(context.Context, *seqapi.FetchAsyncSearchResultRequest) (*seqapi.FetchAsyncSearchResultResponse, error)
	GetAsyncSearchesList(context.Context, *seqapi.GetAsyncSearchesListRequest, []string) (*seqapi.GetAsyncSearchesListResponse, error)
	CancelAsyncSearch(context.Context, *seqapi.CancelAsyncSearchRequest) (*seqapi.CancelAsyncSearchResponse, error)
	DeleteAsyncSearch(context.Context, *seqapi.DeleteAsyncSearchRequest) (*seqapi.DeleteAsyncSearchResponse, error)

	// masking
	WithMasking(m *mask.Masker)
}

type ClientParams struct {
	Addrs               []string
	Timeout             time.Duration
	MaxRetries          int
	InitialRetryBackoff time.Duration
	MaxRetryBackoff     time.Duration
	MaxRecvMsgSize      int
	GRPCKeepaliveParams *GRPCKeepaliveParams
}

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

type GRPCKeepaliveParams struct {
	Time                time.Duration
	Timeout             time.Duration
	PermitWithoutStream bool
}