code

Documentation

Index

• func InMemoryObserver(name string) graph.IOFunc
• func New(b *base.Node, node *code.Code) graph.Node
• func NewFunctionProto() *code.Code
• func NewProto(name string, c *code.Code) *gen.Node
• func NewServerProto(runtime code.Runtime) *code.Code
• type FunctionNode
  • func NewFunctionNode(b *base.Node, node *code.Function, ops ...FunctionNodeOption) *FunctionNode
  • func (n *FunctionNode) ToGRPC(r *Server) *grpc.Method
  • func (n *FunctionNode) Type() (*graph.Info, error)
  • func (n *FunctionNode) Wire(ctx context.Context, input graph.IO) (graph.IO, error)
• type FunctionNodeOption
  • func WithFunction(f graph.IOFunc) FunctionNodeOption
• type Server
  • func NewServer(b *base.Node, node *code.Server) *Server
  • func (r *Server) GetServer() *grpc.Server
  • func (r *Server) Provide() ([]*gen.Node, error)
  • func (r *Server) Type() (*graph.Info, error)
  • func (r *Server) Wire(ctx context.Context, input graph.IO) (graph.IO, error)

Functions

func InMemoryObserver

func InMemoryObserver(name string) graph.IOFunc

func New

func New(b *base.Node, node *code.Code) graph.Node

func NewFunctionProto

func NewFunctionProto() *code.Code

func NewProto

func NewProto(name string, c *code.Code) *gen.Node

func NewServerProto

func NewServerProto(runtime code.Runtime) *code.Code

Types

type FunctionNode

type FunctionNode struct {
	*base.Node
	*code.Function
	// contains filtered or unexported fields
}

func NewFunctionNode

func NewFunctionNode(b *base.Node, node *code.Function, ops ...FunctionNodeOption) *FunctionNode

func (*FunctionNode) ToGRPC

func (n *FunctionNode) ToGRPC(r *Server) *grpc.Method

func (*FunctionNode) Type

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

func (*FunctionNode) Wire

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

type FunctionNodeOption

type FunctionNodeOption func(*FunctionNode) *FunctionNode

func WithFunction

func WithFunction(f graph.IOFunc) FunctionNodeOption

type Server

type Server struct {
	*base.Node
	*code.Server
	GRPC *grpc.Server
}

func NewServer

func NewServer(b *base.Node, node *code.Server) *Server

func (*Server) GetServer

func (r *Server) GetServer() *grpc.Server

func (*Server) Provide

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

func (*Server) Type

func (r *Server) Type() (*graph.Info, error)

func (*Server) Wire

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