Documentation
¶
Index ¶
- func NewGRPCServer(logger *slog.Logger) *grpc.Server
- type EventServer
- func New(logger *slog.Logger) *EventServer
- func NewWithPublisher(logger *slog.Logger, pub *publisher.NATSPublisher) *EventServer
- func RegisterServices(s *grpc.Server, logger *slog.Logger, _ interface{}) *EventServer
- func RegisterServicesWithPublisher(s *grpc.Server, logger *slog.Logger, _ interface{}, ...) *EventServer
- func (s *EventServer) Heartbeat(ctx context.Context, in *events.HeartbeatEventRequest) (*observer.AckResponse, error)
- func (s *EventServer) ReportRunEnd(ctx context.Context, in *events.TestRunEndEventRequest) (*observer.AckResponse, error)
- func (s *EventServer) ReportRunStart(ctx context.Context, in *events.ReportRunStartEventRequest) (*observer.AckResponse, error)
- func (s *EventServer) ReportStdError(ctx context.Context, in *events.StdErrorEventRequest) (*observer.AckResponse, error)
- func (s *EventServer) ReportStdOutput(ctx context.Context, in *events.StdOutputEventRequest) (*observer.AckResponse, error)
- func (s *EventServer) ReportStepBegin(ctx context.Context, in *events.StepBeginEventRequest) (*observer.AckResponse, error)
- func (s *EventServer) ReportStepEnd(ctx context.Context, in *events.StepEndEventRequest) (*observer.AckResponse, error)
- func (s *EventServer) ReportSuiteBegin(ctx context.Context, in *events.SuiteBeginEventRequest) (*observer.AckResponse, error)
- func (s *EventServer) ReportSuiteEnd(ctx context.Context, in *events.SuiteEndEventRequest) (*observer.AckResponse, error)
- func (s *EventServer) ReportTestBegin(ctx context.Context, in *events.TestBeginEventRequest) (*observer.AckResponse, error)
- func (s *EventServer) ReportTestEnd(ctx context.Context, in *events.TestEndEventRequest) (*observer.AckResponse, error)
- func (s *EventServer) ReportTestError(ctx context.Context, in *events.TestErrorEventRequest) (*observer.AckResponse, error)
- func (s *EventServer) ReportTestFailure(ctx context.Context, in *events.TestFailureEventRequest) (*observer.AckResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type EventServer ¶
type EventServer struct {
observer.UnimplementedTestEventCollectorServer
// contains filtered or unexported fields
}
func New ¶
func New(logger *slog.Logger) *EventServer
New returns a new EventServer. If logger is nil, a no-op logger is used.
func NewWithPublisher ¶
func NewWithPublisher(logger *slog.Logger, pub *publisher.NATSPublisher) *EventServer
NewWithPublisher returns a new EventServer with NATS publisher support. If logger is nil, a no-op logger is used. The publisher parameter is optional.
func RegisterServices ¶
func RegisterServices(s *grpc.Server, logger *slog.Logger, _ interface{}) *EventServer
RegisterServices registers the gRPC services without database or publisher. Kept for backward compatibility with ingestion service.
func RegisterServicesWithPublisher ¶
func RegisterServicesWithPublisher(s *grpc.Server, logger *slog.Logger, _ interface{}, pub *publisher.NATSPublisher) *EventServer
RegisterServicesWithPublisher registers the gRPC services with NATS publisher support.
func (*EventServer) Heartbeat ¶
func (s *EventServer) Heartbeat(ctx context.Context, in *events.HeartbeatEventRequest) (*observer.AckResponse, error)
func (*EventServer) ReportRunEnd ¶
func (s *EventServer) ReportRunEnd(ctx context.Context, in *events.TestRunEndEventRequest) (*observer.AckResponse, error)
func (*EventServer) ReportRunStart ¶
func (s *EventServer) ReportRunStart(ctx context.Context, in *events.ReportRunStartEventRequest) (*observer.AckResponse, error)
func (*EventServer) ReportStdError ¶
func (s *EventServer) ReportStdError(ctx context.Context, in *events.StdErrorEventRequest) (*observer.AckResponse, error)
func (*EventServer) ReportStdOutput ¶
func (s *EventServer) ReportStdOutput(ctx context.Context, in *events.StdOutputEventRequest) (*observer.AckResponse, error)
func (*EventServer) ReportStepBegin ¶
func (s *EventServer) ReportStepBegin(ctx context.Context, in *events.StepBeginEventRequest) (*observer.AckResponse, error)
func (*EventServer) ReportStepEnd ¶
func (s *EventServer) ReportStepEnd(ctx context.Context, in *events.StepEndEventRequest) (*observer.AckResponse, error)
func (*EventServer) ReportSuiteBegin ¶
func (s *EventServer) ReportSuiteBegin(ctx context.Context, in *events.SuiteBeginEventRequest) (*observer.AckResponse, error)
func (*EventServer) ReportSuiteEnd ¶
func (s *EventServer) ReportSuiteEnd(ctx context.Context, in *events.SuiteEndEventRequest) (*observer.AckResponse, error)
func (*EventServer) ReportTestBegin ¶
func (s *EventServer) ReportTestBegin(ctx context.Context, in *events.TestBeginEventRequest) (*observer.AckResponse, error)
func (*EventServer) ReportTestEnd ¶
func (s *EventServer) ReportTestEnd(ctx context.Context, in *events.TestEndEventRequest) (*observer.AckResponse, error)
func (*EventServer) ReportTestError ¶
func (s *EventServer) ReportTestError(ctx context.Context, in *events.TestErrorEventRequest) (*observer.AckResponse, error)
func (*EventServer) ReportTestFailure ¶
func (s *EventServer) ReportTestFailure(ctx context.Context, in *events.TestFailureEventRequest) (*observer.AckResponse, error)
Source Files
Click to show internal directories.
Click to hide internal directories.