api

Documentation

Index

• type Service
  • func NewService() *Service
  • func (s *Service) AppendRecords(ctx context.Context, request *solaris.AppendRecordsRequest) (*solaris.AppendRecordsResult, error)
  • func (s *Service) CountRecords(ctx context.Context, request *solaris.QueryRecordsRequest) (*solaris.CountResult, error)
  • func (s *Service) CreateLog(ctx context.Context, log *solaris.Log) (*solaris.Log, error)
  • func (s *Service) DeleteLogs(ctx context.Context, request *solaris.DeleteLogsRequest) (*solaris.DeleteLogsResult, error)
  • func (s *Service) QueryLogs(ctx context.Context, request *solaris.QueryLogsRequest) (*solaris.QueryLogsResult, error)
  • func (s *Service) QueryRecords(ctx context.Context, request *solaris.QueryRecordsRequest) (*solaris.QueryRecordsResult, error)
  • func (s *Service) UpdateLog(ctx context.Context, log *solaris.Log) (*solaris.Log, error)

Types

type Service

type Service struct {
	solaris.UnimplementedServiceServer

	LogsStorage storage.Logs `inject:""`
	LogStorage  storage.Log  `inject:""`
	// contains filtered or unexported fields
}

Service implements the grpc public API (see solaris.ServiceServer)

func NewService

func NewService() *Service

func (*Service) AppendRecords

func (s *Service) AppendRecords(ctx context.Context, request *solaris.AppendRecordsRequest) (*solaris.AppendRecordsResult, error)

func (*Service) CountRecords

func (s *Service) CountRecords(ctx context.Context, request *solaris.QueryRecordsRequest) (*solaris.CountResult, error)

func (*Service) CreateLog

func (s *Service) CreateLog(ctx context.Context, log *solaris.Log) (*solaris.Log, error)

func (*Service) DeleteLogs

func (s *Service) DeleteLogs(ctx context.Context, request *solaris.DeleteLogsRequest) (*solaris.DeleteLogsResult, error)

func (*Service) QueryLogs

func (s *Service) QueryLogs(ctx context.Context, request *solaris.QueryLogsRequest) (*solaris.QueryLogsResult, error)

func (*Service) QueryRecords

func (s *Service) QueryRecords(ctx context.Context, request *solaris.QueryRecordsRequest) (*solaris.QueryRecordsResult, error)

func (*Service) UpdateLog

func (s *Service) UpdateLog(ctx context.Context, log *solaris.Log) (*solaris.Log, error)