proto

package
v0.0.0-...-16672c3 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	DataFormat_name = map[int32]string{
		0: "UNKNOWN",
		1: "JSON",
	}
	DataFormat_value = map[string]int32{
		"UNKNOWN": 0,
		"JSON":    1,
	}
)

Enum value maps for DataFormat.

View Source 
var Actor_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Actor",
	HandlerType: (*ActorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Call",
			Handler:    _Actor_Call_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "actor.proto",
}

Actor_ServiceDesc is the grpc.ServiceDesc for Actor 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_actor_proto protoreflect.FileDescriptor
View Source 
var File_golet_proto protoreflect.FileDescriptor
View Source 
var Golet_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Golet",
	HandlerType: (*GoletServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Invoke",
			Handler:    _Golet_Invoke_Handler,
		},
		{
			MethodName: "Load",
			Handler:    _Golet_Load_Handler,
		},
		{
			MethodName: "Unload",
			Handler:    _Golet_Unload_Handler,
		},
		{
			MethodName: "List",
			Handler:    _Golet_List_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "golet.proto",
}

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

Functions

func RegisterActorServer 

func RegisterActorServer(s grpc.ServiceRegistrar, srv ActorServer)

func RegisterGoletServer 

func RegisterGoletServer(s grpc.ServiceRegistrar, srv GoletServer)

Types

type ActorClient 

type ActorClient interface {
	Call(ctx context.Context, in *RemoteMessage, opts ...grpc.CallOption) (*RemoteMessage, error)
}

ActorClient is the client API for Actor 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 NewActorClient 

func NewActorClient(cc grpc.ClientConnInterface) ActorClient

type ActorServer 

type ActorServer interface {
	Call(context.Context, *RemoteMessage) (*RemoteMessage, error)
	// contains filtered or unexported methods
}

ActorServer is the server API for Actor service. All implementations must embed UnimplementedActorServer for forward compatibility

type DataFormat 

type DataFormat int32
const (
	DataFormat_UNKNOWN DataFormat = 0
	DataFormat_JSON    DataFormat = 1
)

func (DataFormat) Descriptor 

func (DataFormat) Descriptor() protoreflect.EnumDescriptor

func (DataFormat) Enum 

func (x DataFormat) Enum() *DataFormat

func (DataFormat) EnumDescriptor deprecated 

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

Deprecated: Use DataFormat.Descriptor instead.

func (DataFormat) Number 

func (x DataFormat) Number() protoreflect.EnumNumber

func (DataFormat) String 

func (x DataFormat) String() string

func (DataFormat) Type 

func (DataFormat) Type() protoreflect.EnumType

type GoletClient 

type GoletClient interface {
	Invoke(ctx context.Context, in *RemoteMessage, opts ...grpc.CallOption) (*RemoteMessage, error)
	Load(ctx context.Context, in *LoadRequest, opts ...grpc.CallOption) (*LoadResponse, error)
	Unload(ctx context.Context, in *UnloadRequest, opts ...grpc.CallOption) (*UnloadResponse, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
}

GoletClient is the client API for Golet 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 NewGoletClient 

func NewGoletClient(cc grpc.ClientConnInterface) GoletClient

type GoletServer 

type GoletServer interface {
	Invoke(context.Context, *RemoteMessage) (*RemoteMessage, error)
	Load(context.Context, *LoadRequest) (*LoadResponse, error)
	Unload(context.Context, *UnloadRequest) (*UnloadResponse, error)
	List(context.Context, *ListRequest) (*ListResponse, error)
	// contains filtered or unexported methods
}

GoletServer is the server API for Golet service. All implementations must embed UnimplementedGoletServer for forward compatibility

type ListRequest 

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

func (*ListRequest) Descriptor deprecated 

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetFilter 

func (x *ListRequest) GetFilter() string

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect 

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

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) String 

func (x *ListRequest) String() string

type ListResponse 

type ListResponse struct {
	Pids []*PID `protobuf:"bytes,1,rep,name=pids,proto3" json:"pids,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResponse) Descriptor deprecated 

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) GetPids 

func (x *ListResponse) GetPids() []*PID

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect 

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

func (*ListResponse) Reset 

func (x *ListResponse) Reset()

func (*ListResponse) String 

func (x *ListResponse) String() string

type LoadRequest 

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

func (*LoadRequest) Descriptor deprecated 

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

Deprecated: Use LoadRequest.ProtoReflect.Descriptor instead.

func (*LoadRequest) GetName 

func (x *LoadRequest) GetName() string

func (*LoadRequest) GetPath 

func (x *LoadRequest) GetPath() string

func (*LoadRequest) ProtoMessage 

func (*LoadRequest) ProtoMessage()

func (*LoadRequest) ProtoReflect 

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

func (*LoadRequest) Reset 

func (x *LoadRequest) Reset()

func (*LoadRequest) String 

func (x *LoadRequest) String() string

type LoadResponse 

type LoadResponse struct {
	Pid *PID `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadResponse) Descriptor deprecated 

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

Deprecated: Use LoadResponse.ProtoReflect.Descriptor instead.

func (*LoadResponse) GetPid 

func (x *LoadResponse) GetPid() *PID

func (*LoadResponse) ProtoMessage 

func (*LoadResponse) ProtoMessage()

func (*LoadResponse) ProtoReflect 

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

func (*LoadResponse) Reset 

func (x *LoadResponse) Reset()

func (*LoadResponse) String 

func (x *LoadResponse) String() string

type PID 

type PID struct {
	Id           string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name         string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	BinarySource string `protobuf:"bytes,3,opt,name=binary_source,json=binarySource,proto3" json:"binary_source,omitempty"`
	Host         string `protobuf:"bytes,4,opt,name=host,proto3" json:"host,omitempty"`
	Endpoint     string `protobuf:"bytes,5,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*PID) Descriptor deprecated 

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

Deprecated: Use PID.ProtoReflect.Descriptor instead.

func (*PID) GetBinarySource 

func (x *PID) GetBinarySource() string

func (*PID) GetEndpoint 

func (x *PID) GetEndpoint() string

func (*PID) GetHost 

func (x *PID) GetHost() string

func (*PID) GetId 

func (x *PID) GetId() string

func (*PID) GetName 

func (x *PID) GetName() string

func (*PID) ProtoMessage 

func (*PID) ProtoMessage()

func (*PID) ProtoReflect 

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

func (*PID) Reset 

func (x *PID) Reset()

func (*PID) String 

func (x *PID) String() string

type RemoteMessage 

type RemoteMessage struct {
	Body   []byte            `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	Header map[string]string `` /* 153-byte string literal not displayed */
	From   *PID              `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"`
	To     *PID              `protobuf:"bytes,4,opt,name=to,proto3" json:"to,omitempty"`
	Format DataFormat        `protobuf:"varint,5,opt,name=format,proto3,enum=proto.DataFormat" json:"format,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteMessage) Descriptor deprecated 

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

Deprecated: Use RemoteMessage.ProtoReflect.Descriptor instead.

func (*RemoteMessage) GetBody 

func (x *RemoteMessage) GetBody() []byte

func (*RemoteMessage) GetFormat 

func (x *RemoteMessage) GetFormat() DataFormat

func (*RemoteMessage) GetFrom 

func (x *RemoteMessage) GetFrom() *PID

func (*RemoteMessage) GetHeader 

func (x *RemoteMessage) GetHeader() map[string]string

func (*RemoteMessage) GetTo 

func (x *RemoteMessage) GetTo() *PID

func (*RemoteMessage) ProtoMessage 

func (*RemoteMessage) ProtoMessage()

func (*RemoteMessage) ProtoReflect 

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

func (*RemoteMessage) Reset 

func (x *RemoteMessage) Reset()

func (*RemoteMessage) String 

func (x *RemoteMessage) String() string

type UnimplementedActorServer 

type UnimplementedActorServer struct {
}

UnimplementedActorServer must be embedded to have forward compatible implementations.

func (UnimplementedActorServer) Call 

func (UnimplementedActorServer) Call(context.Context, *RemoteMessage) (*RemoteMessage, error)

type UnimplementedGoletServer 

type UnimplementedGoletServer struct {
}

UnimplementedGoletServer must be embedded to have forward compatible implementations.

func (UnimplementedGoletServer) Invoke 

func (UnimplementedGoletServer) Invoke(context.Context, *RemoteMessage) (*RemoteMessage, error)

func (UnimplementedGoletServer) List 

func (UnimplementedGoletServer) List(context.Context, *ListRequest) (*ListResponse, error)

func (UnimplementedGoletServer) Load 

func (UnimplementedGoletServer) Load(context.Context, *LoadRequest) (*LoadResponse, error)

func (UnimplementedGoletServer) Unload 

func (UnimplementedGoletServer) Unload(context.Context, *UnloadRequest) (*UnloadResponse, error)

type UnloadRequest 

type UnloadRequest struct {
	Pid *PID `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

func (*UnloadRequest) Descriptor deprecated 

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

Deprecated: Use UnloadRequest.ProtoReflect.Descriptor instead.

func (*UnloadRequest) GetPid 

func (x *UnloadRequest) GetPid() *PID

func (*UnloadRequest) ProtoMessage 

func (*UnloadRequest) ProtoMessage()

func (*UnloadRequest) ProtoReflect 

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

func (*UnloadRequest) Reset 

func (x *UnloadRequest) Reset()

func (*UnloadRequest) String 

func (x *UnloadRequest) String() string

type UnloadResponse 

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

func (*UnloadResponse) Descriptor deprecated 

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

Deprecated: Use UnloadResponse.ProtoReflect.Descriptor instead.

func (*UnloadResponse) ProtoMessage 

func (*UnloadResponse) ProtoMessage()

func (*UnloadResponse) ProtoReflect 

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

func (*UnloadResponse) Reset 

func (x *UnloadResponse) Reset()

func (*UnloadResponse) String 

func (x *UnloadResponse) String() string

type UnsafeActorServer 

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

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

type UnsafeGoletServer 

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

UnsafeGoletServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GoletServer 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.