mock

Documentation

Index

• type CAServer
  • func NewCAServerWithKeyCert(port int, key, cert []byte, opts ...grpc.ServerOption) (*CAServer, error)
  • func (s *CAServer) Check(ctx context.Context, in *ghc.HealthCheckRequest) (*ghc.HealthCheckResponse, error)
  • func (s *CAServer) CreateCertificate(ctx context.Context, request *pb.IstioCertificateRequest) (*pb.IstioCertificateResponse, error)
  • func (s *CAServer) RejectCSR(reject bool)
  • func (s *CAServer) SendEmptyCert()
  • func (s *CAServer) Watch(_ *ghc.HealthCheckRequest, _ ghc.Health_WatchServer) error

Types

type CAServer

type CAServer struct {
	pb.UnimplementedIstioCertificateServiceServer
	URL            string
	GRPCServer     *grpc.Server
	Authenticators []security.Authenticator

	KeyCertBundle *util.KeyCertBundle
	// contains filtered or unexported fields
}

CAServer is a mock CA server.

func NewCAServerWithKeyCert

func NewCAServerWithKeyCert(port int, key, cert []byte, opts ...grpc.ServerOption) (*CAServer, error)

func (*CAServer) Check

func (s *CAServer) Check(ctx context.Context, in *ghc.HealthCheckRequest) (*ghc.HealthCheckResponse, error)

Check handles health check requests.

func (*CAServer) CreateCertificate

func (s *CAServer) CreateCertificate(ctx context.Context, request *pb.IstioCertificateRequest) (
	*pb.IstioCertificateResponse, error,
)

CreateCertificate handles CSR.

func (*CAServer) RejectCSR

func (s *CAServer) RejectCSR(reject bool)

RejectCSR specifies whether to send error response to CSR.

func (*CAServer) SendEmptyCert

func (s *CAServer) SendEmptyCert()

SendEmptyCert force CA server send empty cert chain.

func (*CAServer) Watch

func (s *CAServer) Watch(_ *ghc.HealthCheckRequest, _ ghc.Health_WatchServer) error

Watch handles health check streams.