Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterInjureServer

func RegisterInjureServer(s *grpc.Server, srv InjureServer)

Types

type InjureClient

type InjureClient interface {
	Methods(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Response, error)
	RecoverAll(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	RecoverMethod(ctx context.Context, in *Request, opts ...grpc.CallOption) (*empty.Empty, error)
	SetFault(ctx context.Context, in *Request, opts ...grpc.CallOption) (*empty.Empty, error)
	SetFaultAll(ctx context.Context, in *Request, opts ...grpc.CallOption) (*empty.Empty, error)
}

    InjureClient is the client API for Injure service.

    For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

    func NewInjureClient

    func NewInjureClient(cc *grpc.ClientConn) InjureClient

    type InjureServer

    type InjureServer interface {
    	Methods(context.Context, *empty.Empty) (*Response, error)
    	RecoverAll(context.Context, *empty.Empty) (*empty.Empty, error)
    	RecoverMethod(context.Context, *Request) (*empty.Empty, error)
    	SetFault(context.Context, *Request) (*empty.Empty, error)
    	SetFaultAll(context.Context, *Request) (*empty.Empty, error)
    }

      InjureServer is the server API for Injure service.

      type Request

      type Request struct {
      	Methods              []string `protobuf:"bytes,1,rep,name=methods,proto3" json:"methods,omitempty"`
      	Errno                uint32   `protobuf:"varint,2,opt,name=errno,proto3" json:"errno,omitempty"`
      	Random               bool     `protobuf:"varint,3,opt,name=random,proto3" json:"random,omitempty"`
      	Pct                  uint32   `protobuf:"varint,4,opt,name=pct,proto3" json:"pct,omitempty"`
      	Path                 string   `protobuf:"bytes,5,opt,name=path,proto3" json:"path,omitempty"`
      	Delay                uint32   `protobuf:"varint,6,opt,name=delay,proto3" json:"delay,omitempty"`
      	XXX_NoUnkeyedLiteral struct{} `json:"-"`
      	XXX_unrecognized     []byte   `json:"-"`
      	XXX_sizecache        int32    `json:"-"`
      }

      func (*Request) Descriptor

      func (*Request) Descriptor() ([]byte, []int)

      func (*Request) GetDelay

      func (m *Request) GetDelay() uint32

      func (*Request) GetErrno

      func (m *Request) GetErrno() uint32

      func (*Request) GetMethods

      func (m *Request) GetMethods() []string

      func (*Request) GetPath

      func (m *Request) GetPath() string

      func (*Request) GetPct

      func (m *Request) GetPct() uint32

      func (*Request) GetRandom

      func (m *Request) GetRandom() bool

      func (*Request) ProtoMessage

      func (*Request) ProtoMessage()

      func (*Request) Reset

      func (m *Request) Reset()

      func (*Request) String

      func (m *Request) String() string

      func (*Request) XXX_DiscardUnknown

      func (m *Request) XXX_DiscardUnknown()

      func (*Request) XXX_Marshal

      func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*Request) XXX_Merge

      func (dst *Request) XXX_Merge(src proto.Message)

      func (*Request) XXX_Size

      func (m *Request) XXX_Size() int

      func (*Request) XXX_Unmarshal

      func (m *Request) XXX_Unmarshal(b []byte) error

      type Response

      type Response struct {
      	Methods              []string `protobuf:"bytes,1,rep,name=methods,proto3" json:"methods,omitempty"`
      	XXX_NoUnkeyedLiteral struct{} `json:"-"`
      	XXX_unrecognized     []byte   `json:"-"`
      	XXX_sizecache        int32    `json:"-"`
      }

      func (*Response) Descriptor

      func (*Response) Descriptor() ([]byte, []int)

      func (*Response) GetMethods

      func (m *Response) GetMethods() []string

      func (*Response) ProtoMessage

      func (*Response) ProtoMessage()

      func (*Response) Reset

      func (m *Response) Reset()

      func (*Response) String

      func (m *Response) String() string

      func (*Response) XXX_DiscardUnknown

      func (m *Response) XXX_DiscardUnknown()

      func (*Response) XXX_Marshal

      func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*Response) XXX_Merge

      func (dst *Response) XXX_Merge(src proto.Message)

      func (*Response) XXX_Size

      func (m *Response) XXX_Size() int

      func (*Response) XXX_Unmarshal

      func (m *Response) XXX_Unmarshal(b []byte) error

      Source Files