grpc

package
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 13, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 (*FSSReconcileServer) UpdateStatus

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

func (*FSSReconcileServer) WaitForReady

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

type FuncRuntime added in v0.5.0

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

func (*FuncRuntime) Call added in v0.5.0

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

func (*FuncRuntime) Stop added in v0.5.0

func (f *FuncRuntime) 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 (*FuncRuntime) Update added in v0.5.0

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

func (*FuncRuntime) WaitForReady added in v0.5.0

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

type FunctionServerImpl

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

func NewFunctionServerImpl

func NewFunctionServerImpl(s *FSSReconcileServer) *FunctionServerImpl

func (*FunctionServerImpl) GetState

func (*FunctionServerImpl) Output

func (*FunctionServerImpl) Process

func (*FunctionServerImpl) PutState

type Status

type Status int32
const (
	NotReady Status = iota
	Ready
)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL