command

package
v5.33.0 Latest Latest
Warning

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

 Go to latest Published: May 26, 2025 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SubscriptionManagerService_ListTrackedSubscription_FullMethodName      = "/v2ray.core.app.subscription.subscriptionmanager.command.SubscriptionManagerService/ListTrackedSubscription"
	SubscriptionManagerService_AddTrackedSubscription_FullMethodName       = "/v2ray.core.app.subscription.subscriptionmanager.command.SubscriptionManagerService/AddTrackedSubscription"
	SubscriptionManagerService_RemoveTrackedSubscription_FullMethodName    = "/v2ray.core.app.subscription.subscriptionmanager.command.SubscriptionManagerService/RemoveTrackedSubscription"
	SubscriptionManagerService_GetTrackedSubscriptionStatus_FullMethodName = "/v2ray.core.app.subscription.subscriptionmanager.command.SubscriptionManagerService/GetTrackedSubscriptionStatus"
	SubscriptionManagerService_UpdateTrackedSubscription_FullMethodName    = "/v2ray.core.app.subscription.subscriptionmanager.command.SubscriptionManagerService/UpdateTrackedSubscription"
)

Variables

View Source 
var File_app_subscription_subscriptionmanager_command_command_proto protoreflect.FileDescriptor
View Source 
var SubscriptionManagerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v2ray.core.app.subscription.subscriptionmanager.command.SubscriptionManagerService",
	HandlerType: (*SubscriptionManagerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListTrackedSubscription",
			Handler:    _SubscriptionManagerService_ListTrackedSubscription_Handler,
		},
		{
			MethodName: "AddTrackedSubscription",
			Handler:    _SubscriptionManagerService_AddTrackedSubscription_Handler,
		},
		{
			MethodName: "RemoveTrackedSubscription",
			Handler:    _SubscriptionManagerService_RemoveTrackedSubscription_Handler,
		},
		{
			MethodName: "GetTrackedSubscriptionStatus",
			Handler:    _SubscriptionManagerService_GetTrackedSubscriptionStatus_Handler,
		},
		{
			MethodName: "UpdateTrackedSubscription",
			Handler:    _SubscriptionManagerService_UpdateTrackedSubscription_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "app/subscription/subscriptionmanager/command/command.proto",
}

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

Functions

func RegisterSubscriptionManagerServiceServer 

func RegisterSubscriptionManagerServiceServer(s grpc.ServiceRegistrar, srv SubscriptionManagerServiceServer)

Types

type AddTrackedSubscriptionRequest 

type AddTrackedSubscriptionRequest struct {
	Source *subscription.ImportSource `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	// contains filtered or unexported fields
}

func (*AddTrackedSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use AddTrackedSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*AddTrackedSubscriptionRequest) GetSource 

func (x *AddTrackedSubscriptionRequest) GetSource() *subscription.ImportSource

func (*AddTrackedSubscriptionRequest) ProtoMessage 

func (*AddTrackedSubscriptionRequest) ProtoMessage()

func (*AddTrackedSubscriptionRequest) ProtoReflect 

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

func (*AddTrackedSubscriptionRequest) Reset 

func (x *AddTrackedSubscriptionRequest) Reset()

func (*AddTrackedSubscriptionRequest) String 

func (x *AddTrackedSubscriptionRequest) String() string

type AddTrackedSubscriptionResponse 

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

func (*AddTrackedSubscriptionResponse) Descriptor deprecated 

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

Deprecated: Use AddTrackedSubscriptionResponse.ProtoReflect.Descriptor instead.

func (*AddTrackedSubscriptionResponse) ProtoMessage 

func (*AddTrackedSubscriptionResponse) ProtoMessage()

func (*AddTrackedSubscriptionResponse) ProtoReflect 

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

func (*AddTrackedSubscriptionResponse) Reset 

func (x *AddTrackedSubscriptionResponse) Reset()

func (*AddTrackedSubscriptionResponse) String 

func (x *AddTrackedSubscriptionResponse) String() string

type Config 

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

func (*Config) Descriptor deprecated 

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) ProtoReflect 

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

func (*Config) Reset 

func (x *Config) Reset()

func (*Config) String 

func (x *Config) String() string

type GetTrackedSubscriptionStatusRequest 

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

func (*GetTrackedSubscriptionStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetTrackedSubscriptionStatusRequest.ProtoReflect.Descriptor instead.

func (*GetTrackedSubscriptionStatusRequest) GetName 

func (x *GetTrackedSubscriptionStatusRequest) GetName() string

func (*GetTrackedSubscriptionStatusRequest) ProtoMessage 

func (*GetTrackedSubscriptionStatusRequest) ProtoMessage()

func (*GetTrackedSubscriptionStatusRequest) ProtoReflect 

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

func (*GetTrackedSubscriptionStatusRequest) Reset 

func (x *GetTrackedSubscriptionStatusRequest) Reset()

func (*GetTrackedSubscriptionStatusRequest) String 

func (x *GetTrackedSubscriptionStatusRequest) String() string

type GetTrackedSubscriptionStatusResponse 

type GetTrackedSubscriptionStatusResponse struct {
	Status *subscription.TrackedSubscriptionStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTrackedSubscriptionStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetTrackedSubscriptionStatusResponse.ProtoReflect.Descriptor instead.

func (*GetTrackedSubscriptionStatusResponse) GetStatus 

func (x *GetTrackedSubscriptionStatusResponse) GetStatus() *subscription.TrackedSubscriptionStatus

func (*GetTrackedSubscriptionStatusResponse) ProtoMessage 

func (*GetTrackedSubscriptionStatusResponse) ProtoMessage()

func (*GetTrackedSubscriptionStatusResponse) ProtoReflect 

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

func (*GetTrackedSubscriptionStatusResponse) Reset 

func (x *GetTrackedSubscriptionStatusResponse) Reset()

func (*GetTrackedSubscriptionStatusResponse) String 

func (x *GetTrackedSubscriptionStatusResponse) String() string

type ListTrackedSubscriptionRequest 

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

func (*ListTrackedSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use ListTrackedSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*ListTrackedSubscriptionRequest) ProtoMessage 

func (*ListTrackedSubscriptionRequest) ProtoMessage()

func (*ListTrackedSubscriptionRequest) ProtoReflect 

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

func (*ListTrackedSubscriptionRequest) Reset 

func (x *ListTrackedSubscriptionRequest) Reset()

func (*ListTrackedSubscriptionRequest) String 

func (x *ListTrackedSubscriptionRequest) String() string

type ListTrackedSubscriptionResponse 

type ListTrackedSubscriptionResponse struct {
	Names []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTrackedSubscriptionResponse) Descriptor deprecated 

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

Deprecated: Use ListTrackedSubscriptionResponse.ProtoReflect.Descriptor instead.

func (*ListTrackedSubscriptionResponse) GetNames 

func (x *ListTrackedSubscriptionResponse) GetNames() []string

func (*ListTrackedSubscriptionResponse) ProtoMessage 

func (*ListTrackedSubscriptionResponse) ProtoMessage()

func (*ListTrackedSubscriptionResponse) ProtoReflect 

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

func (*ListTrackedSubscriptionResponse) Reset 

func (x *ListTrackedSubscriptionResponse) Reset()

func (*ListTrackedSubscriptionResponse) String 

func (x *ListTrackedSubscriptionResponse) String() string

type RemoveTrackedSubscriptionRequest 

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

func (*RemoveTrackedSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use RemoveTrackedSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*RemoveTrackedSubscriptionRequest) GetName 

func (x *RemoveTrackedSubscriptionRequest) GetName() string

func (*RemoveTrackedSubscriptionRequest) ProtoMessage 

func (*RemoveTrackedSubscriptionRequest) ProtoMessage()

func (*RemoveTrackedSubscriptionRequest) ProtoReflect 

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

func (*RemoveTrackedSubscriptionRequest) Reset 

func (x *RemoveTrackedSubscriptionRequest) Reset()

func (*RemoveTrackedSubscriptionRequest) String 

func (x *RemoveTrackedSubscriptionRequest) String() string

type RemoveTrackedSubscriptionResponse 

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

func (*RemoveTrackedSubscriptionResponse) Descriptor deprecated 

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

Deprecated: Use RemoveTrackedSubscriptionResponse.ProtoReflect.Descriptor instead.

func (*RemoveTrackedSubscriptionResponse) ProtoMessage 

func (*RemoveTrackedSubscriptionResponse) ProtoMessage()

func (*RemoveTrackedSubscriptionResponse) ProtoReflect 

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

func (*RemoveTrackedSubscriptionResponse) Reset 

func (x *RemoveTrackedSubscriptionResponse) Reset()

func (*RemoveTrackedSubscriptionResponse) String 

func (x *RemoveTrackedSubscriptionResponse) String() string

type SubscriptionManagerService 

type SubscriptionManagerService struct {
	UnimplementedSubscriptionManagerServiceServer
	// contains filtered or unexported fields
}

func NewSubscriptionManagerService 

func NewSubscriptionManagerService(manager subscription.SubscriptionManager) *SubscriptionManagerService

func (*SubscriptionManagerService) AddTrackedSubscription 

func (s *SubscriptionManagerService) AddTrackedSubscription(ctx context.Context, req *AddTrackedSubscriptionRequest) (*AddTrackedSubscriptionResponse, error)

func (*SubscriptionManagerService) GetTrackedSubscriptionStatus 

func (s *SubscriptionManagerService) GetTrackedSubscriptionStatus(ctx context.Context, req *GetTrackedSubscriptionStatusRequest) (*GetTrackedSubscriptionStatusResponse, error)

func (*SubscriptionManagerService) ListTrackedSubscription 

func (s *SubscriptionManagerService) ListTrackedSubscription(ctx context.Context, req *ListTrackedSubscriptionRequest) (*ListTrackedSubscriptionResponse, error)

func (*SubscriptionManagerService) Register 

func (s *SubscriptionManagerService) Register(server *grpc.Server)

func (*SubscriptionManagerService) RemoveTrackedSubscription 

func (s *SubscriptionManagerService) RemoveTrackedSubscription(ctx context.Context, req *RemoveTrackedSubscriptionRequest) (*RemoveTrackedSubscriptionResponse, error)

func (*SubscriptionManagerService) UpdateTrackedSubscription added in v5.28.0 

func (s *SubscriptionManagerService) UpdateTrackedSubscription(ctx context.Context, request *UpdateTrackedSubscriptionRequest) (*UpdateTrackedSubscriptionResponse, error)

type SubscriptionManagerServiceClient 

type SubscriptionManagerServiceClient interface {
	ListTrackedSubscription(ctx context.Context, in *ListTrackedSubscriptionRequest, opts ...grpc.CallOption) (*ListTrackedSubscriptionResponse, error)
	AddTrackedSubscription(ctx context.Context, in *AddTrackedSubscriptionRequest, opts ...grpc.CallOption) (*AddTrackedSubscriptionResponse, error)
	RemoveTrackedSubscription(ctx context.Context, in *RemoveTrackedSubscriptionRequest, opts ...grpc.CallOption) (*RemoveTrackedSubscriptionResponse, error)
	GetTrackedSubscriptionStatus(ctx context.Context, in *GetTrackedSubscriptionStatusRequest, opts ...grpc.CallOption) (*GetTrackedSubscriptionStatusResponse, error)
	UpdateTrackedSubscription(ctx context.Context, in *UpdateTrackedSubscriptionRequest, opts ...grpc.CallOption) (*UpdateTrackedSubscriptionResponse, error)
}

SubscriptionManagerServiceClient is the client API for SubscriptionManagerService 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 NewSubscriptionManagerServiceClient 

func NewSubscriptionManagerServiceClient(cc grpc.ClientConnInterface) SubscriptionManagerServiceClient

type SubscriptionManagerServiceServer 

type SubscriptionManagerServiceServer interface {
	ListTrackedSubscription(context.Context, *ListTrackedSubscriptionRequest) (*ListTrackedSubscriptionResponse, error)
	AddTrackedSubscription(context.Context, *AddTrackedSubscriptionRequest) (*AddTrackedSubscriptionResponse, error)
	RemoveTrackedSubscription(context.Context, *RemoveTrackedSubscriptionRequest) (*RemoveTrackedSubscriptionResponse, error)
	GetTrackedSubscriptionStatus(context.Context, *GetTrackedSubscriptionStatusRequest) (*GetTrackedSubscriptionStatusResponse, error)
	UpdateTrackedSubscription(context.Context, *UpdateTrackedSubscriptionRequest) (*UpdateTrackedSubscriptionResponse, error)
	// contains filtered or unexported methods
}

SubscriptionManagerServiceServer is the server API for SubscriptionManagerService service. All implementations must embed UnimplementedSubscriptionManagerServiceServer for forward compatibility.

type UnimplementedSubscriptionManagerServiceServer 

type UnimplementedSubscriptionManagerServiceServer struct{}

UnimplementedSubscriptionManagerServiceServer must 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 (UnimplementedSubscriptionManagerServiceServer) AddTrackedSubscription 

func (UnimplementedSubscriptionManagerServiceServer) AddTrackedSubscription(context.Context, *AddTrackedSubscriptionRequest) (*AddTrackedSubscriptionResponse, error)

func (UnimplementedSubscriptionManagerServiceServer) GetTrackedSubscriptionStatus 

func (UnimplementedSubscriptionManagerServiceServer) GetTrackedSubscriptionStatus(context.Context, *GetTrackedSubscriptionStatusRequest) (*GetTrackedSubscriptionStatusResponse, error)

func (UnimplementedSubscriptionManagerServiceServer) ListTrackedSubscription 

func (UnimplementedSubscriptionManagerServiceServer) ListTrackedSubscription(context.Context, *ListTrackedSubscriptionRequest) (*ListTrackedSubscriptionResponse, error)

func (UnimplementedSubscriptionManagerServiceServer) RemoveTrackedSubscription 

func (UnimplementedSubscriptionManagerServiceServer) RemoveTrackedSubscription(context.Context, *RemoveTrackedSubscriptionRequest) (*RemoveTrackedSubscriptionResponse, error)

func (UnimplementedSubscriptionManagerServiceServer) UpdateTrackedSubscription added in v5.28.0 

func (UnimplementedSubscriptionManagerServiceServer) UpdateTrackedSubscription(context.Context, *UpdateTrackedSubscriptionRequest) (*UpdateTrackedSubscriptionResponse, error)

type UnsafeSubscriptionManagerServiceServer 

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

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

type UpdateTrackedSubscriptionRequest added in v5.28.0 

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

func (*UpdateTrackedSubscriptionRequest) Descriptor deprecated added in v5.28.0 

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

Deprecated: Use UpdateTrackedSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*UpdateTrackedSubscriptionRequest) GetName added in v5.28.0 

func (x *UpdateTrackedSubscriptionRequest) GetName() string

func (*UpdateTrackedSubscriptionRequest) ProtoMessage added in v5.28.0 

func (*UpdateTrackedSubscriptionRequest) ProtoMessage()

func (*UpdateTrackedSubscriptionRequest) ProtoReflect added in v5.28.0 

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

func (*UpdateTrackedSubscriptionRequest) Reset added in v5.28.0 

func (x *UpdateTrackedSubscriptionRequest) Reset()

func (*UpdateTrackedSubscriptionRequest) String added in v5.28.0 

func (x *UpdateTrackedSubscriptionRequest) String() string

type UpdateTrackedSubscriptionResponse added in v5.28.0 

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

func (*UpdateTrackedSubscriptionResponse) Descriptor deprecated added in v5.28.0 

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

Deprecated: Use UpdateTrackedSubscriptionResponse.ProtoReflect.Descriptor instead.

func (*UpdateTrackedSubscriptionResponse) ProtoMessage added in v5.28.0 

func (*UpdateTrackedSubscriptionResponse) ProtoMessage()

func (*UpdateTrackedSubscriptionResponse) ProtoReflect added in v5.28.0 

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

func (*UpdateTrackedSubscriptionResponse) Reset added in v5.28.0 

func (x *UpdateTrackedSubscriptionResponse) Reset()

func (*UpdateTrackedSubscriptionResponse) String added in v5.28.0 

func (x *UpdateTrackedSubscriptionResponse) String() string

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.