mockpubsublite

Documentation

Index

• type MockService
  • func New(env *common.MockEnvironment, storage storage.Storage) *MockService
  • func (s *MockService) ExpectedHosts() []string
  • func (s *MockService) NewHTTPMux(ctx context.Context, conn *grpc.ClientConn) (http.Handler, error)
  • func (s *MockService) Register(grpcServer *grpc.Server)
• type PubSubLiteV1
  • func (s *PubSubLiteV1) CreateReservation(ctx context.Context, req *pb.CreateReservationRequest) (*pb.Reservation, error)
  • func (s *PubSubLiteV1) CreateSubscription(ctx context.Context, req *pb.CreateSubscriptionRequest) (*pb.Subscription, error)
  • func (s *PubSubLiteV1) CreateTopic(ctx context.Context, req *pb.CreateTopicRequest) (*pb.Topic, error)
  • func (s *PubSubLiteV1) DeleteReservation(ctx context.Context, req *pb.DeleteReservationRequest) (*emptypb.Empty, error)
  • func (s *PubSubLiteV1) DeleteSubscription(ctx context.Context, req *pb.DeleteSubscriptionRequest) (*emptypb.Empty, error)
  • func (s *PubSubLiteV1) DeleteTopic(ctx context.Context, req *pb.DeleteTopicRequest) (*emptypb.Empty, error)
  • func (s *PubSubLiteV1) GetReservation(ctx context.Context, req *pb.GetReservationRequest) (*pb.Reservation, error)
  • func (s *PubSubLiteV1) GetSubscription(ctx context.Context, req *pb.GetSubscriptionRequest) (*pb.Subscription, error)
  • func (s *PubSubLiteV1) GetTopic(ctx context.Context, req *pb.GetTopicRequest) (*pb.Topic, error)
  • func (s *PubSubLiteV1) UpdateReservation(ctx context.Context, req *pb.UpdateReservationRequest) (*pb.Reservation, error)
  • func (s *PubSubLiteV1) UpdateSubscription(ctx context.Context, req *pb.UpdateSubscriptionRequest) (*pb.Subscription, error)
  • func (s *PubSubLiteV1) UpdateTopic(ctx context.Context, req *pb.UpdateTopicRequest) (*pb.Topic, error)

Types

type MockService

type MockService struct {
	*common.MockEnvironment
	// contains filtered or unexported fields
}

MockService represents a mocked privateca service.

func New

func New(env *common.MockEnvironment, storage storage.Storage) *MockService

New creates a MockService.

func (*MockService) ExpectedHosts

func (s *MockService) ExpectedHosts() []string

func (*MockService) NewHTTPMux

func (s *MockService) NewHTTPMux(ctx context.Context, conn *grpc.ClientConn) (http.Handler, error)

func (*MockService) Register

func (s *MockService) Register(grpcServer *grpc.Server)

type PubSubLiteV1

type PubSubLiteV1 struct {
	*MockService
	pb.UnimplementedAdminServiceServer
}

func (*PubSubLiteV1) CreateReservation

func (s *PubSubLiteV1) CreateReservation(ctx context.Context, req *pb.CreateReservationRequest) (*pb.Reservation, error)

func (*PubSubLiteV1) CreateSubscription

func (s *PubSubLiteV1) CreateSubscription(ctx context.Context, req *pb.CreateSubscriptionRequest) (*pb.Subscription, error)

func (*PubSubLiteV1) CreateTopic

func (s *PubSubLiteV1) CreateTopic(ctx context.Context, req *pb.CreateTopicRequest) (*pb.Topic, error)

func (*PubSubLiteV1) DeleteReservation

func (s *PubSubLiteV1) DeleteReservation(ctx context.Context, req *pb.DeleteReservationRequest) (*emptypb.Empty, error)

func (*PubSubLiteV1) DeleteSubscription

func (s *PubSubLiteV1) DeleteSubscription(ctx context.Context, req *pb.DeleteSubscriptionRequest) (*emptypb.Empty, error)

func (*PubSubLiteV1) DeleteTopic

func (s *PubSubLiteV1) DeleteTopic(ctx context.Context, req *pb.DeleteTopicRequest) (*emptypb.Empty, error)

func (*PubSubLiteV1) GetReservation

func (s *PubSubLiteV1) GetReservation(ctx context.Context, req *pb.GetReservationRequest) (*pb.Reservation, error)

func (*PubSubLiteV1) GetSubscription

func (s *PubSubLiteV1) GetSubscription(ctx context.Context, req *pb.GetSubscriptionRequest) (*pb.Subscription, error)

func (*PubSubLiteV1) GetTopic

func (s *PubSubLiteV1) GetTopic(ctx context.Context, req *pb.GetTopicRequest) (*pb.Topic, error)

func (*PubSubLiteV1) UpdateReservation

func (s *PubSubLiteV1) UpdateReservation(ctx context.Context, req *pb.UpdateReservationRequest) (*pb.Reservation, error)

func (*PubSubLiteV1) UpdateSubscription

func (s *PubSubLiteV1) UpdateSubscription(ctx context.Context, req *pb.UpdateSubscriptionRequest) (*pb.Subscription, error)

func (*PubSubLiteV1) UpdateTopic

func (s *PubSubLiteV1) UpdateTopic(ctx context.Context, req *pb.UpdateTopicRequest) (*pb.Topic, error)