entity

type BidiStream interface {
	Send(req proto.Message) error
	Receive(res *proto.Message) error
	Close() error
}

type ClientStream interface {
	Send(req proto.Message) error
	CloseAndReceive(res *proto.Message) error
}

type Enum interface {
	Name() string
	Values() []EnumValue
}

type EnumField interface {
	Field
	Enum
}

type EnumValue interface {
	Name() string
	Number() int32
}

type Field interface {
	FieldName() string
	FQRN() string
	Type() FieldType
	IsRepeated() bool

	// *desc.FieldDescriptor.GetType().String()
	// used only from port.Showable
	PBType() string
}

type FieldType int

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

	GRPCReflectionClient
}

type GRPCReflectionClient interface {
	ReflectionEnabled() bool
	ListPackages() ([]*Package, error)
}

type Header struct {
	Key, Val string

	// NeedToRemove is used only from REPL header command
	NeedToRemove bool
}

type Message interface {
	Name() string
	Fields() []Field
	IsCycled() bool
}

type MessageField interface {
	Field
	Message
}

type OneOfField interface {
	Field
	Choices() []Field
}

type Package struct {
	Name     string
	Services []Service
	Messages []Message
}

type Parser interface {
	ParseFile(fnames []string, fpaths []string) ([]*Package, error)
}

type PrimitiveField interface {
	Field
}

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 interface {
	Send(req proto.Message) error
	Receive(res *proto.Message) error
}

type Service interface {
	Name() string
	FQRN() string
	RPCs() []RPC
}