Documentation ¶
Index ¶
- Variables
- func RegisterFaultInjectorServer(s *grpc.Server, srv FaultInjectorServer)
- type EnumerateServicesRequest
- type EnumerateServicesResponse
- func (*EnumerateServicesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *EnumerateServicesResponse) GetServices() []*Service
- func (*EnumerateServicesResponse) ProtoMessage()
- func (x *EnumerateServicesResponse) ProtoReflect() protoreflect.Message
- func (x *EnumerateServicesResponse) Reset()
- func (x *EnumerateServicesResponse) String() string
- type FaultInjectorClient
- type FaultInjectorServer
- type FaultInjector_ListenClient
- type FaultInjector_ListenServer
- type ListenRequest
- func (*ListenRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListenRequest) GetMethod() string
- func (x *ListenRequest) GetService() string
- func (*ListenRequest) ProtoMessage()
- func (x *ListenRequest) ProtoReflect() protoreflect.Message
- func (x *ListenRequest) Reset()
- func (x *ListenRequest) String() string
- type ListenResponse
- func (*ListenResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListenResponse) GetError() string
- func (x *ListenResponse) GetReply() string
- func (x *ListenResponse) GetRequest() string
- func (*ListenResponse) ProtoMessage()
- func (x *ListenResponse) ProtoReflect() protoreflect.Message
- func (x *ListenResponse) Reset()
- func (x *ListenResponse) String() string
- type Method
- type RegisterFaultRequest
- func (*RegisterFaultRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterFaultRequest) GetExpression() string
- func (x *RegisterFaultRequest) GetMethod() string
- func (x *RegisterFaultRequest) GetService() string
- func (*RegisterFaultRequest) ProtoMessage()
- func (x *RegisterFaultRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterFaultRequest) Reset()
- func (x *RegisterFaultRequest) String() string
- type RegisterFaultResponse
- type RemoveFaultRequest
- func (*RemoveFaultRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveFaultRequest) GetMethod() string
- func (x *RemoveFaultRequest) GetService() string
- func (*RemoveFaultRequest) ProtoMessage()
- func (x *RemoveFaultRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveFaultRequest) Reset()
- func (x *RemoveFaultRequest) String() string
- type RemoveFaultResponse
- type Service
- type UnimplementedFaultInjectorServer
- func (*UnimplementedFaultInjectorServer) EnumerateServices(context.Context, *EnumerateServicesRequest) (*EnumerateServicesResponse, error)
- func (*UnimplementedFaultInjectorServer) Listen(*ListenRequest, FaultInjector_ListenServer) error
- func (*UnimplementedFaultInjectorServer) RegisterFault(context.Context, *RegisterFaultRequest) (*RegisterFaultResponse, error)
- func (*UnimplementedFaultInjectorServer) RemoveFault(context.Context, *RemoveFaultRequest) (*RemoveFaultResponse, error)
Constants ¶
This section is empty.
Variables ¶
var File_faultinjector_proto protoreflect.FileDescriptor
Functions ¶
func RegisterFaultInjectorServer ¶
func RegisterFaultInjectorServer(s *grpc.Server, srv FaultInjectorServer)
Types ¶
type EnumerateServicesRequest ¶
type EnumerateServicesRequest struct {
// contains filtered or unexported fields
}
func (*EnumerateServicesRequest) Descriptor
deprecated
func (*EnumerateServicesRequest) Descriptor() ([]byte, []int)
Deprecated: Use EnumerateServicesRequest.ProtoReflect.Descriptor instead.
func (*EnumerateServicesRequest) ProtoMessage ¶
func (*EnumerateServicesRequest) ProtoMessage()
func (*EnumerateServicesRequest) ProtoReflect ¶
func (x *EnumerateServicesRequest) ProtoReflect() protoreflect.Message
func (*EnumerateServicesRequest) Reset ¶
func (x *EnumerateServicesRequest) Reset()
func (*EnumerateServicesRequest) String ¶
func (x *EnumerateServicesRequest) String() string
type EnumerateServicesResponse ¶
type EnumerateServicesResponse struct { Services []*Service `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"` // contains filtered or unexported fields }
func (*EnumerateServicesResponse) Descriptor
deprecated
func (*EnumerateServicesResponse) Descriptor() ([]byte, []int)
Deprecated: Use EnumerateServicesResponse.ProtoReflect.Descriptor instead.
func (*EnumerateServicesResponse) GetServices ¶
func (x *EnumerateServicesResponse) GetServices() []*Service
func (*EnumerateServicesResponse) ProtoMessage ¶
func (*EnumerateServicesResponse) ProtoMessage()
func (*EnumerateServicesResponse) ProtoReflect ¶
func (x *EnumerateServicesResponse) ProtoReflect() protoreflect.Message
func (*EnumerateServicesResponse) Reset ¶
func (x *EnumerateServicesResponse) Reset()
func (*EnumerateServicesResponse) String ¶
func (x *EnumerateServicesResponse) String() string
type FaultInjectorClient ¶
type FaultInjectorClient interface { // Sends a greeting EnumerateServices(ctx context.Context, in *EnumerateServicesRequest, opts ...grpc.CallOption) (*EnumerateServicesResponse, error) RegisterFault(ctx context.Context, in *RegisterFaultRequest, opts ...grpc.CallOption) (*RegisterFaultResponse, error) RemoveFault(ctx context.Context, in *RemoveFaultRequest, opts ...grpc.CallOption) (*RemoveFaultResponse, error) Listen(ctx context.Context, in *ListenRequest, opts ...grpc.CallOption) (FaultInjector_ListenClient, error) }
FaultInjectorClient is the client API for FaultInjector service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewFaultInjectorClient ¶
func NewFaultInjectorClient(cc grpc.ClientConnInterface) FaultInjectorClient
type FaultInjectorServer ¶
type FaultInjectorServer interface { // Sends a greeting EnumerateServices(context.Context, *EnumerateServicesRequest) (*EnumerateServicesResponse, error) RegisterFault(context.Context, *RegisterFaultRequest) (*RegisterFaultResponse, error) RemoveFault(context.Context, *RemoveFaultRequest) (*RemoveFaultResponse, error) Listen(*ListenRequest, FaultInjector_ListenServer) error }
FaultInjectorServer is the server API for FaultInjector service.
type FaultInjector_ListenClient ¶
type FaultInjector_ListenClient interface { Recv() (*ListenResponse, error) grpc.ClientStream }
type FaultInjector_ListenServer ¶
type FaultInjector_ListenServer interface { Send(*ListenResponse) error grpc.ServerStream }
type ListenRequest ¶
type ListenRequest struct { Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"` // contains filtered or unexported fields }
func (*ListenRequest) Descriptor
deprecated
func (*ListenRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListenRequest.ProtoReflect.Descriptor instead.
func (*ListenRequest) GetMethod ¶
func (x *ListenRequest) GetMethod() string
func (*ListenRequest) GetService ¶
func (x *ListenRequest) GetService() string
func (*ListenRequest) ProtoMessage ¶
func (*ListenRequest) ProtoMessage()
func (*ListenRequest) ProtoReflect ¶
func (x *ListenRequest) ProtoReflect() protoreflect.Message
func (*ListenRequest) Reset ¶
func (x *ListenRequest) Reset()
func (*ListenRequest) String ¶
func (x *ListenRequest) String() string
type ListenResponse ¶
type ListenResponse struct { Request string `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` Reply string `protobuf:"bytes,2,opt,name=reply,proto3" json:"reply,omitempty"` Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*ListenResponse) Descriptor
deprecated
func (*ListenResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListenResponse.ProtoReflect.Descriptor instead.
func (*ListenResponse) GetError ¶
func (x *ListenResponse) GetError() string
func (*ListenResponse) GetReply ¶
func (x *ListenResponse) GetReply() string
func (*ListenResponse) GetRequest ¶
func (x *ListenResponse) GetRequest() string
func (*ListenResponse) ProtoMessage ¶
func (*ListenResponse) ProtoMessage()
func (*ListenResponse) ProtoReflect ¶
func (x *ListenResponse) ProtoReflect() protoreflect.Message
func (*ListenResponse) Reset ¶
func (x *ListenResponse) Reset()
func (*ListenResponse) String ¶
func (x *ListenResponse) String() string
type Method ¶
type Method struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Expression string `protobuf:"bytes,2,opt,name=expression,proto3" json:"expression,omitempty"` // contains filtered or unexported fields }
func (*Method) Descriptor
deprecated
func (*Method) GetExpression ¶
func (*Method) ProtoMessage ¶
func (*Method) ProtoMessage()
func (*Method) ProtoReflect ¶
func (x *Method) ProtoReflect() protoreflect.Message
type RegisterFaultRequest ¶
type RegisterFaultRequest struct { Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"` Expression string `protobuf:"bytes,3,opt,name=expression,proto3" json:"expression,omitempty"` // contains filtered or unexported fields }
func (*RegisterFaultRequest) Descriptor
deprecated
func (*RegisterFaultRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterFaultRequest.ProtoReflect.Descriptor instead.
func (*RegisterFaultRequest) GetExpression ¶
func (x *RegisterFaultRequest) GetExpression() string
func (*RegisterFaultRequest) GetMethod ¶
func (x *RegisterFaultRequest) GetMethod() string
func (*RegisterFaultRequest) GetService ¶
func (x *RegisterFaultRequest) GetService() string
func (*RegisterFaultRequest) ProtoMessage ¶
func (*RegisterFaultRequest) ProtoMessage()
func (*RegisterFaultRequest) ProtoReflect ¶
func (x *RegisterFaultRequest) ProtoReflect() protoreflect.Message
func (*RegisterFaultRequest) Reset ¶
func (x *RegisterFaultRequest) Reset()
func (*RegisterFaultRequest) String ¶
func (x *RegisterFaultRequest) String() string
type RegisterFaultResponse ¶
type RegisterFaultResponse struct {
// contains filtered or unexported fields
}
func (*RegisterFaultResponse) Descriptor
deprecated
func (*RegisterFaultResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterFaultResponse.ProtoReflect.Descriptor instead.
func (*RegisterFaultResponse) ProtoMessage ¶
func (*RegisterFaultResponse) ProtoMessage()
func (*RegisterFaultResponse) ProtoReflect ¶
func (x *RegisterFaultResponse) ProtoReflect() protoreflect.Message
func (*RegisterFaultResponse) Reset ¶
func (x *RegisterFaultResponse) Reset()
func (*RegisterFaultResponse) String ¶
func (x *RegisterFaultResponse) String() string
type RemoveFaultRequest ¶
type RemoveFaultRequest struct { Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"` // contains filtered or unexported fields }
func (*RemoveFaultRequest) Descriptor
deprecated
func (*RemoveFaultRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveFaultRequest.ProtoReflect.Descriptor instead.
func (*RemoveFaultRequest) GetMethod ¶
func (x *RemoveFaultRequest) GetMethod() string
func (*RemoveFaultRequest) GetService ¶
func (x *RemoveFaultRequest) GetService() string
func (*RemoveFaultRequest) ProtoMessage ¶
func (*RemoveFaultRequest) ProtoMessage()
func (*RemoveFaultRequest) ProtoReflect ¶
func (x *RemoveFaultRequest) ProtoReflect() protoreflect.Message
func (*RemoveFaultRequest) Reset ¶
func (x *RemoveFaultRequest) Reset()
func (*RemoveFaultRequest) String ¶
func (x *RemoveFaultRequest) String() string
type RemoveFaultResponse ¶
type RemoveFaultResponse struct {
// contains filtered or unexported fields
}
func (*RemoveFaultResponse) Descriptor
deprecated
func (*RemoveFaultResponse) Descriptor() ([]byte, []int)
Deprecated: Use RemoveFaultResponse.ProtoReflect.Descriptor instead.
func (*RemoveFaultResponse) ProtoMessage ¶
func (*RemoveFaultResponse) ProtoMessage()
func (*RemoveFaultResponse) ProtoReflect ¶
func (x *RemoveFaultResponse) ProtoReflect() protoreflect.Message
func (*RemoveFaultResponse) Reset ¶
func (x *RemoveFaultResponse) Reset()
func (*RemoveFaultResponse) String ¶
func (x *RemoveFaultResponse) String() string
type Service ¶
type Service struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Methods []*Method `protobuf:"bytes,2,rep,name=methods,proto3" json:"methods,omitempty"` // contains filtered or unexported fields }
func (*Service) Descriptor
deprecated
func (*Service) GetMethods ¶
func (*Service) ProtoMessage ¶
func (*Service) ProtoMessage()
func (*Service) ProtoReflect ¶
func (x *Service) ProtoReflect() protoreflect.Message
type UnimplementedFaultInjectorServer ¶
type UnimplementedFaultInjectorServer struct { }
UnimplementedFaultInjectorServer can be embedded to have forward compatible implementations.
func (*UnimplementedFaultInjectorServer) EnumerateServices ¶
func (*UnimplementedFaultInjectorServer) EnumerateServices(context.Context, *EnumerateServicesRequest) (*EnumerateServicesResponse, error)
func (*UnimplementedFaultInjectorServer) Listen ¶
func (*UnimplementedFaultInjectorServer) Listen(*ListenRequest, FaultInjector_ListenServer) error
func (*UnimplementedFaultInjectorServer) RegisterFault ¶
func (*UnimplementedFaultInjectorServer) RegisterFault(context.Context, *RegisterFaultRequest) (*RegisterFaultResponse, error)
func (*UnimplementedFaultInjectorServer) RemoveFault ¶
func (*UnimplementedFaultInjectorServer) RemoveFault(context.Context, *RemoveFaultRequest) (*RemoveFaultResponse, error)