Documentation ¶
Index ¶
- Variables
- type BidiStream
- type ClientStream
- type Enum
- type EnumField
- type EnumValue
- type Env
- func (e *Env) AddHeader(h *Header)
- func (e *Env) DSN() string
- func (e *Env) HasCurrentPackage() bool
- func (e *Env) HasCurrentService() bool
- func (e *Env) Headers() (headers []*Header)
- func (e *Env) Message(name string) (Message, error)
- func (e *Env) Messages() ([]Message, error)
- func (e *Env) Packages() []*Package
- func (e *Env) RPC(name string) (RPC, error)
- func (e *Env) RPCs() ([]RPC, error)
- func (e *Env) RemoveHeader(key string)
- func (e *Env) Service(name string) (Service, error)
- func (e *Env) Services() ([]Service, error)
- func (e *Env) UsePackage(name string) error
- func (e *Env) UseService(name string) error
- type Environment
- type Field
- type FieldType
- type GRPCClient
- type Header
- type Message
- type MessageField
- type OneOfField
- type Package
- type Parser
- type PrimitiveField
- type RPC
- type ServerStream
- type Service
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrPackageUnselected = errors.New("package unselected") ErrServiceUnselected = errors.New("service unselected") ErrUnknownPackage = errors.New("unknown package") ErrUnknownService = errors.New("unknown service") ErrInvalidServiceName = errors.New("invalid service name") ErrInvalidMessageName = errors.New("invalid message name") ErrInvalidRPCName = errors.New("invalid RPC name") )
Functions ¶
This section is empty.
Types ¶
type BidiStream ¶
type ClientStream ¶
type Env ¶
type Env struct {
// contains filtered or unexported fields
}
func NewEnvFromServices ¶
NewEnvFromServices is called if the target server has enabled gRPC reflection. gRPC reflection has no packages, so Evans creates pseudo package "default".
func (*Env) HasCurrentPackage ¶
func (*Env) HasCurrentService ¶
func (*Env) RemoveHeader ¶
func (*Env) UsePackage ¶
func (*Env) UseService ¶
type Environment ¶
type Environment interface { Packages() []*Package Services() ([]Service, error) Messages() ([]Message, error) RPCs() ([]RPC, error) Service(name string) (Service, error) Message(name string) (Message, error) RPC(name string) (RPC, error) Headers() []*Header AddHeader(header *Header) RemoveHeader(key string) UsePackage(name string) error UseService(name string) error DSN() string }
type Field ¶
type Field interface { FieldName() string FQRN() string Type() FieldType IsRepeated() bool // *desc.FieldDescriptor.GetType().String() // used only from port.Showable PBType() string }
Field represents base field features. fieldable types:
enum, oneof, message, primitive
type GRPCClient ¶
type GRPCClient interface { Invoke(ctx context.Context, fqrn string, req, res interface{}) error NewClientStream(ctx context.Context, rpc RPC) (ClientStream, error) NewServerStream(ctx context.Context, rpc RPC) (ServerStream, error) NewBidiStream(ctx context.Context, rpc RPC) (BidiStream, error) Close(ctx context.Context) error }
type MessageField ¶
type OneOfField ¶
type PrimitiveField ¶
type PrimitiveField interface { Field }
type RPC ¶
type RPC interface { Name() string FQRN() string RequestMessage() Message ResponseMessage() Message IsServerStreaming() bool IsClientStreaming() bool // StreamDesc returns *grpc.StreamDesc. // if both of IsServerStreaming and IsClientStreaming are nil, // StreamDesc will panic. StreamDesc() *grpc.StreamDesc }
type ServerStream ¶
Source Files ¶
Click to show internal directories.
Click to hide internal directories.