grpc

Documentation

Index

• Variables
• func GetImportPaths(protoFiles []*domain.ProtoFile, files []string) ([]string, []string)
• func ProtoFilesFromDisk(importPaths, filenames []string) (*protoregistry.Files, error)
• func ProtoFilesFromReflectionAPI(ctx context.Context, conn *grpc.ClientConn) (*protoregistry.Files, error)
• type Response
• type Service
  • func NewService(requests *state.Requests, envs *state.Environments, ...) *Service
  • func (s *Service) Dial(req *domain.GRPCRequestSpec) (*grpc.ClientConn, error)
  • func (s *Service) GetRequestStruct(id, environmentID string) (string, error)
  • func (s *Service) GetServices(id, activeEnvironmentID string) ([]domain.GRPCService, error)
  • func (s *Service) Invoke(id, activeEnvironmentID string) (*Response, error)

Variables

var (
	ErrRequestNotFound = errors.New("request not found")
)

Functions

func GetImportPaths

func GetImportPaths(protoFiles []*domain.ProtoFile, files []string) ([]string, []string)

func ProtoFilesFromDisk

func ProtoFilesFromDisk(importPaths, filenames []string) (*protoregistry.Files, error)

func ProtoFilesFromReflectionAPI

func ProtoFilesFromReflectionAPI(ctx context.Context, conn *grpc.ClientConn) (*protoregistry.Files, error)

Types

type Response

type Response struct {
	Body       string
	Metadata   []domain.KeyValue
	Trailers   []domain.KeyValue
	TimePassed time.Duration
	Size       int
	Error      error

	StatueCode int
	Status     string
}

type Service

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

func NewService

func NewService(requests *state.Requests, envs *state.Environments, protoFiles *state.ProtoFiles) *Service

func (*Service) Dial

func (s *Service) Dial(req *domain.GRPCRequestSpec) (*grpc.ClientConn, error)

func (*Service) GetRequestStruct

func (s *Service) GetRequestStruct(id, environmentID string) (string, error)

func (*Service) GetServices

func (s *Service) GetServices(id, activeEnvironmentID string) ([]domain.GRPCService, error)

func (*Service) Invoke

func (s *Service) Invoke(id, activeEnvironmentID string) (*Response, error)