grpc

Documentation

Index

• func StartGRPCServer(f *FSSReconcileServer, addr string) (*grpc.Server, error)
• type FSSReconcileServer
  • func NewFSReconcile(ctx context.Context) *FSSReconcileServer
  • func (s *FSSReconcileServer) NewFunctionRuntime(instance api.FunctionInstance) (api.FunctionRuntime, error)
  • func (s *FSSReconcileServer) Reconcile(_ *proto.ConnectRequest, stream proto.FSReconcile_ReconcileServer) error
  • func (s *FSSReconcileServer) UpdateStatus(_ context.Context, newStatus *proto.FunctionStatus) (*proto.Response, error)
  • func (s *FSSReconcileServer) WaitForReady() <-chan struct{}
• type FunctionServerImpl
  • func NewFunctionServerImpl(s *FSSReconcileServer) *FunctionServerImpl
  • func (f *FunctionServerImpl) GetState(ctx context.Context, req *proto.GetStateRequest) (*proto.GetStateResponse, error)
  • func (f *FunctionServerImpl) Output(ctx context.Context, e *proto.Event) (*proto.Response, error)
  • func (f *FunctionServerImpl) Process(req *proto.FunctionProcessRequest, stream proto.Function_ProcessServer) error
  • func (f *FunctionServerImpl) PutState(ctx context.Context, req *proto.PutStateRequest) (*proto.Response, error)
• type GRPCFuncRuntime
  • func (f *GRPCFuncRuntime) Call(event contube.Record) (contube.Record, error)
  • func (f *GRPCFuncRuntime) Stop()
  • func (f *GRPCFuncRuntime) Update(new *proto.FunctionStatus)
  • func (f *GRPCFuncRuntime) WaitForReady() <-chan error
• type Status

Functions

func StartGRPCServer

func StartGRPCServer(f *FSSReconcileServer, addr string) (*grpc.Server, error)

Types

type FSSReconcileServer

type FSSReconcileServer struct {
	proto.UnimplementedFSReconcileServer
	// contains filtered or unexported fields
}

FSSReconcileServer is the struct that implements the FSServiceServer interface.

func NewFSReconcile

func NewFSReconcile(ctx context.Context) *FSSReconcileServer

func (*FSSReconcileServer) NewFunctionRuntime

func (s *FSSReconcileServer) NewFunctionRuntime(instance api.FunctionInstance) (api.FunctionRuntime, error)

func (*FSSReconcileServer) Reconcile

func (s *FSSReconcileServer) Reconcile(_ *proto.ConnectRequest, stream proto.FSReconcile_ReconcileServer) error

func (*FSSReconcileServer) UpdateStatus

func (s *FSSReconcileServer) UpdateStatus(_ context.Context, newStatus *proto.FunctionStatus) (*proto.Response, error)

func (*FSSReconcileServer) WaitForReady

func (s *FSSReconcileServer) WaitForReady() <-chan struct{}

type FunctionServerImpl

type FunctionServerImpl struct {
	proto.UnimplementedFunctionServer
	// contains filtered or unexported fields
}

func NewFunctionServerImpl

func NewFunctionServerImpl(s *FSSReconcileServer) *FunctionServerImpl

func (*FunctionServerImpl) GetState

func (f *FunctionServerImpl) GetState(ctx context.Context, req *proto.GetStateRequest) (*proto.GetStateResponse, error)

func (*FunctionServerImpl) Output

func (f *FunctionServerImpl) Output(ctx context.Context, e *proto.Event) (*proto.Response, error)

func (*FunctionServerImpl) Process

func (f *FunctionServerImpl) Process(req *proto.FunctionProcessRequest, stream proto.Function_ProcessServer) error

func (*FunctionServerImpl) PutState

func (f *FunctionServerImpl) PutState(ctx context.Context, req *proto.PutStateRequest) (*proto.Response, error)

type GRPCFuncRuntime

type GRPCFuncRuntime struct {
	api.FunctionRuntime
	Name string
	// contains filtered or unexported fields
}

func (*GRPCFuncRuntime) Call

func (f *GRPCFuncRuntime) Call(event contube.Record) (contube.Record, error)

func (*GRPCFuncRuntime) Stop

func (f *GRPCFuncRuntime) Stop()

Stop stops the function runtime and remove it It is different from the ctx.Cancel. It will make sure the runtime has been deleted after this method returns.

func (*GRPCFuncRuntime) Update

func (f *GRPCFuncRuntime) Update(new *proto.FunctionStatus)

func (*GRPCFuncRuntime) WaitForReady

func (f *GRPCFuncRuntime) WaitForReady() <-chan error

type Status

type Status int32

const (
	NotReady Status = iota
	Ready
)