service

package
v0.3.8 Latest Latest
Warning

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

 Go to latest Published: Feb 2, 2025 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Connections_Conns_FullMethodName         = "/yuhaiin.protos.statistic.service.connections/conns"
	Connections_CloseConn_FullMethodName     = "/yuhaiin.protos.statistic.service.connections/close_conn"
	Connections_Total_FullMethodName         = "/yuhaiin.protos.statistic.service.connections/total"
	Connections_Notify_FullMethodName        = "/yuhaiin.protos.statistic.service.connections/notify"
	Connections_FailedHistory_FullMethodName = "/yuhaiin.protos.statistic.service.connections/failed_history"
	Connections_AllHistory_FullMethodName    = "/yuhaiin.protos.statistic.service.connections/all_history"
)
View Source 
const NotifyData_Data_not_set_case case_NotifyData_Data = 0
View Source 
const NotifyData_NotifyNewConnections_case case_NotifyData_Data = 1
View Source 
const NotifyData_NotifyRemoveConnections_case case_NotifyData_Data = 2
View Source 
const NotifyData_TotalFlow_case case_NotifyData_Data = 3

Variables

View Source 
var Connections_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yuhaiin.protos.statistic.service.connections",
	HandlerType: (*ConnectionsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "conns",
			Handler:    _Connections_Conns_Handler,
		},
		{
			MethodName: "close_conn",
			Handler:    _Connections_CloseConn_Handler,
		},
		{
			MethodName: "total",
			Handler:    _Connections_Total_Handler,
		},
		{
			MethodName: "failed_history",
			Handler:    _Connections_FailedHistory_Handler,
		},
		{
			MethodName: "all_history",
			Handler:    _Connections_AllHistory_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "notify",
			Handler:       _Connections_Notify_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "statistic/grpc/config.proto",
}

Connections_ServiceDesc is the grpc.ServiceDesc for Connections 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_statistic_grpc_config_proto protoreflect.FileDescriptor

Functions

func RegisterConnectionsServer 

func RegisterConnectionsServer(s grpc.ServiceRegistrar, srv ConnectionsServer)

Types

type AllHistory added in v0.3.8 

type AllHistory struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*AllHistory) ClearConnection added in v0.3.8 

func (x *AllHistory) ClearConnection()

func (*AllHistory) ClearCount added in v0.3.8 

func (x *AllHistory) ClearCount()

func (*AllHistory) ClearTime added in v0.3.8 

func (x *AllHistory) ClearTime()

func (*AllHistory) GetConnection added in v0.3.8 

func (x *AllHistory) GetConnection() *statistic.Connection

func (*AllHistory) GetCount added in v0.3.8 

func (x *AllHistory) GetCount() uint64

func (*AllHistory) GetTime added in v0.3.8 

func (x *AllHistory) GetTime() *timestamppb.Timestamp

func (*AllHistory) HasConnection added in v0.3.8 

func (x *AllHistory) HasConnection() bool

func (*AllHistory) HasCount added in v0.3.8 

func (x *AllHistory) HasCount() bool

func (*AllHistory) HasTime added in v0.3.8 

func (x *AllHistory) HasTime() bool

func (*AllHistory) ProtoMessage added in v0.3.8 

func (*AllHistory) ProtoMessage()

func (*AllHistory) ProtoReflect added in v0.3.8 

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

func (*AllHistory) Reset added in v0.3.8 

func (x *AllHistory) Reset()

func (*AllHistory) SetConnection added in v0.3.8 

func (x *AllHistory) SetConnection(v *statistic.Connection)

func (*AllHistory) SetCount added in v0.3.8 

func (x *AllHistory) SetCount(v uint64)

func (*AllHistory) SetTime added in v0.3.8 

func (x *AllHistory) SetTime(v *timestamppb.Timestamp)

func (*AllHistory) String added in v0.3.8 

func (x *AllHistory) String() string

type AllHistoryList added in v0.3.8 

type AllHistoryList struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*AllHistoryList) ClearDumpProcessEnabled added in v0.3.8 

func (x *AllHistoryList) ClearDumpProcessEnabled()

func (*AllHistoryList) GetDumpProcessEnabled added in v0.3.8 

func (x *AllHistoryList) GetDumpProcessEnabled() bool

func (*AllHistoryList) GetObjects added in v0.3.8 

func (x *AllHistoryList) GetObjects() []*AllHistory

func (*AllHistoryList) HasDumpProcessEnabled added in v0.3.8 

func (x *AllHistoryList) HasDumpProcessEnabled() bool

func (*AllHistoryList) ProtoMessage added in v0.3.8 

func (*AllHistoryList) ProtoMessage()

func (*AllHistoryList) ProtoReflect added in v0.3.8 

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

func (*AllHistoryList) Reset added in v0.3.8 

func (x *AllHistoryList) Reset()

func (*AllHistoryList) SetDumpProcessEnabled added in v0.3.8 

func (x *AllHistoryList) SetDumpProcessEnabled(v bool)

func (*AllHistoryList) SetObjects added in v0.3.8 

func (x *AllHistoryList) SetObjects(v []*AllHistory)

func (*AllHistoryList) String added in v0.3.8 

func (x *AllHistoryList) String() string

type AllHistoryList_builder added in v0.3.8 

type AllHistoryList_builder struct {
	Objects            []*AllHistory
	DumpProcessEnabled *bool
	// contains filtered or unexported fields
}

func (AllHistoryList_builder) Build added in v0.3.8 

func (b0 AllHistoryList_builder) Build() *AllHistoryList

type AllHistory_builder added in v0.3.8 

type AllHistory_builder struct {
	Connection *statistic.Connection
	Count      *uint64
	Time       *timestamppb.Timestamp
	// contains filtered or unexported fields
}

func (AllHistory_builder) Build added in v0.3.8 

func (b0 AllHistory_builder) Build() *AllHistory

type ConnectionsClient 

type ConnectionsClient interface {
	Conns(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NotifyNewConnections, error)
	CloseConn(ctx context.Context, in *NotifyRemoveConnections, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Total(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*TotalFlow, error)
	Notify(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[NotifyData], error)
	FailedHistory(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*FailedHistoryList, error)
	AllHistory(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*AllHistoryList, error)
}

ConnectionsClient is the client API for Connections 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 NewConnectionsClient 

func NewConnectionsClient(cc grpc.ClientConnInterface) ConnectionsClient

type ConnectionsServer 

type ConnectionsServer interface {
	Conns(context.Context, *emptypb.Empty) (*NotifyNewConnections, error)
	CloseConn(context.Context, *NotifyRemoveConnections) (*emptypb.Empty, error)
	Total(context.Context, *emptypb.Empty) (*TotalFlow, error)
	Notify(*emptypb.Empty, grpc.ServerStreamingServer[NotifyData]) error
	FailedHistory(context.Context, *emptypb.Empty) (*FailedHistoryList, error)
	AllHistory(context.Context, *emptypb.Empty) (*AllHistoryList, error)
	// contains filtered or unexported methods
}

ConnectionsServer is the server API for Connections service. All implementations must embed UnimplementedConnectionsServer for forward compatibility.

type Connections_NotifyClient 

type Connections_NotifyClient = grpc.ServerStreamingClient[NotifyData]

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

type Connections_NotifyServer 

type Connections_NotifyServer = grpc.ServerStreamingServer[NotifyData]

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

type FailedHistory added in v0.3.7 

type FailedHistory struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*FailedHistory) ClearError added in v0.3.8 

func (x *FailedHistory) ClearError()

func (*FailedHistory) ClearFailedCount added in v0.3.8 

func (x *FailedHistory) ClearFailedCount()

func (*FailedHistory) ClearHost added in v0.3.8 

func (x *FailedHistory) ClearHost()

func (*FailedHistory) ClearProcess added in v0.3.8 

func (x *FailedHistory) ClearProcess()

func (*FailedHistory) ClearProtocol added in v0.3.8 

func (x *FailedHistory) ClearProtocol()

func (*FailedHistory) ClearTime added in v0.3.8 

func (x *FailedHistory) ClearTime()

func (*FailedHistory) GetError added in v0.3.7 

func (x *FailedHistory) GetError() string

func (*FailedHistory) GetFailedCount added in v0.3.8 

func (x *FailedHistory) GetFailedCount() uint64

func (*FailedHistory) GetHost added in v0.3.7 

func (x *FailedHistory) GetHost() string

func (*FailedHistory) GetProcess added in v0.3.7 

func (x *FailedHistory) GetProcess() string

func (*FailedHistory) GetProtocol added in v0.3.7 

func (x *FailedHistory) GetProtocol() string

func (*FailedHistory) GetTime added in v0.3.7 

func (x *FailedHistory) GetTime() *timestamppb.Timestamp

func (*FailedHistory) HasError added in v0.3.8 

func (x *FailedHistory) HasError() bool

func (*FailedHistory) HasFailedCount added in v0.3.8 

func (x *FailedHistory) HasFailedCount() bool

func (*FailedHistory) HasHost added in v0.3.8 

func (x *FailedHistory) HasHost() bool

func (*FailedHistory) HasProcess added in v0.3.8 

func (x *FailedHistory) HasProcess() bool

func (*FailedHistory) HasProtocol added in v0.3.8 

func (x *FailedHistory) HasProtocol() bool

func (*FailedHistory) HasTime added in v0.3.8 

func (x *FailedHistory) HasTime() bool

func (*FailedHistory) ProtoMessage added in v0.3.7 

func (*FailedHistory) ProtoMessage()

func (*FailedHistory) ProtoReflect added in v0.3.7 

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

func (*FailedHistory) Reset added in v0.3.7 

func (x *FailedHistory) Reset()

func (*FailedHistory) SetError added in v0.3.8 

func (x *FailedHistory) SetError(v string)

func (*FailedHistory) SetFailedCount added in v0.3.8 

func (x *FailedHistory) SetFailedCount(v uint64)

func (*FailedHistory) SetHost added in v0.3.8 

func (x *FailedHistory) SetHost(v string)

func (*FailedHistory) SetProcess added in v0.3.8 

func (x *FailedHistory) SetProcess(v string)

func (*FailedHistory) SetProtocol added in v0.3.8 

func (x *FailedHistory) SetProtocol(v string)

func (*FailedHistory) SetTime added in v0.3.8 

func (x *FailedHistory) SetTime(v *timestamppb.Timestamp)

func (*FailedHistory) String added in v0.3.7 

func (x *FailedHistory) String() string

type FailedHistoryList added in v0.3.7 

type FailedHistoryList struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*FailedHistoryList) ClearDumpProcessEnabled added in v0.3.8 

func (x *FailedHistoryList) ClearDumpProcessEnabled()

func (*FailedHistoryList) GetDumpProcessEnabled added in v0.3.7 

func (x *FailedHistoryList) GetDumpProcessEnabled() bool

func (*FailedHistoryList) GetObjects added in v0.3.7 

func (x *FailedHistoryList) GetObjects() []*FailedHistory

func (*FailedHistoryList) HasDumpProcessEnabled added in v0.3.8 

func (x *FailedHistoryList) HasDumpProcessEnabled() bool

func (*FailedHistoryList) ProtoMessage added in v0.3.7 

func (*FailedHistoryList) ProtoMessage()

func (*FailedHistoryList) ProtoReflect added in v0.3.7 

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

func (*FailedHistoryList) Reset added in v0.3.7 

func (x *FailedHistoryList) Reset()

func (*FailedHistoryList) SetDumpProcessEnabled added in v0.3.8 

func (x *FailedHistoryList) SetDumpProcessEnabled(v bool)

func (*FailedHistoryList) SetObjects added in v0.3.8 

func (x *FailedHistoryList) SetObjects(v []*FailedHistory)

func (*FailedHistoryList) String added in v0.3.7 

func (x *FailedHistoryList) String() string

type FailedHistoryList_builder added in v0.3.8 

type FailedHistoryList_builder struct {
	Objects            []*FailedHistory
	DumpProcessEnabled *bool
	// contains filtered or unexported fields
}

func (FailedHistoryList_builder) Build added in v0.3.8 

func (b0 FailedHistoryList_builder) Build() *FailedHistoryList

type FailedHistory_builder added in v0.3.8 

type FailedHistory_builder struct {
	Protocol    *string
	Host        *string
	Error       *string
	Process     *string
	Time        *timestamppb.Timestamp
	FailedCount *uint64
	// contains filtered or unexported fields
}

func (FailedHistory_builder) Build added in v0.3.8 

func (b0 FailedHistory_builder) Build() *FailedHistory

type NotifyData 

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

func (*NotifyData) ClearData added in v0.3.8 

func (x *NotifyData) ClearData()

func (*NotifyData) ClearNotifyNewConnections added in v0.3.8 

func (x *NotifyData) ClearNotifyNewConnections()

func (*NotifyData) ClearNotifyRemoveConnections added in v0.3.8 

func (x *NotifyData) ClearNotifyRemoveConnections()

func (*NotifyData) ClearTotalFlow added in v0.3.8 

func (x *NotifyData) ClearTotalFlow()

func (*NotifyData) GetNotifyNewConnections 

func (x *NotifyData) GetNotifyNewConnections() *NotifyNewConnections

func (*NotifyData) GetNotifyRemoveConnections 

func (x *NotifyData) GetNotifyRemoveConnections() *NotifyRemoveConnections

func (*NotifyData) GetTotalFlow 

func (x *NotifyData) GetTotalFlow() *TotalFlow

func (*NotifyData) HasData added in v0.3.8 

func (x *NotifyData) HasData() bool

func (*NotifyData) HasNotifyNewConnections added in v0.3.8 

func (x *NotifyData) HasNotifyNewConnections() bool

func (*NotifyData) HasNotifyRemoveConnections added in v0.3.8 

func (x *NotifyData) HasNotifyRemoveConnections() bool

func (*NotifyData) HasTotalFlow added in v0.3.8 

func (x *NotifyData) HasTotalFlow() bool

func (*NotifyData) ProtoMessage 

func (*NotifyData) ProtoMessage()

func (*NotifyData) ProtoReflect 

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

func (*NotifyData) Reset 

func (x *NotifyData) Reset()

func (*NotifyData) SetNotifyNewConnections added in v0.3.8 

func (x *NotifyData) SetNotifyNewConnections(v *NotifyNewConnections)

func (*NotifyData) SetNotifyRemoveConnections added in v0.3.8 

func (x *NotifyData) SetNotifyRemoveConnections(v *NotifyRemoveConnections)

func (*NotifyData) SetTotalFlow added in v0.3.8 

func (x *NotifyData) SetTotalFlow(v *TotalFlow)

func (*NotifyData) String 

func (x *NotifyData) String() string

func (*NotifyData) WhichData added in v0.3.8 

func (x *NotifyData) WhichData() case_NotifyData_Data

type NotifyData_builder added in v0.3.8 

type NotifyData_builder struct {

	// Fields of oneof xxx_hidden_Data:
	TotalFlow               *TotalFlow
	NotifyNewConnections    *NotifyNewConnections
	NotifyRemoveConnections *NotifyRemoveConnections
	// contains filtered or unexported fields
}

func (NotifyData_builder) Build added in v0.3.8 

func (b0 NotifyData_builder) Build() *NotifyData

type NotifyNewConnections 

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

func (*NotifyNewConnections) GetConnections 

func (x *NotifyNewConnections) GetConnections() []*statistic.Connection

func (*NotifyNewConnections) ProtoMessage 

func (*NotifyNewConnections) ProtoMessage()

func (*NotifyNewConnections) ProtoReflect 

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

func (*NotifyNewConnections) Reset 

func (x *NotifyNewConnections) Reset()

func (*NotifyNewConnections) SetConnections added in v0.3.8 

func (x *NotifyNewConnections) SetConnections(v []*statistic.Connection)

func (*NotifyNewConnections) String 

func (x *NotifyNewConnections) String() string

type NotifyNewConnections_builder added in v0.3.8 

type NotifyNewConnections_builder struct {
	Connections []*statistic.Connection
	// contains filtered or unexported fields
}

func (NotifyNewConnections_builder) Build added in v0.3.8 

func (b0 NotifyNewConnections_builder) Build() *NotifyNewConnections

type NotifyRemoveConnections 

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

func (*NotifyRemoveConnections) GetIds 

func (x *NotifyRemoveConnections) GetIds() []uint64

func (*NotifyRemoveConnections) ProtoMessage 

func (*NotifyRemoveConnections) ProtoMessage()

func (*NotifyRemoveConnections) ProtoReflect 

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

func (*NotifyRemoveConnections) Reset 

func (x *NotifyRemoveConnections) Reset()

func (*NotifyRemoveConnections) SetIds added in v0.3.8 

func (x *NotifyRemoveConnections) SetIds(v []uint64)

func (*NotifyRemoveConnections) String 

func (x *NotifyRemoveConnections) String() string

type NotifyRemoveConnections_builder added in v0.3.8 

type NotifyRemoveConnections_builder struct {
	Ids []uint64
	// contains filtered or unexported fields
}

func (NotifyRemoveConnections_builder) Build added in v0.3.8 

func (b0 NotifyRemoveConnections_builder) Build() *NotifyRemoveConnections

type TotalFlow 

type TotalFlow struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*TotalFlow) ClearDownload added in v0.3.8 

func (x *TotalFlow) ClearDownload()

func (*TotalFlow) ClearUpload added in v0.3.8 

func (x *TotalFlow) ClearUpload()

func (*TotalFlow) GetDownload 

func (x *TotalFlow) GetDownload() uint64

func (*TotalFlow) GetUpload 

func (x *TotalFlow) GetUpload() uint64

func (*TotalFlow) HasDownload added in v0.3.8 

func (x *TotalFlow) HasDownload() bool

func (*TotalFlow) HasUpload added in v0.3.8 

func (x *TotalFlow) HasUpload() bool

func (*TotalFlow) ProtoMessage 

func (*TotalFlow) ProtoMessage()

func (*TotalFlow) ProtoReflect 

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

func (*TotalFlow) Reset 

func (x *TotalFlow) Reset()

func (*TotalFlow) SetDownload added in v0.3.8 

func (x *TotalFlow) SetDownload(v uint64)

func (*TotalFlow) SetUpload added in v0.3.8 

func (x *TotalFlow) SetUpload(v uint64)

func (*TotalFlow) String 

func (x *TotalFlow) String() string

type TotalFlow_builder added in v0.3.8 

type TotalFlow_builder struct {
	Download *uint64
	Upload   *uint64
	// contains filtered or unexported fields
}

func (TotalFlow_builder) Build added in v0.3.8 

func (b0 TotalFlow_builder) Build() *TotalFlow

type UnimplementedConnectionsServer 

type UnimplementedConnectionsServer struct{}

UnimplementedConnectionsServer 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 (UnimplementedConnectionsServer) AllHistory added in v0.3.8 

func (UnimplementedConnectionsServer) AllHistory(context.Context, *emptypb.Empty) (*AllHistoryList, error)

func (UnimplementedConnectionsServer) CloseConn 

func (UnimplementedConnectionsServer) CloseConn(context.Context, *NotifyRemoveConnections) (*emptypb.Empty, error)

func (UnimplementedConnectionsServer) Conns 

func (UnimplementedConnectionsServer) Conns(context.Context, *emptypb.Empty) (*NotifyNewConnections, error)

func (UnimplementedConnectionsServer) FailedHistory added in v0.3.7 

func (UnimplementedConnectionsServer) FailedHistory(context.Context, *emptypb.Empty) (*FailedHistoryList, error)

func (UnimplementedConnectionsServer) Notify 

func (UnimplementedConnectionsServer) Notify(*emptypb.Empty, grpc.ServerStreamingServer[NotifyData]) error

func (UnimplementedConnectionsServer) Total 

func (UnimplementedConnectionsServer) Total(context.Context, *emptypb.Empty) (*TotalFlow, error)

type UnsafeConnectionsServer 

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

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