daemon

package
v1.13.0-beta.6 Latest Latest
Warning

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

 Go to latest Published: Jan 16, 2026 License: GPL-2.0 Imports: 35 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	StartedService_StopService_FullMethodName            = "/daemon.StartedService/StopService"
	StartedService_ReloadService_FullMethodName          = "/daemon.StartedService/ReloadService"
	StartedService_SubscribeServiceStatus_FullMethodName = "/daemon.StartedService/SubscribeServiceStatus"
	StartedService_SubscribeLog_FullMethodName           = "/daemon.StartedService/SubscribeLog"
	StartedService_GetDefaultLogLevel_FullMethodName     = "/daemon.StartedService/GetDefaultLogLevel"
	StartedService_ClearLogs_FullMethodName              = "/daemon.StartedService/ClearLogs"
	StartedService_SubscribeStatus_FullMethodName        = "/daemon.StartedService/SubscribeStatus"
	StartedService_SubscribeGroups_FullMethodName        = "/daemon.StartedService/SubscribeGroups"
	StartedService_GetClashModeStatus_FullMethodName     = "/daemon.StartedService/GetClashModeStatus"
	StartedService_SubscribeClashMode_FullMethodName     = "/daemon.StartedService/SubscribeClashMode"
	StartedService_SetClashMode_FullMethodName           = "/daemon.StartedService/SetClashMode"
	StartedService_URLTest_FullMethodName                = "/daemon.StartedService/URLTest"
	StartedService_SelectOutbound_FullMethodName         = "/daemon.StartedService/SelectOutbound"
	StartedService_SetGroupExpand_FullMethodName         = "/daemon.StartedService/SetGroupExpand"
	StartedService_GetSystemProxyStatus_FullMethodName   = "/daemon.StartedService/GetSystemProxyStatus"
	StartedService_SetSystemProxyEnabled_FullMethodName  = "/daemon.StartedService/SetSystemProxyEnabled"
	StartedService_SubscribeConnections_FullMethodName   = "/daemon.StartedService/SubscribeConnections"
	StartedService_CloseConnection_FullMethodName        = "/daemon.StartedService/CloseConnection"
	StartedService_CloseAllConnections_FullMethodName    = "/daemon.StartedService/CloseAllConnections"
	StartedService_GetDeprecatedWarnings_FullMethodName  = "/daemon.StartedService/GetDeprecatedWarnings"
	StartedService_GetStartedAt_FullMethodName           = "/daemon.StartedService/GetStartedAt"
)

Variables

View Source 
var (
	LogLevel_name = map[int32]string{
		0: "PANIC",
		1: "FATAL",
		2: "ERROR",
		3: "WARN",
		4: "INFO",
		5: "DEBUG",
		6: "TRACE",
	}
	LogLevel_value = map[string]int32{
		"PANIC": 0,
		"FATAL": 1,
		"ERROR": 2,
		"WARN":  3,
		"INFO":  4,
		"DEBUG": 5,
		"TRACE": 6,
	}
)

Enum value maps for LogLevel.

View Source 
var (
	ConnectionEventType_name = map[int32]string{
		0: "CONNECTION_EVENT_NEW",
		1: "CONNECTION_EVENT_UPDATE",
		2: "CONNECTION_EVENT_CLOSED",
	}
	ConnectionEventType_value = map[string]int32{
		"CONNECTION_EVENT_NEW":    0,
		"CONNECTION_EVENT_UPDATE": 1,
		"CONNECTION_EVENT_CLOSED": 2,
	}
)

Enum value maps for ConnectionEventType.

View Source 
var (
	ServiceStatus_Type_name = map[int32]string{
		0: "IDLE",
		1: "STARTING",
		2: "STARTED",
		3: "STOPPING",
		4: "FATAL",
	}
	ServiceStatus_Type_value = map[string]int32{
		"IDLE":     0,
		"STARTING": 1,
		"STARTED":  2,
		"STOPPING": 3,
		"FATAL":    4,
	}
)

Enum value maps for ServiceStatus_Type.

View Source 
var File_daemon_started_service_proto protoreflect.FileDescriptor
View Source 
var StartedService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "daemon.StartedService",
	HandlerType: (*StartedServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StopService",
			Handler:    _StartedService_StopService_Handler,
		},
		{
			MethodName: "ReloadService",
			Handler:    _StartedService_ReloadService_Handler,
		},
		{
			MethodName: "GetDefaultLogLevel",
			Handler:    _StartedService_GetDefaultLogLevel_Handler,
		},
		{
			MethodName: "ClearLogs",
			Handler:    _StartedService_ClearLogs_Handler,
		},
		{
			MethodName: "GetClashModeStatus",
			Handler:    _StartedService_GetClashModeStatus_Handler,
		},
		{
			MethodName: "SetClashMode",
			Handler:    _StartedService_SetClashMode_Handler,
		},
		{
			MethodName: "URLTest",
			Handler:    _StartedService_URLTest_Handler,
		},
		{
			MethodName: "SelectOutbound",
			Handler:    _StartedService_SelectOutbound_Handler,
		},
		{
			MethodName: "SetGroupExpand",
			Handler:    _StartedService_SetGroupExpand_Handler,
		},
		{
			MethodName: "GetSystemProxyStatus",
			Handler:    _StartedService_GetSystemProxyStatus_Handler,
		},
		{
			MethodName: "SetSystemProxyEnabled",
			Handler:    _StartedService_SetSystemProxyEnabled_Handler,
		},
		{
			MethodName: "CloseConnection",
			Handler:    _StartedService_CloseConnection_Handler,
		},
		{
			MethodName: "CloseAllConnections",
			Handler:    _StartedService_CloseAllConnections_Handler,
		},
		{
			MethodName: "GetDeprecatedWarnings",
			Handler:    _StartedService_GetDeprecatedWarnings_Handler,
		},
		{
			MethodName: "GetStartedAt",
			Handler:    _StartedService_GetStartedAt_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubscribeServiceStatus",
			Handler:       _StartedService_SubscribeServiceStatus_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeLog",
			Handler:       _StartedService_SubscribeLog_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeStatus",
			Handler:       _StartedService_SubscribeStatus_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeGroups",
			Handler:       _StartedService_SubscribeGroups_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeClashMode",
			Handler:       _StartedService_SubscribeClashMode_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeConnections",
			Handler:       _StartedService_SubscribeConnections_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "daemon/started_service.proto",
}

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

Functions

func RegisterStartedServiceServer 

func RegisterStartedServiceServer(s grpc.ServiceRegistrar, srv StartedServiceServer)

Types

type ClashMode 

type ClashMode struct {
	Mode string `protobuf:"bytes,3,opt,name=mode,proto3" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

func (*ClashMode) Descriptor deprecated 

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

Deprecated: Use ClashMode.ProtoReflect.Descriptor instead.

func (*ClashMode) GetMode 

func (x *ClashMode) GetMode() string

func (*ClashMode) ProtoMessage 

func (*ClashMode) ProtoMessage()

func (*ClashMode) ProtoReflect 

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

func (*ClashMode) Reset 

func (x *ClashMode) Reset()

func (*ClashMode) String 

func (x *ClashMode) String() string

type ClashModeStatus 

type ClashModeStatus struct {
	ModeList    []string `protobuf:"bytes,1,rep,name=modeList,proto3" json:"modeList,omitempty"`
	CurrentMode string   `protobuf:"bytes,2,opt,name=currentMode,proto3" json:"currentMode,omitempty"`
	// contains filtered or unexported fields
}

func (*ClashModeStatus) Descriptor deprecated 

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

Deprecated: Use ClashModeStatus.ProtoReflect.Descriptor instead.

func (*ClashModeStatus) GetCurrentMode 

func (x *ClashModeStatus) GetCurrentMode() string

func (*ClashModeStatus) GetModeList 

func (x *ClashModeStatus) GetModeList() []string

func (*ClashModeStatus) ProtoMessage 

func (*ClashModeStatus) ProtoMessage()

func (*ClashModeStatus) ProtoReflect 

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

func (*ClashModeStatus) Reset 

func (x *ClashModeStatus) Reset()

func (*ClashModeStatus) String 

func (x *ClashModeStatus) String() string

type CloseConnectionRequest 

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

func (*CloseConnectionRequest) Descriptor deprecated 

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

Deprecated: Use CloseConnectionRequest.ProtoReflect.Descriptor instead.

func (*CloseConnectionRequest) GetId 

func (x *CloseConnectionRequest) GetId() string

func (*CloseConnectionRequest) ProtoMessage 

func (*CloseConnectionRequest) ProtoMessage()

func (*CloseConnectionRequest) ProtoReflect 

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

func (*CloseConnectionRequest) Reset 

func (x *CloseConnectionRequest) Reset()

func (*CloseConnectionRequest) String 

func (x *CloseConnectionRequest) String() string

type Connection 

type Connection struct {
	Id            string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Inbound       string       `protobuf:"bytes,2,opt,name=inbound,proto3" json:"inbound,omitempty"`
	InboundType   string       `protobuf:"bytes,3,opt,name=inboundType,proto3" json:"inboundType,omitempty"`
	IpVersion     int32        `protobuf:"varint,4,opt,name=ipVersion,proto3" json:"ipVersion,omitempty"`
	Network       string       `protobuf:"bytes,5,opt,name=network,proto3" json:"network,omitempty"`
	Source        string       `protobuf:"bytes,6,opt,name=source,proto3" json:"source,omitempty"`
	Destination   string       `protobuf:"bytes,7,opt,name=destination,proto3" json:"destination,omitempty"`
	Domain        string       `protobuf:"bytes,8,opt,name=domain,proto3" json:"domain,omitempty"`
	Protocol      string       `protobuf:"bytes,9,opt,name=protocol,proto3" json:"protocol,omitempty"`
	User          string       `protobuf:"bytes,10,opt,name=user,proto3" json:"user,omitempty"`
	FromOutbound  string       `protobuf:"bytes,11,opt,name=fromOutbound,proto3" json:"fromOutbound,omitempty"`
	CreatedAt     int64        `protobuf:"varint,12,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	ClosedAt      int64        `protobuf:"varint,13,opt,name=closedAt,proto3" json:"closedAt,omitempty"`
	Uplink        int64        `protobuf:"varint,14,opt,name=uplink,proto3" json:"uplink,omitempty"`
	Downlink      int64        `protobuf:"varint,15,opt,name=downlink,proto3" json:"downlink,omitempty"`
	UplinkTotal   int64        `protobuf:"varint,16,opt,name=uplinkTotal,proto3" json:"uplinkTotal,omitempty"`
	DownlinkTotal int64        `protobuf:"varint,17,opt,name=downlinkTotal,proto3" json:"downlinkTotal,omitempty"`
	Rule          string       `protobuf:"bytes,18,opt,name=rule,proto3" json:"rule,omitempty"`
	Outbound      string       `protobuf:"bytes,19,opt,name=outbound,proto3" json:"outbound,omitempty"`
	OutboundType  string       `protobuf:"bytes,20,opt,name=outboundType,proto3" json:"outboundType,omitempty"`
	ChainList     []string     `protobuf:"bytes,21,rep,name=chainList,proto3" json:"chainList,omitempty"`
	ProcessInfo   *ProcessInfo `protobuf:"bytes,22,opt,name=processInfo,proto3" json:"processInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*Connection) Descriptor deprecated 

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

Deprecated: Use Connection.ProtoReflect.Descriptor instead.

func (*Connection) GetChainList 

func (x *Connection) GetChainList() []string

func (*Connection) GetClosedAt 

func (x *Connection) GetClosedAt() int64

func (*Connection) GetCreatedAt 

func (x *Connection) GetCreatedAt() int64

func (*Connection) GetDestination 

func (x *Connection) GetDestination() string

func (*Connection) GetDomain 

func (x *Connection) GetDomain() string
func (x *Connection) GetDownlink() int64

func (*Connection) GetDownlinkTotal 

func (x *Connection) GetDownlinkTotal() int64

func (*Connection) GetFromOutbound 

func (x *Connection) GetFromOutbound() string

func (*Connection) GetId 

func (x *Connection) GetId() string

func (*Connection) GetInbound 

func (x *Connection) GetInbound() string

func (*Connection) GetInboundType 

func (x *Connection) GetInboundType() string

func (*Connection) GetIpVersion 

func (x *Connection) GetIpVersion() int32

func (*Connection) GetNetwork 

func (x *Connection) GetNetwork() string

func (*Connection) GetOutbound 

func (x *Connection) GetOutbound() string

func (*Connection) GetOutboundType 

func (x *Connection) GetOutboundType() string

func (*Connection) GetProcessInfo 

func (x *Connection) GetProcessInfo() *ProcessInfo

func (*Connection) GetProtocol 

func (x *Connection) GetProtocol() string

func (*Connection) GetRule 

func (x *Connection) GetRule() string

func (*Connection) GetSource 

func (x *Connection) GetSource() string
func (x *Connection) GetUplink() int64

func (*Connection) GetUplinkTotal 

func (x *Connection) GetUplinkTotal() int64

func (*Connection) GetUser 

func (x *Connection) GetUser() string

func (*Connection) ProtoMessage 

func (*Connection) ProtoMessage()

func (*Connection) ProtoReflect 

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

func (*Connection) Reset 

func (x *Connection) Reset()

func (*Connection) String 

func (x *Connection) String() string

type ConnectionEvent 

type ConnectionEvent struct {
	Type          ConnectionEventType `protobuf:"varint,1,opt,name=type,proto3,enum=daemon.ConnectionEventType" json:"type,omitempty"`
	Id            string              `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Connection    *Connection         `protobuf:"bytes,3,opt,name=connection,proto3" json:"connection,omitempty"`
	UplinkDelta   int64               `protobuf:"varint,4,opt,name=uplinkDelta,proto3" json:"uplinkDelta,omitempty"`
	DownlinkDelta int64               `protobuf:"varint,5,opt,name=downlinkDelta,proto3" json:"downlinkDelta,omitempty"`
	ClosedAt      int64               `protobuf:"varint,6,opt,name=closedAt,proto3" json:"closedAt,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionEvent) Descriptor deprecated 

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

Deprecated: Use ConnectionEvent.ProtoReflect.Descriptor instead.

func (*ConnectionEvent) GetClosedAt 

func (x *ConnectionEvent) GetClosedAt() int64

func (*ConnectionEvent) GetConnection 

func (x *ConnectionEvent) GetConnection() *Connection

func (*ConnectionEvent) GetDownlinkDelta 

func (x *ConnectionEvent) GetDownlinkDelta() int64

func (*ConnectionEvent) GetId 

func (x *ConnectionEvent) GetId() string

func (*ConnectionEvent) GetType 

func (x *ConnectionEvent) GetType() ConnectionEventType

func (*ConnectionEvent) GetUplinkDelta 

func (x *ConnectionEvent) GetUplinkDelta() int64

func (*ConnectionEvent) ProtoMessage 

func (*ConnectionEvent) ProtoMessage()

func (*ConnectionEvent) ProtoReflect 

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

func (*ConnectionEvent) Reset 

func (x *ConnectionEvent) Reset()

func (*ConnectionEvent) String 

func (x *ConnectionEvent) String() string

type ConnectionEventType 

type ConnectionEventType int32
const (
	ConnectionEventType_CONNECTION_EVENT_NEW    ConnectionEventType = 0
	ConnectionEventType_CONNECTION_EVENT_UPDATE ConnectionEventType = 1
	ConnectionEventType_CONNECTION_EVENT_CLOSED ConnectionEventType = 2
)

func (ConnectionEventType) Descriptor 

func (ConnectionEventType) Descriptor() protoreflect.EnumDescriptor

func (ConnectionEventType) Enum 

func (x ConnectionEventType) Enum() *ConnectionEventType

func (ConnectionEventType) EnumDescriptor deprecated 

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

Deprecated: Use ConnectionEventType.Descriptor instead.

func (ConnectionEventType) Number 

func (x ConnectionEventType) Number() protoreflect.EnumNumber

func (ConnectionEventType) String 

func (x ConnectionEventType) String() string

func (ConnectionEventType) Type 

func (ConnectionEventType) Type() protoreflect.EnumType

type ConnectionEvents 

type ConnectionEvents struct {
	Events []*ConnectionEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	Reset_ bool               `protobuf:"varint,2,opt,name=reset,proto3" json:"reset,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionEvents) Descriptor deprecated 

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

Deprecated: Use ConnectionEvents.ProtoReflect.Descriptor instead.

func (*ConnectionEvents) GetEvents 

func (x *ConnectionEvents) GetEvents() []*ConnectionEvent

func (*ConnectionEvents) GetReset_ 

func (x *ConnectionEvents) GetReset_() bool

func (*ConnectionEvents) ProtoMessage 

func (*ConnectionEvents) ProtoMessage()

func (*ConnectionEvents) ProtoReflect 

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

func (*ConnectionEvents) Reset 

func (x *ConnectionEvents) Reset()

func (*ConnectionEvents) String 

func (x *ConnectionEvents) String() string

type DefaultLogLevel 

type DefaultLogLevel struct {
	Level LogLevel `protobuf:"varint,1,opt,name=level,proto3,enum=daemon.LogLevel" json:"level,omitempty"`
	// contains filtered or unexported fields
}

func (*DefaultLogLevel) Descriptor deprecated 

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

Deprecated: Use DefaultLogLevel.ProtoReflect.Descriptor instead.

func (*DefaultLogLevel) GetLevel 

func (x *DefaultLogLevel) GetLevel() LogLevel

func (*DefaultLogLevel) ProtoMessage 

func (*DefaultLogLevel) ProtoMessage()

func (*DefaultLogLevel) ProtoReflect 

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

func (*DefaultLogLevel) Reset 

func (x *DefaultLogLevel) Reset()

func (*DefaultLogLevel) String 

func (x *DefaultLogLevel) String() string

type DeprecatedWarning 

type DeprecatedWarning struct {
	Message       string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Impending     bool   `protobuf:"varint,2,opt,name=impending,proto3" json:"impending,omitempty"`
	MigrationLink string `protobuf:"bytes,3,opt,name=migrationLink,proto3" json:"migrationLink,omitempty"`
	// contains filtered or unexported fields
}

func (*DeprecatedWarning) Descriptor deprecated 

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

Deprecated: Use DeprecatedWarning.ProtoReflect.Descriptor instead.

func (*DeprecatedWarning) GetImpending 

func (x *DeprecatedWarning) GetImpending() bool

func (*DeprecatedWarning) GetMessage 

func (x *DeprecatedWarning) GetMessage() string
func (x *DeprecatedWarning) GetMigrationLink() string

func (*DeprecatedWarning) ProtoMessage 

func (*DeprecatedWarning) ProtoMessage()

func (*DeprecatedWarning) ProtoReflect 

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

func (*DeprecatedWarning) Reset 

func (x *DeprecatedWarning) Reset()

func (*DeprecatedWarning) String 

func (x *DeprecatedWarning) String() string

type DeprecatedWarnings 

type DeprecatedWarnings struct {
	Warnings []*DeprecatedWarning `protobuf:"bytes,1,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// contains filtered or unexported fields
}

func (*DeprecatedWarnings) Descriptor deprecated 

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

Deprecated: Use DeprecatedWarnings.ProtoReflect.Descriptor instead.

func (*DeprecatedWarnings) GetWarnings 

func (x *DeprecatedWarnings) GetWarnings() []*DeprecatedWarning

func (*DeprecatedWarnings) ProtoMessage 

func (*DeprecatedWarnings) ProtoMessage()

func (*DeprecatedWarnings) ProtoReflect 

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

func (*DeprecatedWarnings) Reset 

func (x *DeprecatedWarnings) Reset()

func (*DeprecatedWarnings) String 

func (x *DeprecatedWarnings) String() string

type Group 

type Group struct {
	Tag        string       `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	Type       string       `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Selectable bool         `protobuf:"varint,3,opt,name=selectable,proto3" json:"selectable,omitempty"`
	Selected   string       `protobuf:"bytes,4,opt,name=selected,proto3" json:"selected,omitempty"`
	IsExpand   bool         `protobuf:"varint,5,opt,name=isExpand,proto3" json:"isExpand,omitempty"`
	Items      []*GroupItem `protobuf:"bytes,6,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*Group) Descriptor deprecated 

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

Deprecated: Use Group.ProtoReflect.Descriptor instead.

func (*Group) GetIsExpand 

func (x *Group) GetIsExpand() bool

func (*Group) GetItems 

func (x *Group) GetItems() []*GroupItem

func (*Group) GetSelectable 

func (x *Group) GetSelectable() bool

func (*Group) GetSelected 

func (x *Group) GetSelected() string

func (*Group) GetTag 

func (x *Group) GetTag() string

func (*Group) GetType 

func (x *Group) GetType() string

func (*Group) ProtoMessage 

func (*Group) ProtoMessage()

func (*Group) ProtoReflect 

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

func (*Group) Reset 

func (x *Group) Reset()

func (*Group) String 

func (x *Group) String() string

type GroupItem 

type GroupItem struct {
	Tag          string `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	Type         string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	UrlTestTime  int64  `protobuf:"varint,3,opt,name=urlTestTime,proto3" json:"urlTestTime,omitempty"`
	UrlTestDelay int32  `protobuf:"varint,4,opt,name=urlTestDelay,proto3" json:"urlTestDelay,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupItem) Descriptor deprecated 

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

Deprecated: Use GroupItem.ProtoReflect.Descriptor instead.

func (*GroupItem) GetTag 

func (x *GroupItem) GetTag() string

func (*GroupItem) GetType 

func (x *GroupItem) GetType() string

func (*GroupItem) GetUrlTestDelay 

func (x *GroupItem) GetUrlTestDelay() int32

func (*GroupItem) GetUrlTestTime 

func (x *GroupItem) GetUrlTestTime() int64

func (*GroupItem) ProtoMessage 

func (*GroupItem) ProtoMessage()

func (*GroupItem) ProtoReflect 

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

func (*GroupItem) Reset 

func (x *GroupItem) Reset()

func (*GroupItem) String 

func (x *GroupItem) String() string

type Groups 

type Groups struct {
	Group []*Group `protobuf:"bytes,1,rep,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*Groups) Descriptor deprecated 

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

Deprecated: Use Groups.ProtoReflect.Descriptor instead.

func (*Groups) GetGroup 

func (x *Groups) GetGroup() []*Group

func (*Groups) ProtoMessage 

func (*Groups) ProtoMessage()

func (*Groups) ProtoReflect 

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

func (*Groups) Reset 

func (x *Groups) Reset()

func (*Groups) String 

func (x *Groups) String() string

type Instance 

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

func (*Instance) Box 

func (i *Instance) Box() *box.Box

func (*Instance) Close 

func (i *Instance) Close() error

func (*Instance) PauseManager 

func (i *Instance) PauseManager() pause.Manager

func (*Instance) Start 

func (i *Instance) Start() error

type Log 

type Log struct {
	Messages []*Log_Message `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	Reset_   bool           `protobuf:"varint,2,opt,name=reset,proto3" json:"reset,omitempty"`
	// contains filtered or unexported fields
}

func (*Log) Descriptor deprecated 

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

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetMessages 

func (x *Log) GetMessages() []*Log_Message

func (*Log) GetReset_ 

func (x *Log) GetReset_() bool

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) ProtoReflect 

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

func (*Log) Reset 

func (x *Log) Reset()

func (*Log) String 

func (x *Log) String() string

type LogLevel 

type LogLevel int32
const (
	LogLevel_PANIC LogLevel = 0
	LogLevel_FATAL LogLevel = 1
	LogLevel_ERROR LogLevel = 2
	LogLevel_WARN  LogLevel = 3
	LogLevel_INFO  LogLevel = 4
	LogLevel_DEBUG LogLevel = 5
	LogLevel_TRACE LogLevel = 6
)

func (LogLevel) Descriptor 

func (LogLevel) Descriptor() protoreflect.EnumDescriptor

func (LogLevel) Enum 

func (x LogLevel) Enum() *LogLevel

func (LogLevel) EnumDescriptor deprecated 

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

Deprecated: Use LogLevel.Descriptor instead.

func (LogLevel) Number 

func (x LogLevel) Number() protoreflect.EnumNumber

func (LogLevel) String 

func (x LogLevel) String() string

func (LogLevel) Type 

func (LogLevel) Type() protoreflect.EnumType

type Log_Message 

type Log_Message struct {
	Level   LogLevel `protobuf:"varint,1,opt,name=level,proto3,enum=daemon.LogLevel" json:"level,omitempty"`
	Message string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Log_Message) Descriptor deprecated 

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

Deprecated: Use Log_Message.ProtoReflect.Descriptor instead.

func (*Log_Message) GetLevel 

func (x *Log_Message) GetLevel() LogLevel

func (*Log_Message) GetMessage 

func (x *Log_Message) GetMessage() string

func (*Log_Message) ProtoMessage 

func (*Log_Message) ProtoMessage()

func (*Log_Message) ProtoReflect 

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

func (*Log_Message) Reset 

func (x *Log_Message) Reset()

func (*Log_Message) String 

func (x *Log_Message) String() string

type OverrideOptions 

type OverrideOptions struct {
	AutoRedirect   bool
	IncludePackage []string
	ExcludePackage []string
}

type PlatformHandler 

type PlatformHandler interface {
	ServiceStop() error
	ServiceReload() error
	SystemProxyStatus() (*SystemProxyStatus, error)
	SetSystemProxyEnabled(enabled bool) error
	WriteDebugMessage(message string)
}

type ProcessInfo 

type ProcessInfo struct {
	ProcessId   uint32 `protobuf:"varint,1,opt,name=processId,proto3" json:"processId,omitempty"`
	UserId      int32  `protobuf:"varint,2,opt,name=userId,proto3" json:"userId,omitempty"`
	UserName    string `protobuf:"bytes,3,opt,name=userName,proto3" json:"userName,omitempty"`
	ProcessPath string `protobuf:"bytes,4,opt,name=processPath,proto3" json:"processPath,omitempty"`
	PackageName string `protobuf:"bytes,5,opt,name=packageName,proto3" json:"packageName,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessInfo) Descriptor deprecated 

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

Deprecated: Use ProcessInfo.ProtoReflect.Descriptor instead.

func (*ProcessInfo) GetPackageName 

func (x *ProcessInfo) GetPackageName() string

func (*ProcessInfo) GetProcessId 

func (x *ProcessInfo) GetProcessId() uint32

func (*ProcessInfo) GetProcessPath 

func (x *ProcessInfo) GetProcessPath() string

func (*ProcessInfo) GetUserId 

func (x *ProcessInfo) GetUserId() int32

func (*ProcessInfo) GetUserName 

func (x *ProcessInfo) GetUserName() string

func (*ProcessInfo) ProtoMessage 

func (*ProcessInfo) ProtoMessage()

func (*ProcessInfo) ProtoReflect 

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

func (*ProcessInfo) Reset 

func (x *ProcessInfo) Reset()

func (*ProcessInfo) String 

func (x *ProcessInfo) String() string

type ReloadServiceRequest 

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

func (*ReloadServiceRequest) Descriptor deprecated 

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

Deprecated: Use ReloadServiceRequest.ProtoReflect.Descriptor instead.

func (*ReloadServiceRequest) GetNewProfileContent 

func (x *ReloadServiceRequest) GetNewProfileContent() string

func (*ReloadServiceRequest) ProtoMessage 

func (*ReloadServiceRequest) ProtoMessage()

func (*ReloadServiceRequest) ProtoReflect 

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

func (*ReloadServiceRequest) Reset 

func (x *ReloadServiceRequest) Reset()

func (*ReloadServiceRequest) String 

func (x *ReloadServiceRequest) String() string

type SelectOutboundRequest 

type SelectOutboundRequest struct {
	GroupTag    string `protobuf:"bytes,1,opt,name=groupTag,proto3" json:"groupTag,omitempty"`
	OutboundTag string `protobuf:"bytes,2,opt,name=outboundTag,proto3" json:"outboundTag,omitempty"`
	// contains filtered or unexported fields
}

func (*SelectOutboundRequest) Descriptor deprecated 

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

Deprecated: Use SelectOutboundRequest.ProtoReflect.Descriptor instead.

func (*SelectOutboundRequest) GetGroupTag 

func (x *SelectOutboundRequest) GetGroupTag() string

func (*SelectOutboundRequest) GetOutboundTag 

func (x *SelectOutboundRequest) GetOutboundTag() string

func (*SelectOutboundRequest) ProtoMessage 

func (*SelectOutboundRequest) ProtoMessage()

func (*SelectOutboundRequest) ProtoReflect 

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

func (*SelectOutboundRequest) Reset 

func (x *SelectOutboundRequest) Reset()

func (*SelectOutboundRequest) String 

func (x *SelectOutboundRequest) String() string

type ServiceOptions 

type ServiceOptions struct {
	Context context.Context
	// Platform           adapter.PlatformInterface
	Handler     PlatformHandler
	Debug       bool
	LogMaxLines int
}

type ServiceStatus 

type ServiceStatus struct {
	Status       ServiceStatus_Type `protobuf:"varint,1,opt,name=status,proto3,enum=daemon.ServiceStatus_Type" json:"status,omitempty"`
	ErrorMessage string             `protobuf:"bytes,2,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceStatus) Descriptor deprecated 

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

Deprecated: Use ServiceStatus.ProtoReflect.Descriptor instead.

func (*ServiceStatus) GetErrorMessage 

func (x *ServiceStatus) GetErrorMessage() string

func (*ServiceStatus) GetStatus 

func (x *ServiceStatus) GetStatus() ServiceStatus_Type

func (*ServiceStatus) ProtoMessage 

func (*ServiceStatus) ProtoMessage()

func (*ServiceStatus) ProtoReflect 

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

func (*ServiceStatus) Reset 

func (x *ServiceStatus) Reset()

func (*ServiceStatus) String 

func (x *ServiceStatus) String() string

type ServiceStatus_Type 

type ServiceStatus_Type int32
const (
	ServiceStatus_IDLE     ServiceStatus_Type = 0
	ServiceStatus_STARTING ServiceStatus_Type = 1
	ServiceStatus_STARTED  ServiceStatus_Type = 2
	ServiceStatus_STOPPING ServiceStatus_Type = 3
	ServiceStatus_FATAL    ServiceStatus_Type = 4
)

func (ServiceStatus_Type) Descriptor 

func (ServiceStatus_Type) Descriptor() protoreflect.EnumDescriptor

func (ServiceStatus_Type) Enum 

func (x ServiceStatus_Type) Enum() *ServiceStatus_Type

func (ServiceStatus_Type) EnumDescriptor deprecated 

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

Deprecated: Use ServiceStatus_Type.Descriptor instead.

func (ServiceStatus_Type) Number 

func (x ServiceStatus_Type) Number() protoreflect.EnumNumber

func (ServiceStatus_Type) String 

func (x ServiceStatus_Type) String() string

func (ServiceStatus_Type) Type 

func (ServiceStatus_Type) Type() protoreflect.EnumType

type SetGroupExpandRequest 

type SetGroupExpandRequest struct {
	GroupTag string `protobuf:"bytes,1,opt,name=groupTag,proto3" json:"groupTag,omitempty"`
	IsExpand bool   `protobuf:"varint,2,opt,name=isExpand,proto3" json:"isExpand,omitempty"`
	// contains filtered or unexported fields
}

func (*SetGroupExpandRequest) Descriptor deprecated 

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

Deprecated: Use SetGroupExpandRequest.ProtoReflect.Descriptor instead.

func (*SetGroupExpandRequest) GetGroupTag 

func (x *SetGroupExpandRequest) GetGroupTag() string

func (*SetGroupExpandRequest) GetIsExpand 

func (x *SetGroupExpandRequest) GetIsExpand() bool

func (*SetGroupExpandRequest) ProtoMessage 

func (*SetGroupExpandRequest) ProtoMessage()

func (*SetGroupExpandRequest) ProtoReflect 

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

func (*SetGroupExpandRequest) Reset 

func (x *SetGroupExpandRequest) Reset()

func (*SetGroupExpandRequest) String 

func (x *SetGroupExpandRequest) String() string

type SetSystemProxyEnabledRequest 

type SetSystemProxyEnabledRequest struct {
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

func (*SetSystemProxyEnabledRequest) Descriptor deprecated 

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

Deprecated: Use SetSystemProxyEnabledRequest.ProtoReflect.Descriptor instead.

func (*SetSystemProxyEnabledRequest) GetEnabled 

func (x *SetSystemProxyEnabledRequest) GetEnabled() bool

func (*SetSystemProxyEnabledRequest) ProtoMessage 

func (*SetSystemProxyEnabledRequest) ProtoMessage()

func (*SetSystemProxyEnabledRequest) ProtoReflect 

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

func (*SetSystemProxyEnabledRequest) Reset 

func (x *SetSystemProxyEnabledRequest) Reset()

func (*SetSystemProxyEnabledRequest) String 

func (x *SetSystemProxyEnabledRequest) String() string

type StartedAt 

type StartedAt struct {
	StartedAt int64 `protobuf:"varint,1,opt,name=startedAt,proto3" json:"startedAt,omitempty"`
	// contains filtered or unexported fields
}

func (*StartedAt) Descriptor deprecated 

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

Deprecated: Use StartedAt.ProtoReflect.Descriptor instead.

func (*StartedAt) GetStartedAt 

func (x *StartedAt) GetStartedAt() int64

func (*StartedAt) ProtoMessage 

func (*StartedAt) ProtoMessage()

func (*StartedAt) ProtoReflect 

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

func (*StartedAt) Reset 

func (x *StartedAt) Reset()

func (*StartedAt) String 

func (x *StartedAt) String() string

type StartedService 

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

func NewStartedService 

func NewStartedService(options ServiceOptions) *StartedService

func (*StartedService) CheckConfig 

func (s *StartedService) CheckConfig(configContent string) error

func (*StartedService) ClearLogs 

func (s *StartedService) ClearLogs(ctx context.Context, empty *emptypb.Empty) (*emptypb.Empty, error)

func (*StartedService) CloseAllConnections 

func (s *StartedService) CloseAllConnections(ctx context.Context, empty *emptypb.Empty) (*emptypb.Empty, error)

func (*StartedService) CloseConnection 

func (s *StartedService) CloseConnection(ctx context.Context, request *CloseConnectionRequest) (*emptypb.Empty, error)

func (*StartedService) CloseService 

func (s *StartedService) CloseService() error

func (*StartedService) FormatConfig 

func (s *StartedService) FormatConfig(configContent string) (string, error)

func (*StartedService) GetClashModeStatus 

func (s *StartedService) GetClashModeStatus(ctx context.Context, empty *emptypb.Empty) (*ClashModeStatus, error)

func (*StartedService) GetDefaultLogLevel 

func (s *StartedService) GetDefaultLogLevel(ctx context.Context, empty *emptypb.Empty) (*DefaultLogLevel, error)

func (*StartedService) GetDeprecatedWarnings 

func (s *StartedService) GetDeprecatedWarnings(ctx context.Context, empty *emptypb.Empty) (*DeprecatedWarnings, error)

func (*StartedService) GetStartedAt 

func (s *StartedService) GetStartedAt(ctx context.Context, empty *emptypb.Empty) (*StartedAt, error)

func (*StartedService) GetSystemProxyStatus 

func (s *StartedService) GetSystemProxyStatus(ctx context.Context, empty *emptypb.Empty) (*SystemProxyStatus, error)

func (*StartedService) Instance 

func (s *StartedService) Instance() *Instance

func (*StartedService) ReloadService 

func (s *StartedService) ReloadService(ctx context.Context, empty *emptypb.Empty) (*emptypb.Empty, error)

func (*StartedService) SelectOutbound 

func (s *StartedService) SelectOutbound(ctx context.Context, request *SelectOutboundRequest) (*emptypb.Empty, error)

func (*StartedService) SetClashMode 

func (s *StartedService) SetClashMode(ctx context.Context, request *ClashMode) (*emptypb.Empty, error)

func (*StartedService) SetError 

func (s *StartedService) SetError(err error)

func (*StartedService) SetGroupExpand 

func (s *StartedService) SetGroupExpand(ctx context.Context, request *SetGroupExpandRequest) (*emptypb.Empty, error)

func (*StartedService) SetSystemProxyEnabled 

func (s *StartedService) SetSystemProxyEnabled(ctx context.Context, request *SetSystemProxyEnabledRequest) (*emptypb.Empty, error)

func (*StartedService) StartOrReloadService 

func (s *StartedService) StartOrReloadService(profileContent string, options *OverrideOptions) error

func (*StartedService) StopService 

func (s *StartedService) StopService(ctx context.Context, empty *emptypb.Empty) (*emptypb.Empty, error)

func (*StartedService) SubscribeClashMode 

func (s *StartedService) SubscribeClashMode(empty *emptypb.Empty, server grpc.ServerStreamingServer[ClashMode]) error

func (*StartedService) SubscribeConnections 

func (s *StartedService) SubscribeConnections(request *SubscribeConnectionsRequest, server grpc.ServerStreamingServer[ConnectionEvents]) error

func (*StartedService) SubscribeGroups 

func (s *StartedService) SubscribeGroups(empty *emptypb.Empty, server grpc.ServerStreamingServer[Groups]) error

func (*StartedService) SubscribeLog 

func (s *StartedService) SubscribeLog(empty *emptypb.Empty, server grpc.ServerStreamingServer[Log]) error

func (*StartedService) SubscribeServiceStatus 

func (s *StartedService) SubscribeServiceStatus(empty *emptypb.Empty, server grpc.ServerStreamingServer[ServiceStatus]) error

func (*StartedService) SubscribeStatus 

func (s *StartedService) SubscribeStatus(request *SubscribeStatusRequest, server grpc.ServerStreamingServer[Status]) error

func (*StartedService) URLTest 

func (s *StartedService) URLTest(ctx context.Context, request *URLTestRequest) (*emptypb.Empty, error)

func (*StartedService) WriteMessage 

func (s *StartedService) WriteMessage(level log.Level, message string)

type StartedServiceClient 

type StartedServiceClient interface {
	StopService(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReloadService(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SubscribeServiceStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ServiceStatus], error)
	SubscribeLog(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Log], error)
	GetDefaultLogLevel(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*DefaultLogLevel, error)
	ClearLogs(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SubscribeStatus(ctx context.Context, in *SubscribeStatusRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Status], error)
	SubscribeGroups(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Groups], error)
	GetClashModeStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ClashModeStatus, error)
	SubscribeClashMode(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ClashMode], error)
	SetClashMode(ctx context.Context, in *ClashMode, opts ...grpc.CallOption) (*emptypb.Empty, error)
	URLTest(ctx context.Context, in *URLTestRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SelectOutbound(ctx context.Context, in *SelectOutboundRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SetGroupExpand(ctx context.Context, in *SetGroupExpandRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetSystemProxyStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*SystemProxyStatus, error)
	SetSystemProxyEnabled(ctx context.Context, in *SetSystemProxyEnabledRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SubscribeConnections(ctx context.Context, in *SubscribeConnectionsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ConnectionEvents], error)
	CloseConnection(ctx context.Context, in *CloseConnectionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	CloseAllConnections(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetDeprecatedWarnings(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*DeprecatedWarnings, error)
	GetStartedAt(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*StartedAt, error)
}

StartedServiceClient is the client API for StartedService 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 NewStartedServiceClient 

func NewStartedServiceClient(cc grpc.ClientConnInterface) StartedServiceClient

type StartedServiceServer 

type StartedServiceServer interface {
	StopService(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	ReloadService(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	SubscribeServiceStatus(*emptypb.Empty, grpc.ServerStreamingServer[ServiceStatus]) error
	SubscribeLog(*emptypb.Empty, grpc.ServerStreamingServer[Log]) error
	GetDefaultLogLevel(context.Context, *emptypb.Empty) (*DefaultLogLevel, error)
	ClearLogs(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	SubscribeStatus(*SubscribeStatusRequest, grpc.ServerStreamingServer[Status]) error
	SubscribeGroups(*emptypb.Empty, grpc.ServerStreamingServer[Groups]) error
	GetClashModeStatus(context.Context, *emptypb.Empty) (*ClashModeStatus, error)
	SubscribeClashMode(*emptypb.Empty, grpc.ServerStreamingServer[ClashMode]) error
	SetClashMode(context.Context, *ClashMode) (*emptypb.Empty, error)
	URLTest(context.Context, *URLTestRequest) (*emptypb.Empty, error)
	SelectOutbound(context.Context, *SelectOutboundRequest) (*emptypb.Empty, error)
	SetGroupExpand(context.Context, *SetGroupExpandRequest) (*emptypb.Empty, error)
	GetSystemProxyStatus(context.Context, *emptypb.Empty) (*SystemProxyStatus, error)
	SetSystemProxyEnabled(context.Context, *SetSystemProxyEnabledRequest) (*emptypb.Empty, error)
	SubscribeConnections(*SubscribeConnectionsRequest, grpc.ServerStreamingServer[ConnectionEvents]) error
	CloseConnection(context.Context, *CloseConnectionRequest) (*emptypb.Empty, error)
	CloseAllConnections(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	GetDeprecatedWarnings(context.Context, *emptypb.Empty) (*DeprecatedWarnings, error)
	GetStartedAt(context.Context, *emptypb.Empty) (*StartedAt, error)
	// contains filtered or unexported methods
}

StartedServiceServer is the server API for StartedService service. All implementations must embed UnimplementedStartedServiceServer for forward compatibility.

type StartedService_SubscribeClashModeClient 

type StartedService_SubscribeClashModeClient = grpc.ServerStreamingClient[ClashMode]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type StartedService_SubscribeClashModeServer 

type StartedService_SubscribeClashModeServer = grpc.ServerStreamingServer[ClashMode]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type StartedService_SubscribeConnectionsClient 

type StartedService_SubscribeConnectionsClient = grpc.ServerStreamingClient[ConnectionEvents]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type StartedService_SubscribeConnectionsServer 

type StartedService_SubscribeConnectionsServer = grpc.ServerStreamingServer[ConnectionEvents]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type StartedService_SubscribeGroupsClient 

type StartedService_SubscribeGroupsClient = grpc.ServerStreamingClient[Groups]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type StartedService_SubscribeGroupsServer 

type StartedService_SubscribeGroupsServer = grpc.ServerStreamingServer[Groups]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type StartedService_SubscribeLogClient 

type StartedService_SubscribeLogClient = grpc.ServerStreamingClient[Log]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type StartedService_SubscribeLogServer 

type StartedService_SubscribeLogServer = grpc.ServerStreamingServer[Log]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type StartedService_SubscribeServiceStatusClient 

type StartedService_SubscribeServiceStatusClient = grpc.ServerStreamingClient[ServiceStatus]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type StartedService_SubscribeServiceStatusServer 

type StartedService_SubscribeServiceStatusServer = grpc.ServerStreamingServer[ServiceStatus]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type StartedService_SubscribeStatusClient 

type StartedService_SubscribeStatusClient = grpc.ServerStreamingClient[Status]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type StartedService_SubscribeStatusServer 

type StartedService_SubscribeStatusServer = grpc.ServerStreamingServer[Status]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Status 

type Status struct {
	Memory           uint64 `protobuf:"varint,1,opt,name=memory,proto3" json:"memory,omitempty"`
	Goroutines       int32  `protobuf:"varint,2,opt,name=goroutines,proto3" json:"goroutines,omitempty"`
	ConnectionsIn    int32  `protobuf:"varint,3,opt,name=connectionsIn,proto3" json:"connectionsIn,omitempty"`
	ConnectionsOut   int32  `protobuf:"varint,4,opt,name=connectionsOut,proto3" json:"connectionsOut,omitempty"`
	TrafficAvailable bool   `protobuf:"varint,5,opt,name=trafficAvailable,proto3" json:"trafficAvailable,omitempty"`
	Uplink           int64  `protobuf:"varint,6,opt,name=uplink,proto3" json:"uplink,omitempty"`
	Downlink         int64  `protobuf:"varint,7,opt,name=downlink,proto3" json:"downlink,omitempty"`
	UplinkTotal      int64  `protobuf:"varint,8,opt,name=uplinkTotal,proto3" json:"uplinkTotal,omitempty"`
	DownlinkTotal    int64  `protobuf:"varint,9,opt,name=downlinkTotal,proto3" json:"downlinkTotal,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetConnectionsIn 

func (x *Status) GetConnectionsIn() int32

func (*Status) GetConnectionsOut 

func (x *Status) GetConnectionsOut() int32
func (x *Status) GetDownlink() int64

func (*Status) GetDownlinkTotal 

func (x *Status) GetDownlinkTotal() int64

func (*Status) GetGoroutines 

func (x *Status) GetGoroutines() int32

func (*Status) GetMemory 

func (x *Status) GetMemory() uint64

func (*Status) GetTrafficAvailable 

func (x *Status) GetTrafficAvailable() bool
func (x *Status) GetUplink() int64

func (*Status) GetUplinkTotal 

func (x *Status) GetUplinkTotal() int64

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

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

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type SubscribeConnectionsRequest 

type SubscribeConnectionsRequest struct {
	Interval int64 `protobuf:"varint,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeConnectionsRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeConnectionsRequest.ProtoReflect.Descriptor instead.

func (*SubscribeConnectionsRequest) GetInterval 

func (x *SubscribeConnectionsRequest) GetInterval() int64

func (*SubscribeConnectionsRequest) ProtoMessage 

func (*SubscribeConnectionsRequest) ProtoMessage()

func (*SubscribeConnectionsRequest) ProtoReflect 

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

func (*SubscribeConnectionsRequest) Reset 

func (x *SubscribeConnectionsRequest) Reset()

func (*SubscribeConnectionsRequest) String 

func (x *SubscribeConnectionsRequest) String() string

type SubscribeStatusRequest 

type SubscribeStatusRequest struct {
	Interval int64 `protobuf:"varint,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeStatusRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeStatusRequest.ProtoReflect.Descriptor instead.

func (*SubscribeStatusRequest) GetInterval 

func (x *SubscribeStatusRequest) GetInterval() int64

func (*SubscribeStatusRequest) ProtoMessage 

func (*SubscribeStatusRequest) ProtoMessage()

func (*SubscribeStatusRequest) ProtoReflect 

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

func (*SubscribeStatusRequest) Reset 

func (x *SubscribeStatusRequest) Reset()

func (*SubscribeStatusRequest) String 

func (x *SubscribeStatusRequest) String() string

type SystemProxyStatus 

type SystemProxyStatus struct {
	Available bool `protobuf:"varint,1,opt,name=available,proto3" json:"available,omitempty"`
	Enabled   bool `protobuf:"varint,2,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

func (*SystemProxyStatus) Descriptor deprecated 

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

Deprecated: Use SystemProxyStatus.ProtoReflect.Descriptor instead.

func (*SystemProxyStatus) GetAvailable 

func (x *SystemProxyStatus) GetAvailable() bool

func (*SystemProxyStatus) GetEnabled 

func (x *SystemProxyStatus) GetEnabled() bool

func (*SystemProxyStatus) ProtoMessage 

func (*SystemProxyStatus) ProtoMessage()

func (*SystemProxyStatus) ProtoReflect 

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

func (*SystemProxyStatus) Reset 

func (x *SystemProxyStatus) Reset()

func (*SystemProxyStatus) String 

func (x *SystemProxyStatus) String() string

type URLTestRequest 

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

func (*URLTestRequest) Descriptor deprecated 

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

Deprecated: Use URLTestRequest.ProtoReflect.Descriptor instead.

func (*URLTestRequest) GetOutboundTag 

func (x *URLTestRequest) GetOutboundTag() string

func (*URLTestRequest) ProtoMessage 

func (*URLTestRequest) ProtoMessage()

func (*URLTestRequest) ProtoReflect 

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

func (*URLTestRequest) Reset 

func (x *URLTestRequest) Reset()

func (*URLTestRequest) String 

func (x *URLTestRequest) String() string

type UnimplementedStartedServiceServer 

type UnimplementedStartedServiceServer struct{}

UnimplementedStartedServiceServer 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 (UnimplementedStartedServiceServer) ClearLogs 

func (UnimplementedStartedServiceServer) ClearLogs(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedStartedServiceServer) CloseAllConnections 

func (UnimplementedStartedServiceServer) CloseAllConnections(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedStartedServiceServer) CloseConnection 

func (UnimplementedStartedServiceServer) CloseConnection(context.Context, *CloseConnectionRequest) (*emptypb.Empty, error)

func (UnimplementedStartedServiceServer) GetClashModeStatus 

func (UnimplementedStartedServiceServer) GetClashModeStatus(context.Context, *emptypb.Empty) (*ClashModeStatus, error)

func (UnimplementedStartedServiceServer) GetDefaultLogLevel 

func (UnimplementedStartedServiceServer) GetDefaultLogLevel(context.Context, *emptypb.Empty) (*DefaultLogLevel, error)

func (UnimplementedStartedServiceServer) GetDeprecatedWarnings 

func (UnimplementedStartedServiceServer) GetDeprecatedWarnings(context.Context, *emptypb.Empty) (*DeprecatedWarnings, error)

func (UnimplementedStartedServiceServer) GetStartedAt 

func (UnimplementedStartedServiceServer) GetStartedAt(context.Context, *emptypb.Empty) (*StartedAt, error)

func (UnimplementedStartedServiceServer) GetSystemProxyStatus 

func (UnimplementedStartedServiceServer) GetSystemProxyStatus(context.Context, *emptypb.Empty) (*SystemProxyStatus, error)

func (UnimplementedStartedServiceServer) ReloadService 

func (UnimplementedStartedServiceServer) ReloadService(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedStartedServiceServer) SelectOutbound 

func (UnimplementedStartedServiceServer) SelectOutbound(context.Context, *SelectOutboundRequest) (*emptypb.Empty, error)

func (UnimplementedStartedServiceServer) SetClashMode 

func (UnimplementedStartedServiceServer) SetClashMode(context.Context, *ClashMode) (*emptypb.Empty, error)

func (UnimplementedStartedServiceServer) SetGroupExpand 

func (UnimplementedStartedServiceServer) SetGroupExpand(context.Context, *SetGroupExpandRequest) (*emptypb.Empty, error)

func (UnimplementedStartedServiceServer) SetSystemProxyEnabled 

func (UnimplementedStartedServiceServer) SetSystemProxyEnabled(context.Context, *SetSystemProxyEnabledRequest) (*emptypb.Empty, error)

func (UnimplementedStartedServiceServer) StopService 

func (UnimplementedStartedServiceServer) StopService(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedStartedServiceServer) SubscribeClashMode 

func (UnimplementedStartedServiceServer) SubscribeClashMode(*emptypb.Empty, grpc.ServerStreamingServer[ClashMode]) error

func (UnimplementedStartedServiceServer) SubscribeConnections 

func (UnimplementedStartedServiceServer) SubscribeConnections(*SubscribeConnectionsRequest, grpc.ServerStreamingServer[ConnectionEvents]) error

func (UnimplementedStartedServiceServer) SubscribeGroups 

func (UnimplementedStartedServiceServer) SubscribeGroups(*emptypb.Empty, grpc.ServerStreamingServer[Groups]) error

func (UnimplementedStartedServiceServer) SubscribeLog 

func (UnimplementedStartedServiceServer) SubscribeLog(*emptypb.Empty, grpc.ServerStreamingServer[Log]) error

func (UnimplementedStartedServiceServer) SubscribeServiceStatus 

func (UnimplementedStartedServiceServer) SubscribeServiceStatus(*emptypb.Empty, grpc.ServerStreamingServer[ServiceStatus]) error

func (UnimplementedStartedServiceServer) SubscribeStatus 

func (UnimplementedStartedServiceServer) SubscribeStatus(*SubscribeStatusRequest, grpc.ServerStreamingServer[Status]) error

func (UnimplementedStartedServiceServer) URLTest 

func (UnimplementedStartedServiceServer) URLTest(context.Context, *URLTestRequest) (*emptypb.Empty, error)

type UnsafeStartedServiceServer 

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

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