grpc

Documentation

Index

• func GetMethodDescriptor(s *Server, n *Method) (*grpc.MethodDescriptor, error)
• func GetMethodFromServer(r *Server, n *Method, protocol bufcurl.ReflectProtocol) (protoreflect.MethodDescriptor, error)
• func New(b *base.Node, node *grpc.GRPC) graph.Node
• func NewMethodProto(pack, service, method string) *pgrpc.GRPC
• func NewProto(name string, g *grpc.GRPC) *gen.Node
• func NewServerProto(host string) *pgrpc.GRPC
• func WireMethod(ctx context.Context, g *Server, n *Method, obs rxgo.Observable) (graph.IO, error)
• type Method
  • func NewMethod(b *base.Node, n *pgrpc.Method) *Method
  • func (n *Method) Type() (*graph.Info, error)
  • func (n *Method) Wire(ctx context.Context, input graph.IO) (graph.IO, error)
• type Server
  • func NewServer(b *base.Node, n *pgrpc.Server) *Server
  • func (n *Server) GetServer() *Server
  • func (n *Server) Provide() ([]*gen.Node, error)
  • func (n *Server) Wire(ctx context.Context, input graph.IO) (graph.IO, error)
• type ServerProvider

Functions

func GetMethodDescriptor

func GetMethodDescriptor(s *Server, n *Method) (*grpc.MethodDescriptor, error)

func GetMethodFromServer

func GetMethodFromServer(r *Server, n *Method, protocol bufcurl.ReflectProtocol) (protoreflect.MethodDescriptor, error)

func New

func New(b *base.Node, node *grpc.GRPC) graph.Node

func NewMethodProto

func NewMethodProto(pack, service, method string) *pgrpc.GRPC

func NewProto

func NewProto(name string, g *grpc.GRPC) *gen.Node

func NewServerProto

func NewServerProto(host string) *pgrpc.GRPC

func WireMethod

func WireMethod(ctx context.Context, g *Server, n *Method, obs rxgo.Observable) (graph.IO, error)

Types

type Method

type Method struct {
	*base.Node
	*pgrpc.Method
}

func NewMethod

func NewMethod(b *base.Node, n *pgrpc.Method) *Method

func (*Method) Type

func (n *Method) Type() (*graph.Info, error)

func (*Method) Wire

func (n *Method) Wire(ctx context.Context, input graph.IO) (graph.IO, error)

TODO breadchris this should be workflow.Context, but for the memory executor it needs context.Context

type Server

type Server struct {
	*base.Node
	*pgrpc.Server
}

func NewServer

func NewServer(b *base.Node, n *pgrpc.Server) *Server

func (*Server) GetServer

func (n *Server) GetServer() *Server

func (*Server) Provide

func (n *Server) Provide() ([]*gen.Node, error)

func (*Server) Wire

func (n *Server) Wire(ctx context.Context, input graph.IO) (graph.IO, error)

type ServerProvider

type ServerProvider interface {
	GetServer() *Server
}