Documentation
¶
Index ¶
- type Service
- func (s *Service) Clear()
- func (s *Service) Close() error
- func (s *Service) Count(ctx context.Context, bucketId uint64) (int64, error)
- func (s *Service) CountAll(ctx context.Context) (map[uint64]int64, error)
- func (s *Service) Find(ctx context.Context, data *dto.DataSelect) ([]domain.Data, error)
- func (s *Service) Shutdown()
- func (s *Service) Subscribe() (ch <-chan domain.Data, id uint64)
- func (s *Service) Unsubscribe(id uint64)
- func (s *Service) Write(ctx context.Context, data *domain.Data) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func New ¶
func New(stor ports.DataStorage, bucketService *bucket.Service, ps ports.PointService, _event *event.Subscriber) *Service
func (*Service) Unsubscribe ¶ added in v0.1.13
Source Files
Click to show internal directories.
Click to hide internal directories.