grpcstub

Documentation

Index

• func NewServer(protoDir string, protoStubDir string) (*grpc.Server, error)
• type GRPCService
  • func New(srv *grpc.Server, r Repository) GRPCService
  • func (s *GRPCService) Handler(_ any, ctx context.Context, deccode func(any) error, ...) (interface{}, error)
  • func (s *GRPCService) LoadSpecs(protoDir string) error
  • func (s *GRPCService) StreamHandler(_ any, _ grpc.ServerStream) error
• type Output
• type ProtoStorage
  • func NewStorage() *ProtoStorage
  • func (p *ProtoStorage) Add(s ProtoStub)
  • func (p *ProtoStorage) Get(service string, method string, _ json.RawMessage) (Output, bool)
• type ProtoStub
  • func Load(dir string) ([]ProtoStub, error)
• type Repository

Functions

func NewServer

func NewServer(protoDir string, protoStubDir string) (*grpc.Server, error)

Types

type GRPCService

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

func New

func New(srv *grpc.Server, r Repository) GRPCService

func (*GRPCService) Handler

func (s *GRPCService) Handler(_ any, ctx context.Context, deccode func(any) error, _ grpc.UnaryServerInterceptor) (interface{}, error)

func (*GRPCService) LoadSpecs

func (s *GRPCService) LoadSpecs(protoDir string) error

func (*GRPCService) StreamHandler

func (s *GRPCService) StreamHandler(_ any, _ grpc.ServerStream) error

type Output

type Output struct {
	Data  json.RawMessage `json:"data"`
	Error string          `json:"error"`
	Code  *codes.Code     `json:"code,omitempty"`
}

type ProtoStorage

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

func NewStorage

func NewStorage() *ProtoStorage

func (*ProtoStorage) Add

func (p *ProtoStorage) Add(s ProtoStub)

func (*ProtoStorage) Get

func (p *ProtoStorage) Get(service string, method string, _ json.RawMessage) (Output, bool)

type ProtoStub

type ProtoStub struct {
	Service string `json:"service"`
	Method  string `json:"method"`
	Matcher string `json:"matcher"`
	Output  Output `json:"output"`
}

func Load

func Load(dir string) ([]ProtoStub, error)

type Repository

type Repository interface {
	Add(stub ProtoStub)
	Get(service string, method string, in json.RawMessage) (Output, bool)
}