proto

package
v0.0.8 Latest Latest
Warning

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

 Go to latest Published: Feb 2, 2026 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Rx_OnBootSignal_FullMethodName           = "/proto.Rx/OnBootSignal"
	Rx_OnProjectCreateSignal_FullMethodName  = "/proto.Rx/OnProjectCreateSignal"
	Rx_OnResourceCreateSignal_FullMethodName = "/proto.Rx/OnResourceCreateSignal"
	Rx_OnDeploySignal_FullMethodName         = "/proto.Rx/OnDeploySignal"
)

Variables

View Source 
var File_proto_signal_proto protoreflect.FileDescriptor
View Source 
var Rx_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Rx",
	HandlerType: (*RxServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "OnBootSignal",
			Handler:    _Rx_OnBootSignal_Handler,
		},
		{
			MethodName: "OnProjectCreateSignal",
			Handler:    _Rx_OnProjectCreateSignal_Handler,
		},
		{
			MethodName: "OnResourceCreateSignal",
			Handler:    _Rx_OnResourceCreateSignal_Handler,
		},
		{
			MethodName: "OnDeploySignal",
			Handler:    _Rx_OnDeploySignal_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/signal.proto",
}

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

Functions

func RegisterRxServer added in v0.0.5 

func RegisterRxServer(s grpc.ServiceRegistrar, srv RxServer)

Types

type AckResponse added in v0.0.5 

type AckResponse struct {
	Ok      bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*AckResponse) Descriptor deprecated added in v0.0.5 

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

Deprecated: Use AckResponse.ProtoReflect.Descriptor instead.

func (*AckResponse) GetMessage added in v0.0.5 

func (x *AckResponse) GetMessage() string

func (*AckResponse) GetOk added in v0.0.5 

func (x *AckResponse) GetOk() bool

func (*AckResponse) ProtoMessage added in v0.0.5 

func (*AckResponse) ProtoMessage()

func (*AckResponse) ProtoReflect added in v0.0.5 

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

func (*AckResponse) Reset added in v0.0.5 

func (x *AckResponse) Reset()

func (*AckResponse) String added in v0.0.5 

func (x *AckResponse) String() string

type BootRequest 

type BootRequest struct {

	// Serialized JSON bytes which receivers must know how to make sense of
	Config []byte `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*BootRequest) Descriptor deprecated 

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

Deprecated: Use BootRequest.ProtoReflect.Descriptor instead.

func (*BootRequest) GetConfig 

func (x *BootRequest) GetConfig() []byte

func (*BootRequest) ProtoMessage 

func (*BootRequest) ProtoMessage()

func (*BootRequest) ProtoReflect 

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

func (*BootRequest) Reset 

func (x *BootRequest) Reset()

func (*BootRequest) String 

func (x *BootRequest) String() string

type DeployRequest 

type DeployRequest struct {
	Ns          string `protobuf:"bytes,1,opt,name=ns,proto3" json:"ns,omitempty"`
	App         string `protobuf:"bytes,2,opt,name=app,proto3" json:"app,omitempty"`
	Kind        string `protobuf:"bytes,3,opt,name=kind,proto3" json:"kind,omitempty"`
	ResourceKey string `protobuf:"bytes,4,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	Version     uint32 `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	Content     []byte `protobuf:"bytes,6,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*DeployRequest) Descriptor deprecated 

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

Deprecated: Use DeployRequest.ProtoReflect.Descriptor instead.

func (*DeployRequest) GetApp 

func (x *DeployRequest) GetApp() string

func (*DeployRequest) GetContent 

func (x *DeployRequest) GetContent() []byte

func (*DeployRequest) GetKind 

func (x *DeployRequest) GetKind() string

func (*DeployRequest) GetNs 

func (x *DeployRequest) GetNs() string

func (*DeployRequest) GetResourceKey 

func (x *DeployRequest) GetResourceKey() string

func (*DeployRequest) GetVersion 

func (x *DeployRequest) GetVersion() uint32

func (*DeployRequest) ProtoMessage 

func (*DeployRequest) ProtoMessage()

func (*DeployRequest) ProtoReflect 

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

func (*DeployRequest) Reset 

func (x *DeployRequest) Reset()

func (*DeployRequest) String 

func (x *DeployRequest) String() string

type DeployResponse 

type DeployResponse struct {
	Ack *AckResponse `protobuf:"bytes,1,opt,name=ack,proto3" json:"ack,omitempty"`
	// contains filtered or unexported fields
}

func (*DeployResponse) Descriptor deprecated 

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

Deprecated: Use DeployResponse.ProtoReflect.Descriptor instead.

func (*DeployResponse) GetAck added in v0.0.5 

func (x *DeployResponse) GetAck() *AckResponse

func (*DeployResponse) ProtoMessage 

func (*DeployResponse) ProtoMessage()

func (*DeployResponse) ProtoReflect 

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

func (*DeployResponse) Reset 

func (x *DeployResponse) Reset()

func (*DeployResponse) String 

func (x *DeployResponse) String() string

type ProjectCreateRequest added in v0.0.8 

type ProjectCreateRequest struct {
	Ns  string `protobuf:"bytes,1,opt,name=ns,proto3" json:"ns,omitempty"`
	App string `protobuf:"bytes,2,opt,name=app,proto3" json:"app,omitempty"`
	// contains filtered or unexported fields
}

func (*ProjectCreateRequest) Descriptor deprecated added in v0.0.8 

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

Deprecated: Use ProjectCreateRequest.ProtoReflect.Descriptor instead.

func (*ProjectCreateRequest) GetApp added in v0.0.8 

func (x *ProjectCreateRequest) GetApp() string

func (*ProjectCreateRequest) GetNs added in v0.0.8 

func (x *ProjectCreateRequest) GetNs() string

func (*ProjectCreateRequest) ProtoMessage added in v0.0.8 

func (*ProjectCreateRequest) ProtoMessage()

func (*ProjectCreateRequest) ProtoReflect added in v0.0.8 

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

func (*ProjectCreateRequest) Reset added in v0.0.8 

func (x *ProjectCreateRequest) Reset()

func (*ProjectCreateRequest) String added in v0.0.8 

func (x *ProjectCreateRequest) String() string

type ResourceCreateRequest added in v0.0.8 

type ResourceCreateRequest struct {
	Ns          string `protobuf:"bytes,1,opt,name=ns,proto3" json:"ns,omitempty"`
	App         string `protobuf:"bytes,2,opt,name=app,proto3" json:"app,omitempty"`
	Kind        string `protobuf:"bytes,3,opt,name=kind,proto3" json:"kind,omitempty"`
	ResourceKey string `protobuf:"bytes,4,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceCreateRequest) Descriptor deprecated added in v0.0.8 

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

Deprecated: Use ResourceCreateRequest.ProtoReflect.Descriptor instead.

func (*ResourceCreateRequest) GetApp added in v0.0.8 

func (x *ResourceCreateRequest) GetApp() string

func (*ResourceCreateRequest) GetKind added in v0.0.8 

func (x *ResourceCreateRequest) GetKind() string

func (*ResourceCreateRequest) GetNs added in v0.0.8 

func (x *ResourceCreateRequest) GetNs() string

func (*ResourceCreateRequest) GetResourceKey added in v0.0.8 

func (x *ResourceCreateRequest) GetResourceKey() string

func (*ResourceCreateRequest) ProtoMessage added in v0.0.8 

func (*ResourceCreateRequest) ProtoMessage()

func (*ResourceCreateRequest) ProtoReflect added in v0.0.8 

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

func (*ResourceCreateRequest) Reset added in v0.0.8 

func (x *ResourceCreateRequest) Reset()

func (*ResourceCreateRequest) String added in v0.0.8 

func (x *ResourceCreateRequest) String() string

type RxClient added in v0.0.5 

type RxClient interface {
	OnBootSignal(ctx context.Context, in *BootRequest, opts ...grpc.CallOption) (*AckResponse, error)
	OnProjectCreateSignal(ctx context.Context, in *ProjectCreateRequest, opts ...grpc.CallOption) (*AckResponse, error)
	OnResourceCreateSignal(ctx context.Context, in *ResourceCreateRequest, opts ...grpc.CallOption) (*AckResponse, error)
	OnDeploySignal(ctx context.Context, in *DeployRequest, opts ...grpc.CallOption) (*DeployResponse, error)
}

RxClient is the client API for Rx 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 NewRxClient added in v0.0.5 

func NewRxClient(cc grpc.ClientConnInterface) RxClient

type RxServer added in v0.0.5 

type RxServer interface {
	OnBootSignal(context.Context, *BootRequest) (*AckResponse, error)
	OnProjectCreateSignal(context.Context, *ProjectCreateRequest) (*AckResponse, error)
	OnResourceCreateSignal(context.Context, *ResourceCreateRequest) (*AckResponse, error)
	OnDeploySignal(context.Context, *DeployRequest) (*DeployResponse, error)
}

RxServer is the server API for Rx service. All implementations should embed UnimplementedRxServer for forward compatibility.

type UnimplementedRxServer added in v0.0.5 

type UnimplementedRxServer struct{}

UnimplementedRxServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedRxServer) OnBootSignal added in v0.0.5 

func (UnimplementedRxServer) OnBootSignal(context.Context, *BootRequest) (*AckResponse, error)

func (UnimplementedRxServer) OnDeploySignal added in v0.0.5 

func (UnimplementedRxServer) OnDeploySignal(context.Context, *DeployRequest) (*DeployResponse, error)

func (UnimplementedRxServer) OnProjectCreateSignal added in v0.0.8 

func (UnimplementedRxServer) OnProjectCreateSignal(context.Context, *ProjectCreateRequest) (*AckResponse, error)

func (UnimplementedRxServer) OnResourceCreateSignal added in v0.0.8 

func (UnimplementedRxServer) OnResourceCreateSignal(context.Context, *ResourceCreateRequest) (*AckResponse, error)

type UnsafeRxServer added in v0.0.5 

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

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