logservice

package
v0.0.3-0...-f12fa88 Latest Latest
Warning

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

 Go to latest Published: Apr 9, 2021 License: MIT Imports: 10 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	LogModel_Level_name = map[int32]string{
		0: "INFO",
		1: "WARNING",
		2: "ERROR",
		3: "FATAL",
	}
	LogModel_Level_value = map[string]int32{
		"INFO":    0,
		"WARNING": 1,
		"ERROR":   2,
		"FATAL":   3,
	}
)

Enum value maps for LogModel_Level.

View Source 
var File_log_proto protoreflect.FileDescriptor

Functions

func RegisterLogServiceServer 

func RegisterLogServiceServer(s *grpc.Server, srv LogServiceServer)

Types

type Empty 

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

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type ExtRequest 

type ExtRequest struct {
	Operator        []byte `protobuf:"bytes,1,opt,name=operator,proto3" json:"operator,omitempty"`
	Operation       int32  `protobuf:"varint,2,opt,name=operation,proto3" json:"operation,omitempty"`
	OperationTarget []byte `protobuf:"bytes,3,opt,name=operation_target,json=operationTarget,proto3" json:"operation_target,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtRequest) Descriptor deprecated 

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

Deprecated: Use ExtRequest.ProtoReflect.Descriptor instead.

func (*ExtRequest) GetOperation 

func (x *ExtRequest) GetOperation() int32

func (*ExtRequest) GetOperationTarget 

func (x *ExtRequest) GetOperationTarget() []byte

func (*ExtRequest) GetOperator 

func (x *ExtRequest) GetOperator() []byte

func (*ExtRequest) ProtoMessage 

func (*ExtRequest) ProtoMessage()

func (*ExtRequest) ProtoReflect 

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

func (*ExtRequest) Reset 

func (x *ExtRequest) Reset()

func (*ExtRequest) String 

func (x *ExtRequest) String() string

type ListRequest 

type ListRequest struct {
	UserId   []byte `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Page     int32  `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
	Pagesize int32  `protobuf:"varint,3,opt,name=pagesize,proto3" json:"pagesize,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRequest) Descriptor deprecated 

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetPage 

func (x *ListRequest) GetPage() int32

func (*ListRequest) GetPagesize 

func (x *ListRequest) GetPagesize() int32

func (*ListRequest) GetUserId 

func (x *ListRequest) GetUserId() []byte

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect 

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

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) String 

func (x *ListRequest) String() string

type LogArray 

type LogArray struct {
	Logs []*LogModel `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

func (*LogArray) Descriptor deprecated 

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

Deprecated: Use LogArray.ProtoReflect.Descriptor instead.

func (*LogArray) GetLogs 

func (x *LogArray) GetLogs() []*LogModel

func (*LogArray) ProtoMessage 

func (*LogArray) ProtoMessage()

func (*LogArray) ProtoReflect 

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

func (*LogArray) Reset 

func (x *LogArray) Reset()

func (*LogArray) String 

func (x *LogArray) String() string

type LogClient 

type LogClient interface {
	LogServiceClient
	SendCountQuery(ctx context.Context, query bson.D, opts ...grpc.CallOption) (num *Num, err error)
}

func BuildLogClient 

func BuildLogClient(cc grpc.ClientConnInterface) LogClient

type LogModel 

type LogModel struct {
	Operator             []byte         `protobuf:"bytes,1,opt,name=operator,proto3" json:"operator,omitempty"`
	Operation            int32          `protobuf:"varint,2,opt,name=operation,proto3" json:"operation,omitempty"`
	OperationTarget      []byte         `protobuf:"bytes,3,opt,name=operation_target,json=operationTarget,proto3" json:"operation_target,omitempty"`
	LogLevel             LogModel_Level `protobuf:"varint,4,opt,name=log_level,json=logLevel,proto3,enum=proto.LogModel_Level" json:"log_level,omitempty"`
	ExtraMessage         string         `protobuf:"bytes,5,opt,name=extra_message,json=extraMessage,proto3" json:"extra_message,omitempty"`
	CreateTime           int64          `protobuf:"varint,6,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	UpdateTime           int64          `protobuf:"varint,7,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	OperationTargetOwner []byte         `protobuf:"bytes,8,opt,name=operation_target_owner,json=operationTargetOwner,proto3" json:"operation_target_owner,omitempty"`
	Processed            bool           `protobuf:"varint,9,opt,name=processed,proto3" json:"processed,omitempty"`
	// contains filtered or unexported fields
}

func (*LogModel) Descriptor deprecated 

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

Deprecated: Use LogModel.ProtoReflect.Descriptor instead.

func (*LogModel) GetCreateTime 

func (x *LogModel) GetCreateTime() int64

func (*LogModel) GetExtraMessage 

func (x *LogModel) GetExtraMessage() string

func (*LogModel) GetLogLevel 

func (x *LogModel) GetLogLevel() LogModel_Level

func (*LogModel) GetOperation 

func (x *LogModel) GetOperation() int32

func (*LogModel) GetOperationTarget 

func (x *LogModel) GetOperationTarget() []byte

func (*LogModel) GetOperationTargetOwner 

func (x *LogModel) GetOperationTargetOwner() []byte

func (*LogModel) GetOperator 

func (x *LogModel) GetOperator() []byte

func (*LogModel) GetProcessed 

func (x *LogModel) GetProcessed() bool

func (*LogModel) GetUpdateTime 

func (x *LogModel) GetUpdateTime() int64

func (*LogModel) ProtoMessage 

func (*LogModel) ProtoMessage()

func (*LogModel) ProtoReflect 

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

func (*LogModel) Reset 

func (x *LogModel) Reset()

func (*LogModel) String 

func (x *LogModel) String() string

type LogModel_Level 

type LogModel_Level int32
const (
	LogModel_INFO    LogModel_Level = 0
	LogModel_WARNING LogModel_Level = 1
	LogModel_ERROR   LogModel_Level = 2
	LogModel_FATAL   LogModel_Level = 3
)

func (LogModel_Level) Descriptor 

func (LogModel_Level) Descriptor() protoreflect.EnumDescriptor

func (LogModel_Level) Enum 

func (x LogModel_Level) Enum() *LogModel_Level

func (LogModel_Level) EnumDescriptor deprecated 

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

Deprecated: Use LogModel_Level.Descriptor instead.

func (LogModel_Level) Number 

func (x LogModel_Level) Number() protoreflect.EnumNumber

func (LogModel_Level) String 

func (x LogModel_Level) String() string

func (LogModel_Level) Type 

func (LogModel_Level) Type() protoreflect.EnumType

type LogServiceClient 

type LogServiceClient interface {
	Log(ctx context.Context, in *LogModel, opts ...grpc.CallOption) (*Empty, error)
	Exist(ctx context.Context, in *ExtRequest, opts ...grpc.CallOption) (*LogModel, error)
	GetUserMsgs(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*LogArray, error)
	GetUserNewMsgNum(ctx context.Context, in *UserID, opts ...grpc.CallOption) (*Num, error)
	Count(ctx context.Context, in *UserID, opts ...grpc.CallOption) (*Num, error)
	CountQuery(ctx context.Context, in *Query, opts ...grpc.CallOption) (*Num, error)
	Delete(ctx context.Context, in *Query, opts ...grpc.CallOption) (*Empty, error)
}

LogServiceClient is the client API for LogService service.

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

func NewLogServiceClient 

func NewLogServiceClient(cc grpc.ClientConnInterface) LogServiceClient

type LogServiceServer 

type LogServiceServer interface {
	Log(context.Context, *LogModel) (*Empty, error)
	Exist(context.Context, *ExtRequest) (*LogModel, error)
	GetUserMsgs(context.Context, *ListRequest) (*LogArray, error)
	GetUserNewMsgNum(context.Context, *UserID) (*Num, error)
	Count(context.Context, *UserID) (*Num, error)
	CountQuery(context.Context, *Query) (*Num, error)
	Delete(context.Context, *Query) (*Empty, error)
}

LogServiceServer is the server API for LogService service.

type Num 

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

func (*Num) Descriptor deprecated 

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

Deprecated: Use Num.ProtoReflect.Descriptor instead.

func (*Num) GetNum 

func (x *Num) GetNum() int64

func (*Num) ProtoMessage 

func (*Num) ProtoMessage()

func (*Num) ProtoReflect 

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

func (*Num) Reset 

func (x *Num) Reset()

func (*Num) String 

func (x *Num) String() string

type Query 

type Query struct {
	Query []byte `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*Query) Descriptor deprecated 

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

Deprecated: Use Query.ProtoReflect.Descriptor instead.

func (*Query) GetQuery 

func (x *Query) GetQuery() []byte

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) ProtoReflect 

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

func (*Query) Reset 

func (x *Query) Reset()

func (*Query) String 

func (x *Query) String() string

type UnimplementedLogServiceServer 

type UnimplementedLogServiceServer struct {
}

UnimplementedLogServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedLogServiceServer) Count 

func (*UnimplementedLogServiceServer) Count(context.Context, *UserID) (*Num, error)

func (*UnimplementedLogServiceServer) CountQuery 

func (*UnimplementedLogServiceServer) CountQuery(context.Context, *Query) (*Num, error)

func (*UnimplementedLogServiceServer) Delete 

func (*UnimplementedLogServiceServer) Delete(context.Context, *Query) (*Empty, error)

func (*UnimplementedLogServiceServer) Exist 

func (*UnimplementedLogServiceServer) Exist(context.Context, *ExtRequest) (*LogModel, error)

func (*UnimplementedLogServiceServer) GetUserMsgs 

func (*UnimplementedLogServiceServer) GetUserMsgs(context.Context, *ListRequest) (*LogArray, error)

func (*UnimplementedLogServiceServer) GetUserNewMsgNum 

func (*UnimplementedLogServiceServer) GetUserNewMsgNum(context.Context, *UserID) (*Num, error)

func (*UnimplementedLogServiceServer) Log 

func (*UnimplementedLogServiceServer) Log(context.Context, *LogModel) (*Empty, error)

type UserID 

type UserID struct {
	UserId []byte `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UserID) Descriptor deprecated 

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

Deprecated: Use UserID.ProtoReflect.Descriptor instead.

func (*UserID) GetUserId 

func (x *UserID) GetUserId() []byte

func (*UserID) ProtoMessage 

func (*UserID) ProtoMessage()

func (*UserID) ProtoReflect 

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

func (*UserID) Reset 

func (x *UserID) Reset()

func (*UserID) String 

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