sample

package

v0.4.1 Latest Latest Go to latest Published: Sep 24, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Package sample provides a deterministic gRPC service for ingress experiments.

This section is empty.

This section is empty.

This section is empty.

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

Server serves sample gRPC requests and HTTP health checks on one listener.

func NewServer(grpcServer *grpc.Server, log *slog.Logger) *Server

NewServer constructs a sample server around a configured gRPC server.

func (s *Server) Serve(ctx context.Context, listener net.Listener) error

Serve accepts sample traffic until the context is cancelled or the server fails.

func (s *Server) ServeHTTP(writer http.ResponseWriter, request *http.Request)

ServeHTTP serves sample gRPC requests and health checks.

type Service struct {
	samplepb.UnimplementedUserServiceServer
	// contains filtered or unexported fields
}

Service serves a read-only snapshot loaded from ProtoJSON.

func New(data []byte) (*Service, error)

New loads sample users from a ProtoJSON ListUsersResponse.

func (s *Service) GetUser(ctx context.Context, request *samplepb.GetUserRequest) (*samplepb.GetUserResponse, error)

GetUser returns one sample user, or InvalidArgument or NotFound for an invalid ID.

func (s *Service) ListUsers(ctx context.Context, request *samplepb.ListUsersRequest) (*samplepb.ListUsersResponse, error)

ListUsers filters by IDs and optional role, preserving fixture order and its fixed timestamp.

Path	Synopsis
pb