env

Documentation

Index

• Variables
• type Env
  • func New(pkgs []*entity.Package, defaultHeaders []entity.Header) *Env
  • func NewFromServices(svcs []entity.Service, msgs []entity.Message, defaultHeaders []entity.Header) *Env
  • func (e *Env) AddHeader(h *entity.Header)
  • func (e *Env) DSN() string
  • func (e *Env) HasCurrentPackage() bool
  • func (e *Env) HasCurrentService() bool
  • func (e *Env) Headers() (headers []*entity.Header)
  • func (e *Env) Message(name string) (entity.Message, error)
  • func (e *Env) Messages() ([]entity.Message, error)
  • func (e *Env) Packages() []*entity.Package
  • func (e *Env) RPC(name string) (entity.RPC, error)
  • func (e *Env) RPCs() ([]entity.RPC, error)
  • func (e *Env) RemoveHeader(key string)
  • func (e *Env) Service(name string) (entity.Service, error)
  • func (e *Env) Services() ([]entity.Service, error)
  • func (e *Env) UsePackage(name string) error
  • func (e *Env) UseService(name string) error
• type Environment

Variables

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")
)

Types

type Env

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

func New

func New(pkgs []*entity.Package, defaultHeaders []entity.Header) *Env

func NewFromServices

func NewFromServices(svcs []entity.Service, msgs []entity.Message, defaultHeaders []entity.Header) *Env

NewFromServices is called if the target server has enabled gRPC reflection. gRPC reflection has no packages, so Evans creates pseudo package "default".

func (*Env) AddHeader

func (e *Env) AddHeader(h *entity.Header)

func (*Env) DSN

func (e *Env) DSN() string

func (*Env) HasCurrentPackage

func (e *Env) HasCurrentPackage() bool

func (*Env) HasCurrentService

func (e *Env) HasCurrentService() bool

func (*Env) Headers

func (e *Env) Headers() (headers []*entity.Header)

func (*Env) Message

func (e *Env) Message(name string) (entity.Message, error)

func (*Env) Messages

func (e *Env) Messages() ([]entity.Message, error)

func (*Env) Packages

func (e *Env) Packages() []*entity.Package

func (*Env) RPC

func (e *Env) RPC(name string) (entity.RPC, error)

func (*Env) RPCs

func (e *Env) RPCs() ([]entity.RPC, error)

func (*Env) RemoveHeader

func (e *Env) RemoveHeader(key string)

func (*Env) Service

func (e *Env) Service(name string) (entity.Service, error)

func (*Env) Services

func (e *Env) Services() ([]entity.Service, error)

func (*Env) UsePackage

func (e *Env) UsePackage(name string) error

func (*Env) UseService

func (e *Env) UseService(name string) error

type Environment

type Environment interface {
	Packages() []*entity.Package
	Services() ([]entity.Service, error)
	Messages() ([]entity.Message, error)
	RPCs() ([]entity.RPC, error)
	Service(name string) (entity.Service, error)
	Message(name string) (entity.Message, error)
	RPC(name string) (entity.RPC, error)

	Headers() []*entity.Header
	AddHeader(header *entity.Header)
	RemoveHeader(key string)

	UsePackage(name string) error
	UseService(name string) error

	DSN() string
}