proto

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: May 7, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Response_Status_name = map[int32]string{
		0: "OK",
		1: "ERROR",
	}
	Response_Status_value = map[string]int32{
		"OK":    0,
		"ERROR": 1,
	}
)

Enum value maps for Response_Status.

View Source 
var (
	FunctionStatus_Status_name = map[int32]string{
		0: "CREATING",
		1: "RUNNING",
		2: "DELETING",
		3: "DELETED",
		4: "FAILED",
	}
	FunctionStatus_Status_value = map[string]int32{
		"CREATING": 0,
		"RUNNING":  1,
		"DELETING": 2,
		"DELETED":  3,
		"FAILED":   4,
	}
)

Enum value maps for FunctionStatus_Status.

View Source 
var FSReconcile_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "fs_func.FSReconcile",
	HandlerType: (*FSReconcileServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UpdateStatus",
			Handler:    _FSReconcile_UpdateStatus_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Reconcile",
			Handler:       _FSReconcile_Reconcile_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "fs/runtime/grpc/proto/grpc_func.proto",
}

FSReconcile_ServiceDesc is the grpc.ServiceDesc for FSReconcile service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_fs_runtime_grpc_proto_grpc_func_proto protoreflect.FileDescriptor
View Source 
var Function_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "fs_func.Function",
	HandlerType: (*FunctionServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Output",
			Handler:    _Function_Output_Handler,
		},
		{
			MethodName: "PutState",
			Handler:    _Function_PutState_Handler,
		},
		{
			MethodName: "GetState",
			Handler:    _Function_GetState_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Process",
			Handler:       _Function_Process_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "fs/runtime/grpc/proto/grpc_func.proto",
}

Function_ServiceDesc is the grpc.ServiceDesc for Function service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterFSReconcileServer 

func RegisterFSReconcileServer(s grpc.ServiceRegistrar, srv FSReconcileServer)

func RegisterFunctionServer 

func RegisterFunctionServer(s grpc.ServiceRegistrar, srv FunctionServer)

Types

type ConnectRequest 

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

func (*ConnectRequest) Descriptor deprecated 

func (*ConnectRequest) Descriptor() ([]byte, []int)

Deprecated: Use ConnectRequest.ProtoReflect.Descriptor instead.

func (*ConnectRequest) ProtoMessage 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) ProtoReflect 

func (x *ConnectRequest) ProtoReflect() protoreflect.Message

func (*ConnectRequest) Reset 

func (x *ConnectRequest) Reset()

func (*ConnectRequest) String 

func (x *ConnectRequest) String() string

type Event 

type Event struct {
	Payload string `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The request message for the Process method.

func (*Event) Descriptor deprecated 

func (*Event) Descriptor() ([]byte, []int)

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetPayload 

func (x *Event) GetPayload() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type FSReconcileClient 

type FSReconcileClient interface {
	Reconcile(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (FSReconcile_ReconcileClient, error)
	UpdateStatus(ctx context.Context, in *FunctionStatus, opts ...grpc.CallOption) (*Response, error)
}

FSReconcileClient is the client API for FSReconcile service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewFSReconcileClient 

func NewFSReconcileClient(cc grpc.ClientConnInterface) FSReconcileClient

type FSReconcileServer 

type FSReconcileServer interface {
	Reconcile(*ConnectRequest, FSReconcile_ReconcileServer) error
	UpdateStatus(context.Context, *FunctionStatus) (*Response, error)
	// contains filtered or unexported methods
}

FSReconcileServer is the server API for FSReconcile service. All implementations must embed UnimplementedFSReconcileServer for forward compatibility

type FSReconcile_ReconcileClient 

type FSReconcile_ReconcileClient interface {
	Recv() (*FunctionStatus, error)
	grpc.ClientStream
}

type FSReconcile_ReconcileServer 

type FSReconcile_ReconcileServer interface {
	Send(*FunctionStatus) error
	grpc.ServerStream
}

type FunctionClient 

type FunctionClient interface {
	Process(ctx context.Context, in *FunctionProcessRequest, opts ...grpc.CallOption) (Function_ProcessClient, error)
	Output(ctx context.Context, in *Event, opts ...grpc.CallOption) (*Response, error)
	PutState(ctx context.Context, in *PutStateRequest, opts ...grpc.CallOption) (*Response, error)
	GetState(ctx context.Context, in *GetStateRequest, opts ...grpc.CallOption) (*GetStateResponse, error)
}

FunctionClient is the client API for Function service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewFunctionClient 

func NewFunctionClient(cc grpc.ClientConnInterface) FunctionClient

type FunctionProcessRequest 

type FunctionProcessRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionProcessRequest) Descriptor deprecated 

func (*FunctionProcessRequest) Descriptor() ([]byte, []int)

Deprecated: Use FunctionProcessRequest.ProtoReflect.Descriptor instead.

func (*FunctionProcessRequest) GetName 

func (x *FunctionProcessRequest) GetName() string

func (*FunctionProcessRequest) ProtoMessage 

func (*FunctionProcessRequest) ProtoMessage()

func (*FunctionProcessRequest) ProtoReflect 

func (x *FunctionProcessRequest) ProtoReflect() protoreflect.Message

func (*FunctionProcessRequest) Reset 

func (x *FunctionProcessRequest) Reset()

func (*FunctionProcessRequest) String 

func (x *FunctionProcessRequest) String() string

type FunctionServer 

type FunctionServer interface {
	Process(*FunctionProcessRequest, Function_ProcessServer) error
	Output(context.Context, *Event) (*Response, error)
	PutState(context.Context, *PutStateRequest) (*Response, error)
	GetState(context.Context, *GetStateRequest) (*GetStateResponse, error)
	// contains filtered or unexported methods
}

FunctionServer is the server API for Function service. All implementations must embed UnimplementedFunctionServer for forward compatibility

type FunctionStatus 

type FunctionStatus struct {
	Name    string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Status  FunctionStatus_Status `protobuf:"varint,2,opt,name=status,proto3,enum=fs_func.FunctionStatus_Status" json:"status,omitempty"`
	Details *string               `protobuf:"bytes,3,opt,name=details,proto3,oneof" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionStatus) Descriptor deprecated 

func (*FunctionStatus) Descriptor() ([]byte, []int)

Deprecated: Use FunctionStatus.ProtoReflect.Descriptor instead.

func (*FunctionStatus) GetDetails 

func (x *FunctionStatus) GetDetails() string

func (*FunctionStatus) GetName 

func (x *FunctionStatus) GetName() string

func (*FunctionStatus) GetStatus 

func (x *FunctionStatus) GetStatus() FunctionStatus_Status

func (*FunctionStatus) ProtoMessage 

func (*FunctionStatus) ProtoMessage()

func (*FunctionStatus) ProtoReflect 

func (x *FunctionStatus) ProtoReflect() protoreflect.Message

func (*FunctionStatus) Reset 

func (x *FunctionStatus) Reset()

func (*FunctionStatus) String 

func (x *FunctionStatus) String() string

type FunctionStatus_Status 

type FunctionStatus_Status int32
const (
	FunctionStatus_CREATING FunctionStatus_Status = 0
	FunctionStatus_RUNNING  FunctionStatus_Status = 1
	FunctionStatus_DELETING FunctionStatus_Status = 2
	FunctionStatus_DELETED  FunctionStatus_Status = 3
	FunctionStatus_FAILED   FunctionStatus_Status = 4
)

func (FunctionStatus_Status) Descriptor 

func (FunctionStatus_Status) Descriptor() protoreflect.EnumDescriptor

func (FunctionStatus_Status) Enum 

func (x FunctionStatus_Status) Enum() *FunctionStatus_Status

func (FunctionStatus_Status) EnumDescriptor deprecated 

func (FunctionStatus_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use FunctionStatus_Status.Descriptor instead.

func (FunctionStatus_Status) Number 

func (x FunctionStatus_Status) Number() protoreflect.EnumNumber

func (FunctionStatus_Status) String 

func (x FunctionStatus_Status) String() string

func (FunctionStatus_Status) Type 

func (FunctionStatus_Status) Type() protoreflect.EnumType

type Function_ProcessClient 

type Function_ProcessClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type Function_ProcessServer 

type Function_ProcessServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type GetStateRequest 

type GetStateRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStateRequest) Descriptor deprecated 

func (*GetStateRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetStateRequest.ProtoReflect.Descriptor instead.

func (*GetStateRequest) GetKey 

func (x *GetStateRequest) GetKey() string

func (*GetStateRequest) ProtoMessage 

func (*GetStateRequest) ProtoMessage()

func (*GetStateRequest) ProtoReflect 

func (x *GetStateRequest) ProtoReflect() protoreflect.Message

func (*GetStateRequest) Reset 

func (x *GetStateRequest) Reset()

func (*GetStateRequest) String 

func (x *GetStateRequest) String() string

type GetStateResponse 

type GetStateResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	Value    []byte    `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStateResponse) Descriptor deprecated 

func (*GetStateResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetStateResponse.ProtoReflect.Descriptor instead.

func (*GetStateResponse) GetResponse 

func (x *GetStateResponse) GetResponse() *Response

func (*GetStateResponse) GetValue 

func (x *GetStateResponse) GetValue() []byte

func (*GetStateResponse) ProtoMessage 

func (*GetStateResponse) ProtoMessage()

func (*GetStateResponse) ProtoReflect 

func (x *GetStateResponse) ProtoReflect() protoreflect.Message

func (*GetStateResponse) Reset 

func (x *GetStateResponse) Reset()

func (*GetStateResponse) String 

func (x *GetStateResponse) String() string

type PutStateRequest 

type PutStateRequest struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*PutStateRequest) Descriptor deprecated 

func (*PutStateRequest) Descriptor() ([]byte, []int)

Deprecated: Use PutStateRequest.ProtoReflect.Descriptor instead.

func (*PutStateRequest) GetKey 

func (x *PutStateRequest) GetKey() string

func (*PutStateRequest) GetValue 

func (x *PutStateRequest) GetValue() []byte

func (*PutStateRequest) ProtoMessage 

func (*PutStateRequest) ProtoMessage()

func (*PutStateRequest) ProtoReflect 

func (x *PutStateRequest) ProtoReflect() protoreflect.Message

func (*PutStateRequest) Reset 

func (x *PutStateRequest) Reset()

func (*PutStateRequest) String 

func (x *PutStateRequest) String() string

type Response 

type Response struct {
	Status  Response_Status `protobuf:"varint,1,opt,name=status,proto3,enum=fs_func.Response_Status" json:"status,omitempty"`
	Message *string         `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated 

func (*Response) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetMessage 

func (x *Response) GetMessage() string

func (*Response) GetStatus 

func (x *Response) GetStatus() Response_Status

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

func (x *Response) ProtoReflect() protoreflect.Message

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type Response_Status 

type Response_Status int32
const (
	Response_OK    Response_Status = 0
	Response_ERROR Response_Status = 1
)

func (Response_Status) Descriptor 

func (Response_Status) Descriptor() protoreflect.EnumDescriptor

func (Response_Status) Enum 

func (x Response_Status) Enum() *Response_Status

func (Response_Status) EnumDescriptor deprecated 

func (Response_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use Response_Status.Descriptor instead.

func (Response_Status) Number 

func (x Response_Status) Number() protoreflect.EnumNumber

func (Response_Status) String 

func (x Response_Status) String() string

func (Response_Status) Type 

func (Response_Status) Type() protoreflect.EnumType

type UnimplementedFSReconcileServer 

type UnimplementedFSReconcileServer struct {
}

UnimplementedFSReconcileServer must be embedded to have forward compatible implementations.

func (UnimplementedFSReconcileServer) Reconcile 

func (UnimplementedFSReconcileServer) Reconcile(*ConnectRequest, FSReconcile_ReconcileServer) error

func (UnimplementedFSReconcileServer) UpdateStatus 

func (UnimplementedFSReconcileServer) UpdateStatus(context.Context, *FunctionStatus) (*Response, error)

type UnimplementedFunctionServer 

type UnimplementedFunctionServer struct {
}

UnimplementedFunctionServer must be embedded to have forward compatible implementations.

func (UnimplementedFunctionServer) GetState 

func (UnimplementedFunctionServer) GetState(context.Context, *GetStateRequest) (*GetStateResponse, error)

func (UnimplementedFunctionServer) Output 

func (UnimplementedFunctionServer) Output(context.Context, *Event) (*Response, error)

func (UnimplementedFunctionServer) Process 

func (UnimplementedFunctionServer) Process(*FunctionProcessRequest, Function_ProcessServer) error

func (UnimplementedFunctionServer) PutState 

func (UnimplementedFunctionServer) PutState(context.Context, *PutStateRequest) (*Response, error)

type UnsafeFSReconcileServer 

type UnsafeFSReconcileServer interface {
	// contains filtered or unexported methods
}

UnsafeFSReconcileServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FSReconcileServer will result in compilation errors.

type UnsafeFunctionServer 

type UnsafeFunctionServer interface {
	// contains filtered or unexported methods
}

UnsafeFunctionServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FunctionServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.