proxy

Documentation

Index

• type IntrospectionResponse
• type Proxy
  • func NewProxy(conn *grpc.ClientConn) *Proxy
  • func (p *Proxy) Introspect() ([]byte, error)
  • func (p *Proxy) Invoke(ctx context.Context, serviceName, methodName string, message []byte, ...) ([]byte, error)
  • func (p *Proxy) IsReady() bool

Types

type IntrospectionResponse

type IntrospectionResponse struct {
	Services []*serviceElement `json:"services"`
	Types    []*typeElement    `json:"types"`
}

IntrospectionResponse represents a introspection response

type Proxy

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

Proxy performs upstream invocation as a dynamic gRPC client using reflection

func NewProxy

func NewProxy(conn *grpc.ClientConn) *Proxy

NewProxy creates a new gRPC client

func (*Proxy) Introspect

func (p *Proxy) Introspect() ([]byte, error)

Introspect performs instrospection on this gRPC server, and obtains all services and methods information

func (*Proxy) Invoke

func (p *Proxy) Invoke(ctx context.Context,
	serviceName, methodName string,
	message []byte,
	md *metadata.Metadata,
) ([]byte, error)

Invoke performs the gRPC call after doing reflection to obtain type information

func (*Proxy) IsReady

func (p *Proxy) IsReady() bool

IsReady checks the connectivity to the upstream