api

package
v0.0.0-...-c6b16a5 Latest Latest
Warning

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

 Go to latest Published: Oct 16, 2020 License: GPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SetUsersRequest_Operation_name = map[int32]string{
		0: "Add",
		1: "Delete",
		2: "Modify",
	}
	SetUsersRequest_Operation_value = map[string]int32{
		"Add":    0,
		"Delete": 1,
		"Modify": 2,
	}
)

Enum value maps for SetUsersRequest_Operation.

View Source 
var File_api_proto protoreflect.FileDescriptor

Functions

func RegisterClientServiceServer 

func RegisterClientServiceServer(s *grpc.Server, srv ClientServiceServer)

func RegisterServerServiceServer 

func RegisterServerServiceServer(s *grpc.Server, srv ServerServiceServer)

func RunClientAPI 

func RunClientAPI(ctx context.Context, u user.User, listenAddr string) error

func RunServerAPI 

func RunServerAPI(ctx context.Context, um user.UserManager, listenAddr string) error

Types

type ClientAPI 

type ClientAPI struct {
	ClientServiceServer
	// contains filtered or unexported fields
}

API for CrossFire client

func (*ClientAPI) GetTraffic 

func (s *ClientAPI) GetTraffic(ctx context.Context, req *GetTrafficRequest) (*GetTrafficResponse, error)

type ClientServiceClient 

type ClientServiceClient interface {
	GetTraffic(ctx context.Context, in *GetTrafficRequest, opts ...grpc.CallOption) (*GetTrafficResponse, error)
}

ClientServiceClient is the client API for ClientService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewClientServiceClient 

func NewClientServiceClient(cc grpc.ClientConnInterface) ClientServiceClient

type ClientServiceServer 

type ClientServiceServer interface {
	GetTraffic(context.Context, *GetTrafficRequest) (*GetTrafficResponse, error)
}

ClientServiceServer is the server API for ClientService service.

type GetTrafficRequest 

type GetTrafficRequest struct {
	User *User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTrafficRequest) Descriptor deprecated 

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

Deprecated: Use GetTrafficRequest.ProtoReflect.Descriptor instead.

func (*GetTrafficRequest) GetUser 

func (x *GetTrafficRequest) GetUser() *User

func (*GetTrafficRequest) ProtoMessage 

func (*GetTrafficRequest) ProtoMessage()

func (*GetTrafficRequest) ProtoReflect 

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

func (*GetTrafficRequest) Reset 

func (x *GetTrafficRequest) Reset()

func (*GetTrafficRequest) String 

func (x *GetTrafficRequest) String() string

type GetTrafficResponse 

type GetTrafficResponse struct {
	Success      bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Info         string   `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	TrafficTotal *Traffic `protobuf:"bytes,3,opt,name=traffic_total,json=trafficTotal,proto3" json:"traffic_total,omitempty"`
	SpeedCurrent *Speed   `protobuf:"bytes,4,opt,name=speed_current,json=speedCurrent,proto3" json:"speed_current,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTrafficResponse) Descriptor deprecated 

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

Deprecated: Use GetTrafficResponse.ProtoReflect.Descriptor instead.

func (*GetTrafficResponse) GetInfo 

func (x *GetTrafficResponse) GetInfo() string

func (*GetTrafficResponse) GetSpeedCurrent 

func (x *GetTrafficResponse) GetSpeedCurrent() *Speed

func (*GetTrafficResponse) GetSuccess 

func (x *GetTrafficResponse) GetSuccess() bool

func (*GetTrafficResponse) GetTrafficTotal 

func (x *GetTrafficResponse) GetTrafficTotal() *Traffic

func (*GetTrafficResponse) ProtoMessage 

func (*GetTrafficResponse) ProtoMessage()

func (*GetTrafficResponse) ProtoReflect 

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

func (*GetTrafficResponse) Reset 

func (x *GetTrafficResponse) Reset()

func (*GetTrafficResponse) String 

func (x *GetTrafficResponse) String() string

type GetUsersRequest 

type GetUsersRequest struct {
	User   *User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Reset_ bool  `protobuf:"varint,2,opt,name=reset,proto3" json:"reset,omitempty"`
	// contains filtered or unexported fields
}

func (*GetUsersRequest) Descriptor deprecated 

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

Deprecated: Use GetUsersRequest.ProtoReflect.Descriptor instead.

func (*GetUsersRequest) GetReset_ 

func (x *GetUsersRequest) GetReset_() bool

func (*GetUsersRequest) GetUser 

func (x *GetUsersRequest) GetUser() *User

func (*GetUsersRequest) ProtoMessage 

func (*GetUsersRequest) ProtoMessage()

func (*GetUsersRequest) ProtoReflect 

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

func (*GetUsersRequest) Reset 

func (x *GetUsersRequest) Reset()

func (*GetUsersRequest) String 

func (x *GetUsersRequest) String() string

type GetUsersResponse 

type GetUsersResponse struct {
	Success bool        `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Info    string      `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	Status  *UserStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetUsersResponse) Descriptor deprecated 

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

Deprecated: Use GetUsersResponse.ProtoReflect.Descriptor instead.

func (*GetUsersResponse) GetInfo 

func (x *GetUsersResponse) GetInfo() string

func (*GetUsersResponse) GetStatus 

func (x *GetUsersResponse) GetStatus() *UserStatus

func (*GetUsersResponse) GetSuccess 

func (x *GetUsersResponse) GetSuccess() bool

func (*GetUsersResponse) ProtoMessage 

func (*GetUsersResponse) ProtoMessage()

func (*GetUsersResponse) ProtoReflect 

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

func (*GetUsersResponse) Reset 

func (x *GetUsersResponse) Reset()

func (*GetUsersResponse) String 

func (x *GetUsersResponse) String() string

type ListUsersRequest 

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

func (*ListUsersRequest) Descriptor deprecated 

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

Deprecated: Use ListUsersRequest.ProtoReflect.Descriptor instead.

func (*ListUsersRequest) GetReset_ 

func (x *ListUsersRequest) GetReset_() bool

func (*ListUsersRequest) ProtoMessage 

func (*ListUsersRequest) ProtoMessage()

func (*ListUsersRequest) ProtoReflect 

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

func (*ListUsersRequest) Reset 

func (x *ListUsersRequest) Reset()

func (*ListUsersRequest) String 

func (x *ListUsersRequest) String() string

type ListUsersResponse 

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

func (*ListUsersResponse) Descriptor deprecated 

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

Deprecated: Use ListUsersResponse.ProtoReflect.Descriptor instead.

func (*ListUsersResponse) GetStatus 

func (x *ListUsersResponse) GetStatus() *UserStatus

func (*ListUsersResponse) ProtoMessage 

func (*ListUsersResponse) ProtoMessage()

func (*ListUsersResponse) ProtoReflect 

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

func (*ListUsersResponse) Reset 

func (x *ListUsersResponse) Reset()

func (*ListUsersResponse) String 

func (x *ListUsersResponse) String() string

type ServerAPI 

type ServerAPI struct {
	ServerServiceServer
	// contains filtered or unexported fields
}

API for CrossFire server

func (*ServerAPI) GetUsers 

func (s *ServerAPI) GetUsers(stream ServerService_GetUsersServer) error

func (*ServerAPI) ListUsers 

func (s *ServerAPI) ListUsers(req *ListUsersRequest, stream ServerService_ListUsersServer) error

func (*ServerAPI) SetUsers 

func (s *ServerAPI) SetUsers(stream ServerService_SetUsersServer) error

type ServerServiceClient 

type ServerServiceClient interface {
	// list all users
	ListUsers(ctx context.Context, in *ListUsersRequest, opts ...grpc.CallOption) (ServerService_ListUsersClient, error)
	// obtain specified user's info
	GetUsers(ctx context.Context, opts ...grpc.CallOption) (ServerService_GetUsersClient, error)
	// setup existing users' config
	SetUsers(ctx context.Context, opts ...grpc.CallOption) (ServerService_SetUsersClient, error)
}

ServerServiceClient is the client API for ServerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewServerServiceClient 

func NewServerServiceClient(cc grpc.ClientConnInterface) ServerServiceClient

type ServerServiceServer 

type ServerServiceServer interface {
	// list all users
	ListUsers(*ListUsersRequest, ServerService_ListUsersServer) error
	// obtain specified user's info
	GetUsers(ServerService_GetUsersServer) error
	// setup existing users' config
	SetUsers(ServerService_SetUsersServer) error
}

ServerServiceServer is the server API for ServerService service.

type ServerService_GetUsersClient 

type ServerService_GetUsersClient interface {
	Send(*GetUsersRequest) error
	Recv() (*GetUsersResponse, error)
	grpc.ClientStream
}

type ServerService_GetUsersServer 

type ServerService_GetUsersServer interface {
	Send(*GetUsersResponse) error
	Recv() (*GetUsersRequest, error)
	grpc.ServerStream
}

type ServerService_ListUsersClient 

type ServerService_ListUsersClient interface {
	Recv() (*ListUsersResponse, error)
	grpc.ClientStream
}

type ServerService_ListUsersServer 

type ServerService_ListUsersServer interface {
	Send(*ListUsersResponse) error
	grpc.ServerStream
}

type ServerService_SetUsersClient 

type ServerService_SetUsersClient interface {
	Send(*SetUsersRequest) error
	Recv() (*SetUsersResponse, error)
	grpc.ClientStream
}

type ServerService_SetUsersServer 

type ServerService_SetUsersServer interface {
	Send(*SetUsersResponse) error
	Recv() (*SetUsersRequest, error)
	grpc.ServerStream
}

type SetUsersRequest 

type SetUsersRequest struct {
	Status    *UserStatus               `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Operation SetUsersRequest_Operation `protobuf:"varint,2,opt,name=operation,proto3,enum=api.SetUsersRequest_Operation" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*SetUsersRequest) Descriptor deprecated 

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

Deprecated: Use SetUsersRequest.ProtoReflect.Descriptor instead.

func (*SetUsersRequest) GetOperation 

func (x *SetUsersRequest) GetOperation() SetUsersRequest_Operation

func (*SetUsersRequest) GetStatus 

func (x *SetUsersRequest) GetStatus() *UserStatus

func (*SetUsersRequest) ProtoMessage 

func (*SetUsersRequest) ProtoMessage()

func (*SetUsersRequest) ProtoReflect 

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

func (*SetUsersRequest) Reset 

func (x *SetUsersRequest) Reset()

func (*SetUsersRequest) String 

func (x *SetUsersRequest) String() string

type SetUsersRequest_Operation 

type SetUsersRequest_Operation int32
const (
	SetUsersRequest_Add    SetUsersRequest_Operation = 0
	SetUsersRequest_Delete SetUsersRequest_Operation = 1
	SetUsersRequest_Modify SetUsersRequest_Operation = 2
)

func (SetUsersRequest_Operation) Descriptor 

func (SetUsersRequest_Operation) Descriptor() protoreflect.EnumDescriptor

func (SetUsersRequest_Operation) Enum 

func (x SetUsersRequest_Operation) Enum() *SetUsersRequest_Operation

func (SetUsersRequest_Operation) EnumDescriptor deprecated 

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

Deprecated: Use SetUsersRequest_Operation.Descriptor instead.

func (SetUsersRequest_Operation) Number 

func (x SetUsersRequest_Operation) Number() protoreflect.EnumNumber

func (SetUsersRequest_Operation) String 

func (x SetUsersRequest_Operation) String() string

func (SetUsersRequest_Operation) Type 

func (SetUsersRequest_Operation) Type() protoreflect.EnumType

type SetUsersResponse 

type SetUsersResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Info    string `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*SetUsersResponse) Descriptor deprecated 

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

Deprecated: Use SetUsersResponse.ProtoReflect.Descriptor instead.

func (*SetUsersResponse) GetInfo 

func (x *SetUsersResponse) GetInfo() string

func (*SetUsersResponse) GetSuccess 

func (x *SetUsersResponse) GetSuccess() bool

func (*SetUsersResponse) ProtoMessage 

func (*SetUsersResponse) ProtoMessage()

func (*SetUsersResponse) ProtoReflect 

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

func (*SetUsersResponse) Reset 

func (x *SetUsersResponse) Reset()

func (*SetUsersResponse) String 

func (x *SetUsersResponse) String() string

type Speed 

type Speed struct {
	UploadSpeed   uint64 `protobuf:"varint,1,opt,name=upload_speed,json=uploadSpeed,proto3" json:"upload_speed,omitempty"`
	DownloadSpeed uint64 `protobuf:"varint,2,opt,name=download_speed,json=downloadSpeed,proto3" json:"download_speed,omitempty"`
	// contains filtered or unexported fields
}

func (*Speed) Descriptor deprecated 

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

Deprecated: Use Speed.ProtoReflect.Descriptor instead.

func (*Speed) GetDownloadSpeed 

func (x *Speed) GetDownloadSpeed() uint64

func (*Speed) GetUploadSpeed 

func (x *Speed) GetUploadSpeed() uint64

func (*Speed) ProtoMessage 

func (*Speed) ProtoMessage()

func (*Speed) ProtoReflect 

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

func (*Speed) Reset 

func (x *Speed) Reset()

func (*Speed) String 

func (x *Speed) String() string

type Traffic 

type Traffic struct {
	UploadTraffic   uint64 `protobuf:"varint,1,opt,name=upload_traffic,json=uploadTraffic,proto3" json:"upload_traffic,omitempty"`
	DownloadTraffic uint64 `protobuf:"varint,2,opt,name=download_traffic,json=downloadTraffic,proto3" json:"download_traffic,omitempty"`
	// contains filtered or unexported fields
}

func (*Traffic) Descriptor deprecated 

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

Deprecated: Use Traffic.ProtoReflect.Descriptor instead.

func (*Traffic) GetDownloadTraffic 

func (x *Traffic) GetDownloadTraffic() uint64

func (*Traffic) GetUploadTraffic 

func (x *Traffic) GetUploadTraffic() uint64

func (*Traffic) ProtoMessage 

func (*Traffic) ProtoMessage()

func (*Traffic) ProtoReflect 

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

func (*Traffic) Reset 

func (x *Traffic) Reset()

func (*Traffic) String 

func (x *Traffic) String() string

type UnimplementedClientServiceServer 

type UnimplementedClientServiceServer struct {
}

UnimplementedClientServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedClientServiceServer) GetTraffic 

func (*UnimplementedClientServiceServer) GetTraffic(context.Context, *GetTrafficRequest) (*GetTrafficResponse, error)

type UnimplementedServerServiceServer 

type UnimplementedServerServiceServer struct {
}

UnimplementedServerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedServerServiceServer) GetUsers 

func (*UnimplementedServerServiceServer) GetUsers(ServerService_GetUsersServer) error

func (*UnimplementedServerServiceServer) ListUsers 

func (*UnimplementedServerServiceServer) ListUsers(*ListUsersRequest, ServerService_ListUsersServer) error

func (*UnimplementedServerServiceServer) SetUsers 

func (*UnimplementedServerServiceServer) SetUsers(ServerService_SetUsersServer) error

type User 

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

func (*User) Descriptor deprecated 

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

Deprecated: Use User.ProtoReflect.Descriptor instead.

func (*User) GetHash 

func (x *User) GetHash() string

func (*User) ProtoMessage 

func (*User) ProtoMessage()

func (*User) ProtoReflect 

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

func (*User) Reset 

func (x *User) Reset()

func (*User) String 

func (x *User) String() string

type UserStatus 

type UserStatus struct {
	User         *User    `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	TrafficTotal *Traffic `protobuf:"bytes,2,opt,name=traffic_total,json=trafficTotal,proto3" json:"traffic_total,omitempty"`
	SpeedCurrent *Speed   `protobuf:"bytes,3,opt,name=speed_current,json=speedCurrent,proto3" json:"speed_current,omitempty"`
	SpeedLimit   *Speed   `protobuf:"bytes,4,opt,name=speed_limit,json=speedLimit,proto3" json:"speed_limit,omitempty"`
	IpCurrent    int32    `protobuf:"varint,5,opt,name=ip_current,json=ipCurrent,proto3" json:"ip_current,omitempty"`
	IpLimit      int32    `protobuf:"varint,6,opt,name=ip_limit,json=ipLimit,proto3" json:"ip_limit,omitempty"`
	// contains filtered or unexported fields
}

func (*UserStatus) Descriptor deprecated 

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

Deprecated: Use UserStatus.ProtoReflect.Descriptor instead.

func (*UserStatus) GetIpCurrent 

func (x *UserStatus) GetIpCurrent() int32

func (*UserStatus) GetIpLimit 

func (x *UserStatus) GetIpLimit() int32

func (*UserStatus) GetSpeedCurrent 

func (x *UserStatus) GetSpeedCurrent() *Speed

func (*UserStatus) GetSpeedLimit 

func (x *UserStatus) GetSpeedLimit() *Speed

func (*UserStatus) GetTrafficTotal 

func (x *UserStatus) GetTrafficTotal() *Traffic

func (*UserStatus) GetUser 

func (x *UserStatus) GetUser() *User

func (*UserStatus) ProtoMessage 

func (*UserStatus) ProtoMessage()

func (*UserStatus) ProtoReflect 

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

func (*UserStatus) Reset 

func (x *UserStatus) Reset()

func (*UserStatus) String 

func (x *UserStatus) 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.