grpc

package
v0.0.0-...-98addd5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 30, 2017 License: MPL-2.0 Imports: 32 Imported by: 0

Documentation

Overview

Package wrappers wraps the GRPC calls in the core interfaces.

Package wrappers wraps the GRPC calls in the core interfaces.

Package wrappers wraps the GRPC calls in the core interfaces.

Package wrappers wraps the GRPC calls in the core interfaces.

Package wrappers wraps the GRPC calls in the core interfaces.

Index

Constants

View Source 
const (
	MalformedRequestError = iota + 100
	NotSupportedError
	UnauthorizedError
	NotFoundError
	LengthRequiredError
	SignatureValidationError
	RateLimitedError
	BadNonceError
	NoSuchRegistrationError
	InternalServerError
	ProblemDetails
)

gRPC error codes used by Boulder. While the gRPC codes end at 16 we start at 100 to provide a little leeway in case they ever decide to add more TODO(#2507): Deprecated, remove once boulder/errors code is deployed

Variables

View Source 
var CodedError = grpc.Errorf

CodedError is a alias required to appease go vet

View Source 
var ErrMissingParameters = CodedError(codes.FailedPrecondition, "required RPC parameter was missing")

Functions

func ClientSetup 

func ClientSetup(c *cmd.GRPCClientConfig, tls *tls.Config, stats metrics.Scope) (*grpc.ClientConn, error)

ClientSetup creates a gRPC TransportCredentials that presents a client certificate and validates the the server certificate based on the provided *tls.Config. It dials the remote service and returns a grpc.ClientConn if successful.

func NewServer 

func NewServer(c *cmd.GRPCServerConfig, tls *tls.Config, stats metrics.Scope) (*grpc.Server, net.Listener, error)

NewServer creates a gRPC server that uses the provided *tls.Config, and verifies that clients present a certificate that (a) is signed by one of the configured ClientCAs, and (b) contains at least one subjectAlternativeName matching the accepted list from GRPCServerConfig.

func NewValidationAuthorityGRPCClient 

func NewValidationAuthorityGRPCClient(cc *ggrpc.ClientConn) core.ValidationAuthority

func RegisterValidationAuthorityGRPCServer 

func RegisterValidationAuthorityGRPCServer(s *ggrpc.Server, impl core.ValidationAuthority) error

Types

type CertificateAuthorityClientWrapper 

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

CertificateAuthorityClientWrapper is the gRPC version of a core.CertificateAuthority client. It composites a CertificateAuthorityClient and OCSPGeneratorClient, either of which may be nil if the calling code doesn't intend to use the relevant functions. Once we've fully moved to gRPC, calling code will do away with this wrapper and directly instantiate exactly the type of client it needs.

func NewCertificateAuthorityClient 

func NewCertificateAuthorityClient(inner caPB.CertificateAuthorityClient, innerOCSP caPB.OCSPGeneratorClient) *CertificateAuthorityClientWrapper

func (CertificateAuthorityClientWrapper) GenerateOCSP 

func (cac CertificateAuthorityClientWrapper) GenerateOCSP(ctx context.Context, ocspReq core.OCSPSigningRequest) ([]byte, error)

func (CertificateAuthorityClientWrapper) IssueCertificate 

func (cac CertificateAuthorityClientWrapper) IssueCertificate(ctx context.Context, csr x509.CertificateRequest, regID int64) (core.Certificate, error)

type CertificateAuthorityServerWrapper 

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

CertificateAuthorityServerWrapper is the gRPC version of a core.CertificateAuthority server

func NewCertificateAuthorityServer 

func NewCertificateAuthorityServer(inner core.CertificateAuthority) *CertificateAuthorityServerWrapper

func (*CertificateAuthorityServerWrapper) GenerateOCSP 

func (cas *CertificateAuthorityServerWrapper) GenerateOCSP(ctx context.Context, request *caPB.GenerateOCSPRequest) (*caPB.OCSPResponse, error)

func (*CertificateAuthorityServerWrapper) IssueCertificate 

func (cas *CertificateAuthorityServerWrapper) IssueCertificate(ctx context.Context, request *caPB.IssueCertificateRequest) (*corepb.Certificate, error)

type PublisherClientWrapper 

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

PublisherClientWrapper is a wrapper needed to satisfy the interfaces in core/interfaces.go

func NewPublisherClientWrapper 

func NewPublisherClientWrapper(inner pubPB.PublisherClient) *PublisherClientWrapper

NewPublisherClientWrapper returns an initialized PublisherClientWrapper

func (*PublisherClientWrapper) SubmitToCT 

func (pc *PublisherClientWrapper) SubmitToCT(ctx context.Context, der []byte) error

SubmitToCT makes a call to the gRPC version of the publisher

func (*PublisherClientWrapper) SubmitToSingleCT 

func (pc *PublisherClientWrapper) SubmitToSingleCT(ctx context.Context, logURL, logPublicKey string, der []byte) error

SubmitToSingleCT makes a call to the gRPC version of the publisher to send the provided certificate to the log specified by log URI and public key

type PublisherServerWrapper 

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

PublisherServerWrapper is a wrapper required to bridge the differences between the gRPC and previous AMQP interfaces

func NewPublisherServerWrapper 

func NewPublisherServerWrapper(inner *publisher.Impl) *PublisherServerWrapper

NewPublisherServerWrapper returns an initialized PublisherServerWrapper

func (*PublisherServerWrapper) SubmitToCT 

func (pub *PublisherServerWrapper) SubmitToCT(ctx context.Context, request *pubPB.Request) (*pubPB.Empty, error)

SubmitToCT calls the same method on the wrapped publisher.Impl since their interfaces are different

func (*PublisherServerWrapper) SubmitToSingleCT 

func (pub *PublisherServerWrapper) SubmitToSingleCT(ctx context.Context, request *pubPB.Request) (*pubPB.Empty, error)

type RegistrationAuthorityClientWrapper 

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

RegistrationAuthorityClientWrapper is the gRPC version of a core.RegistrationAuthority client

func NewRegistrationAuthorityClient 

func NewRegistrationAuthorityClient(inner rapb.RegistrationAuthorityClient) *RegistrationAuthorityClientWrapper

func (RegistrationAuthorityClientWrapper) AdministrativelyRevokeCertificate 

func (rac RegistrationAuthorityClientWrapper) AdministrativelyRevokeCertificate(ctx context.Context, cert x509.Certificate, code revocation.Reason, adminName string) error

func (RegistrationAuthorityClientWrapper) DeactivateAuthorization 

func (rac RegistrationAuthorityClientWrapper) DeactivateAuthorization(ctx context.Context, auth core.Authorization) error

func (RegistrationAuthorityClientWrapper) DeactivateRegistration 

func (rac RegistrationAuthorityClientWrapper) DeactivateRegistration(ctx context.Context, reg core.Registration) error

func (RegistrationAuthorityClientWrapper) NewAuthorization 

func (rac RegistrationAuthorityClientWrapper) NewAuthorization(ctx context.Context, authz core.Authorization, regID int64) (core.Authorization, error)

func (RegistrationAuthorityClientWrapper) NewCertificate 

func (rac RegistrationAuthorityClientWrapper) NewCertificate(ctx context.Context, csr core.CertificateRequest, regID int64) (core.Certificate, error)

func (RegistrationAuthorityClientWrapper) NewRegistration 

func (rac RegistrationAuthorityClientWrapper) NewRegistration(ctx context.Context, reg core.Registration) (core.Registration, error)

func (RegistrationAuthorityClientWrapper) RevokeCertificateWithReg 

func (rac RegistrationAuthorityClientWrapper) RevokeCertificateWithReg(ctx context.Context, cert x509.Certificate, code revocation.Reason, regID int64) error

func (RegistrationAuthorityClientWrapper) UpdateAuthorization 

func (rac RegistrationAuthorityClientWrapper) UpdateAuthorization(ctx context.Context, authz core.Authorization, challengeIndex int, chall core.Challenge) (core.Authorization, error)

func (RegistrationAuthorityClientWrapper) UpdateRegistration 

func (rac RegistrationAuthorityClientWrapper) UpdateRegistration(ctx context.Context, base, updates core.Registration) (core.Registration, error)

type RegistrationAuthorityServerWrapper 

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

RegistrationAuthorityServerWrapper is the gRPC version of a core.RegistrationAuthority server

func NewRegistrationAuthorityServer 

func NewRegistrationAuthorityServer(inner core.RegistrationAuthority) *RegistrationAuthorityServerWrapper

func (*RegistrationAuthorityServerWrapper) AdministrativelyRevokeCertificate 

func (ras *RegistrationAuthorityServerWrapper) AdministrativelyRevokeCertificate(ctx context.Context, request *rapb.AdministrativelyRevokeCertificateRequest) (*corepb.Empty, error)

func (*RegistrationAuthorityServerWrapper) DeactivateAuthorization 

func (ras *RegistrationAuthorityServerWrapper) DeactivateAuthorization(ctx context.Context, request *corepb.Authorization) (*corepb.Empty, error)

func (*RegistrationAuthorityServerWrapper) DeactivateRegistration 

func (ras *RegistrationAuthorityServerWrapper) DeactivateRegistration(ctx context.Context, request *corepb.Registration) (*corepb.Empty, error)

func (*RegistrationAuthorityServerWrapper) NewAuthorization 

func (ras *RegistrationAuthorityServerWrapper) NewAuthorization(ctx context.Context, request *rapb.NewAuthorizationRequest) (*corepb.Authorization, error)

func (*RegistrationAuthorityServerWrapper) NewCertificate 

func (ras *RegistrationAuthorityServerWrapper) NewCertificate(ctx context.Context, request *rapb.NewCertificateRequest) (*corepb.Certificate, error)

func (*RegistrationAuthorityServerWrapper) NewRegistration 

func (ras *RegistrationAuthorityServerWrapper) NewRegistration(ctx context.Context, request *corepb.Registration) (*corepb.Registration, error)

func (*RegistrationAuthorityServerWrapper) RevokeCertificateWithReg 

func (ras *RegistrationAuthorityServerWrapper) RevokeCertificateWithReg(ctx context.Context, request *rapb.RevokeCertificateWithRegRequest) (*corepb.Empty, error)

func (*RegistrationAuthorityServerWrapper) UpdateAuthorization 

func (ras *RegistrationAuthorityServerWrapper) UpdateAuthorization(ctx context.Context, request *rapb.UpdateAuthorizationRequest) (*corepb.Authorization, error)

func (*RegistrationAuthorityServerWrapper) UpdateRegistration 

func (ras *RegistrationAuthorityServerWrapper) UpdateRegistration(ctx context.Context, request *rapb.UpdateRegistrationRequest) (*corepb.Registration, error)

type StorageAuthorityClientWrapper 

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

StorageAuthorityClientWrapper is the gRPC version of a core.StorageAuthority client

func NewStorageAuthorityClient 

func NewStorageAuthorityClient(inner sapb.StorageAuthorityClient) *StorageAuthorityClientWrapper

func (StorageAuthorityClientWrapper) AddCertificate 

func (sac StorageAuthorityClientWrapper) AddCertificate(ctx context.Context, der []byte, regID int64) (string, error)

func (StorageAuthorityClientWrapper) AddSCTReceipt 

func (sac StorageAuthorityClientWrapper) AddSCTReceipt(ctx context.Context, sct core.SignedCertificateTimestamp) error

func (StorageAuthorityClientWrapper) CountCertificatesByNames 

func (sac StorageAuthorityClientWrapper) CountCertificatesByNames(ctx context.Context, domains []string, earliest, latest time.Time) (map[string]int, error)

func (StorageAuthorityClientWrapper) CountCertificatesRange 

func (sac StorageAuthorityClientWrapper) CountCertificatesRange(ctx context.Context, earliest, latest time.Time) (int64, error)

func (StorageAuthorityClientWrapper) CountFQDNSets 

func (sac StorageAuthorityClientWrapper) CountFQDNSets(ctx context.Context, window time.Duration, domains []string) (int64, error)

func (StorageAuthorityClientWrapper) CountInvalidAuthorizations 

func (sac StorageAuthorityClientWrapper) CountInvalidAuthorizations(ctx context.Context, request *sapb.CountInvalidAuthorizationsRequest) (*sapb.Count, error)

func (StorageAuthorityClientWrapper) CountPendingAuthorizations 

func (sac StorageAuthorityClientWrapper) CountPendingAuthorizations(ctx context.Context, regID int64) (int, error)

func (StorageAuthorityClientWrapper) CountRegistrationsByIP 

func (sac StorageAuthorityClientWrapper) CountRegistrationsByIP(ctx context.Context, ip net.IP, earliest, latest time.Time) (int, error)

func (StorageAuthorityClientWrapper) DeactivateAuthorization 

func (sac StorageAuthorityClientWrapper) DeactivateAuthorization(ctx context.Context, id string) error

func (StorageAuthorityClientWrapper) DeactivateRegistration 

func (sac StorageAuthorityClientWrapper) DeactivateRegistration(ctx context.Context, id int64) error

func (StorageAuthorityClientWrapper) FQDNSetExists 

func (sac StorageAuthorityClientWrapper) FQDNSetExists(ctx context.Context, domains []string) (bool, error)

func (StorageAuthorityClientWrapper) FinalizeAuthorization 

func (sac StorageAuthorityClientWrapper) FinalizeAuthorization(ctx context.Context, authz core.Authorization) error

func (StorageAuthorityClientWrapper) GetAuthorization 

func (sac StorageAuthorityClientWrapper) GetAuthorization(ctx context.Context, authID string) (core.Authorization, error)

func (StorageAuthorityClientWrapper) GetCertificate 

func (sac StorageAuthorityClientWrapper) GetCertificate(ctx context.Context, serial string) (core.Certificate, error)

func (StorageAuthorityClientWrapper) GetCertificateStatus 

func (sac StorageAuthorityClientWrapper) GetCertificateStatus(ctx context.Context, serial string) (core.CertificateStatus, error)

func (StorageAuthorityClientWrapper) GetRegistration 

func (sac StorageAuthorityClientWrapper) GetRegistration(ctx context.Context, regID int64) (core.Registration, error)

func (StorageAuthorityClientWrapper) GetRegistrationByKey 

func (sac StorageAuthorityClientWrapper) GetRegistrationByKey(ctx context.Context, key *jose.JsonWebKey) (core.Registration, error)

func (StorageAuthorityClientWrapper) GetSCTReceipt 

func (sac StorageAuthorityClientWrapper) GetSCTReceipt(ctx context.Context, serial, logID string) (core.SignedCertificateTimestamp, error)

func (StorageAuthorityClientWrapper) GetValidAuthorizations 

func (sac StorageAuthorityClientWrapper) GetValidAuthorizations(ctx context.Context, regID int64, domains []string, now time.Time) (map[string]*core.Authorization, error)

func (StorageAuthorityClientWrapper) MarkCertificateRevoked 

func (sac StorageAuthorityClientWrapper) MarkCertificateRevoked(ctx context.Context, serial string, reasonCode revocation.Reason) error

func (StorageAuthorityClientWrapper) NewPendingAuthorization 

func (sac StorageAuthorityClientWrapper) NewPendingAuthorization(ctx context.Context, authz core.Authorization) (core.Authorization, error)

func (StorageAuthorityClientWrapper) NewRegistration 

func (sac StorageAuthorityClientWrapper) NewRegistration(ctx context.Context, reg core.Registration) (core.Registration, error)

func (StorageAuthorityClientWrapper) RevokeAuthorizationsByDomain 

func (sac StorageAuthorityClientWrapper) RevokeAuthorizationsByDomain(ctx context.Context, domain core.AcmeIdentifier) (int64, int64, error)

func (StorageAuthorityClientWrapper) UpdatePendingAuthorization 

func (sac StorageAuthorityClientWrapper) UpdatePendingAuthorization(ctx context.Context, authz core.Authorization) error

func (StorageAuthorityClientWrapper) UpdateRegistration 

func (sac StorageAuthorityClientWrapper) UpdateRegistration(ctx context.Context, reg core.Registration) error

type StorageAuthorityServerWrapper 

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

StorageAuthorityServerWrapper is the gRPC version of a core.ServerAuthority server

func NewStorageAuthorityServer 

func NewStorageAuthorityServer(inner *sa.SQLStorageAuthority) *StorageAuthorityServerWrapper

func (StorageAuthorityServerWrapper) AddCertificate 

func (sas StorageAuthorityServerWrapper) AddCertificate(ctx context.Context, request *sapb.AddCertificateRequest) (*sapb.AddCertificateResponse, error)

func (StorageAuthorityServerWrapper) AddSCTReceipt 

func (sas StorageAuthorityServerWrapper) AddSCTReceipt(ctx context.Context, request *sapb.SignedCertificateTimestamp) (*corepb.Empty, error)

func (StorageAuthorityServerWrapper) CountCertificatesByNames 

func (sas StorageAuthorityServerWrapper) CountCertificatesByNames(ctx context.Context, request *sapb.CountCertificatesByNamesRequest) (*sapb.CountByNames, error)

func (StorageAuthorityServerWrapper) CountCertificatesRange 

func (sas StorageAuthorityServerWrapper) CountCertificatesRange(ctx context.Context, request *sapb.Range) (*sapb.Count, error)

func (StorageAuthorityServerWrapper) CountFQDNSets 

func (sas StorageAuthorityServerWrapper) CountFQDNSets(ctx context.Context, request *sapb.CountFQDNSetsRequest) (*sapb.Count, error)

func (StorageAuthorityServerWrapper) CountInvalidAuthorizations 

func (sas StorageAuthorityServerWrapper) CountInvalidAuthorizations(ctx context.Context, request *sapb.CountInvalidAuthorizationsRequest) (*sapb.Count, error)

func (StorageAuthorityServerWrapper) CountPendingAuthorizations 

func (sas StorageAuthorityServerWrapper) CountPendingAuthorizations(ctx context.Context, request *sapb.RegistrationID) (*sapb.Count, error)

func (StorageAuthorityServerWrapper) CountRegistrationsByIP 

func (sas StorageAuthorityServerWrapper) CountRegistrationsByIP(ctx context.Context, request *sapb.CountRegistrationsByIPRequest) (*sapb.Count, error)

func (StorageAuthorityServerWrapper) DeactivateAuthorization 

func (sas StorageAuthorityServerWrapper) DeactivateAuthorization(ctx context.Context, request *sapb.AuthorizationID) (*corepb.Empty, error)

func (StorageAuthorityServerWrapper) DeactivateRegistration 

func (sas StorageAuthorityServerWrapper) DeactivateRegistration(ctx context.Context, request *sapb.RegistrationID) (*corepb.Empty, error)

func (StorageAuthorityServerWrapper) FQDNSetExists 

func (sas StorageAuthorityServerWrapper) FQDNSetExists(ctx context.Context, request *sapb.FQDNSetExistsRequest) (*sapb.Exists, error)

func (StorageAuthorityServerWrapper) FinalizeAuthorization 

func (sas StorageAuthorityServerWrapper) FinalizeAuthorization(ctx context.Context, request *corepb.Authorization) (*corepb.Empty, error)

func (StorageAuthorityServerWrapper) GetAuthorization 

func (sas StorageAuthorityServerWrapper) GetAuthorization(ctx context.Context, request *sapb.AuthorizationID) (*corepb.Authorization, error)

func (StorageAuthorityServerWrapper) GetCertificate 

func (sas StorageAuthorityServerWrapper) GetCertificate(ctx context.Context, request *sapb.Serial) (*corepb.Certificate, error)

func (StorageAuthorityServerWrapper) GetCertificateStatus 

func (sas StorageAuthorityServerWrapper) GetCertificateStatus(ctx context.Context, request *sapb.Serial) (*sapb.CertificateStatus, error)

func (StorageAuthorityServerWrapper) GetRegistration 

func (sas StorageAuthorityServerWrapper) GetRegistration(ctx context.Context, request *sapb.RegistrationID) (*corepb.Registration, error)

func (StorageAuthorityServerWrapper) GetRegistrationByKey 

func (sas StorageAuthorityServerWrapper) GetRegistrationByKey(ctx context.Context, request *sapb.JsonWebKey) (*corepb.Registration, error)

func (StorageAuthorityServerWrapper) GetSCTReceipt 

func (sas StorageAuthorityServerWrapper) GetSCTReceipt(ctx context.Context, request *sapb.GetSCTReceiptRequest) (*sapb.SignedCertificateTimestamp, error)

func (StorageAuthorityServerWrapper) GetValidAuthorizations 

func (sas StorageAuthorityServerWrapper) GetValidAuthorizations(ctx context.Context, request *sapb.GetValidAuthorizationsRequest) (*sapb.ValidAuthorizations, error)

func (StorageAuthorityServerWrapper) MarkCertificateRevoked 

func (sas StorageAuthorityServerWrapper) MarkCertificateRevoked(ctx context.Context, request *sapb.MarkCertificateRevokedRequest) (*corepb.Empty, error)

func (StorageAuthorityServerWrapper) NewPendingAuthorization 

func (sas StorageAuthorityServerWrapper) NewPendingAuthorization(ctx context.Context, request *corepb.Authorization) (*corepb.Authorization, error)

func (StorageAuthorityServerWrapper) NewRegistration 

func (sas StorageAuthorityServerWrapper) NewRegistration(ctx context.Context, request *corepb.Registration) (*corepb.Registration, error)

func (StorageAuthorityServerWrapper) RevokeAuthorizationsByDomain 

func (sas StorageAuthorityServerWrapper) RevokeAuthorizationsByDomain(ctx context.Context, request *sapb.RevokeAuthorizationsByDomainRequest) (*sapb.RevokeAuthorizationsByDomainResponse, error)

func (StorageAuthorityServerWrapper) UpdatePendingAuthorization 

func (sas StorageAuthorityServerWrapper) UpdatePendingAuthorization(ctx context.Context, request *corepb.Authorization) (*corepb.Empty, error)

func (StorageAuthorityServerWrapper) UpdateRegistration 

func (sas StorageAuthorityServerWrapper) UpdateRegistration(ctx context.Context, request *corepb.Registration) (*corepb.Empty, error)

type ValidationAuthorityGRPCClient 

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

func (ValidationAuthorityGRPCClient) IsSafeDomain 

func (vac ValidationAuthorityGRPCClient) IsSafeDomain(ctx context.Context, req *vaPB.IsSafeDomainRequest) (*vaPB.IsDomainSafe, error)

IsSafeDomain returns true if the domain given is determined to be safe by an third-party safe browsing API.

func (ValidationAuthorityGRPCClient) PerformValidation 

func (vac ValidationAuthorityGRPCClient) PerformValidation(ctx context.Context, domain string, challenge core.Challenge, authz core.Authorization) ([]core.ValidationRecord, error)

PerformValidation has the VA revalidate the specified challenge and returns the updated Challenge object.

type ValidationAuthorityGRPCServer 

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

func (*ValidationAuthorityGRPCServer) IsSafeDomain 

func (s *ValidationAuthorityGRPCServer) IsSafeDomain(ctx context.Context, in *vaPB.IsSafeDomainRequest) (*vaPB.IsDomainSafe, error)

func (*ValidationAuthorityGRPCServer) PerformValidation 

func (s *ValidationAuthorityGRPCServer) PerformValidation(ctx context.Context, in *vaPB.PerformValidationRequest) (*vaPB.ValidationResult, error)

Source Files

View all Source files

Directories

Path Synopsis
Package test_proto is a generated protocol buffer package.
 Package test_proto is a generated protocol buffer package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.