pb

package
v1.4.0 Latest Latest
Warning

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

Go to latest
Published: Nov 4, 2021 License: Apache-2.0 Imports: 24 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_query_proto protoreflect.FileDescriptor

Functions

func LogQueryServiceClientType

func LogQueryServiceClientType() reflect.Type

LogQueryServiceClientType .

func LogQueryServiceHandlerType

func LogQueryServiceHandlerType() reflect.Type

LogQueryServiceHandlerType .

func LogQueryServiceServerType

func LogQueryServiceServerType() reflect.Type

LogQueryServiceServerType .

func RegisterLogQueryServiceHandler

func RegisterLogQueryServiceHandler(r http.Router, srv LogQueryServiceHandler, opts ...http.HandleOption)

RegisterLogQueryServiceHandler register LogQueryServiceHandler to http.Router.

func RegisterLogQueryServiceImp

func RegisterLogQueryServiceImp(regester transport.Register, srv LogQueryServiceServer, opts ...transport.ServiceOption)

RegisterLogQueryServiceImp query.proto

func RegisterLogQueryServiceServer

func RegisterLogQueryServiceServer(s grpc1.ServiceRegistrar, srv LogQueryServiceServer, opts ...grpc1.HandleOption)

func ServiceNames

func ServiceNames(svr ...string) []string

ServiceNames return all service names

func Types

func Types() []reflect.Type

Types

type GetLogByOrganizationRequest

type GetLogByOrganizationRequest struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Source      string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` // job or container
	Stream      string `protobuf:"bytes,3,opt,name=stream,proto3" json:"stream,omitempty"`
	RequestId   string `protobuf:"bytes,4,opt,name=requestId,proto3" json:"requestId,omitempty"`
	Start       int64  `protobuf:"varint,5,opt,name=start,proto3" json:"start,omitempty"`
	End         int64  `protobuf:"varint,6,opt,name=end,proto3" json:"end,omitempty"`
	Count       int64  `protobuf:"varint,7,opt,name=count,proto3" json:"count,omitempty"`
	ClusterName string `protobuf:"bytes,8,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	Pattern     string `protobuf:"bytes,9,opt,name=pattern,proto3" json:"pattern,omitempty"`
	Offset      int64  `protobuf:"varint,10,opt,name=offset,proto3" json:"offset,omitempty"`
	Live        bool   `protobuf:"varint,11,opt,name=live,proto3" json:"live,omitempty"`
	Debug       bool   `protobuf:"varint,12,opt,name=debug,proto3" json:"debug,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogByOrganizationRequest) Descriptor deprecated

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

Deprecated: Use GetLogByOrganizationRequest.ProtoReflect.Descriptor instead.

func (*GetLogByOrganizationRequest) GetClusterName

func (x *GetLogByOrganizationRequest) GetClusterName() string

func (*GetLogByOrganizationRequest) GetCount

func (x *GetLogByOrganizationRequest) GetCount() int64

func (*GetLogByOrganizationRequest) GetDebug added in v1.4.0

func (x *GetLogByOrganizationRequest) GetDebug() bool

func (*GetLogByOrganizationRequest) GetEnd

func (x *GetLogByOrganizationRequest) GetEnd() int64

func (*GetLogByOrganizationRequest) GetId

func (*GetLogByOrganizationRequest) GetLive added in v1.4.0

func (x *GetLogByOrganizationRequest) GetLive() bool

func (*GetLogByOrganizationRequest) GetOffset added in v1.4.0

func (x *GetLogByOrganizationRequest) GetOffset() int64

func (*GetLogByOrganizationRequest) GetPattern

func (x *GetLogByOrganizationRequest) GetPattern() string

func (*GetLogByOrganizationRequest) GetRequestId

func (x *GetLogByOrganizationRequest) GetRequestId() string

func (*GetLogByOrganizationRequest) GetSource

func (x *GetLogByOrganizationRequest) GetSource() string

func (*GetLogByOrganizationRequest) GetStart

func (x *GetLogByOrganizationRequest) GetStart() int64

func (*GetLogByOrganizationRequest) GetStream

func (x *GetLogByOrganizationRequest) GetStream() string

func (*GetLogByOrganizationRequest) MarshalJSON

func (m *GetLogByOrganizationRequest) MarshalJSON() ([]byte, error)

GetLogByOrganizationRequest implement json.Marshaler.

func (*GetLogByOrganizationRequest) ProtoMessage

func (*GetLogByOrganizationRequest) ProtoMessage()

func (*GetLogByOrganizationRequest) ProtoReflect

func (*GetLogByOrganizationRequest) Reset

func (x *GetLogByOrganizationRequest) Reset()

func (*GetLogByOrganizationRequest) String

func (x *GetLogByOrganizationRequest) String() string

func (*GetLogByOrganizationRequest) UnmarshalJSON

func (m *GetLogByOrganizationRequest) UnmarshalJSON(b []byte) error

GetLogByOrganizationRequest implement json.Marshaler.

func (*GetLogByOrganizationRequest) UnmarshalURLValues

func (m *GetLogByOrganizationRequest) UnmarshalURLValues(prefix string, values url.Values) error

GetLogByOrganizationRequest implement urlenc.URLValuesUnmarshaler.

func (*GetLogByOrganizationRequest) Validate

func (this *GetLogByOrganizationRequest) Validate() error

type GetLogByOrganizationResponse

type GetLogByOrganizationResponse struct {
	Lines []*LogItem `protobuf:"bytes,1,rep,name=lines,proto3" json:"lines,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogByOrganizationResponse) Descriptor deprecated

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

Deprecated: Use GetLogByOrganizationResponse.ProtoReflect.Descriptor instead.

func (*GetLogByOrganizationResponse) GetLines

func (x *GetLogByOrganizationResponse) GetLines() []*LogItem

func (*GetLogByOrganizationResponse) MarshalJSON

func (m *GetLogByOrganizationResponse) MarshalJSON() ([]byte, error)

GetLogByOrganizationResponse implement json.Marshaler.

func (*GetLogByOrganizationResponse) ProtoMessage

func (*GetLogByOrganizationResponse) ProtoMessage()

func (*GetLogByOrganizationResponse) ProtoReflect

func (*GetLogByOrganizationResponse) Reset

func (x *GetLogByOrganizationResponse) Reset()

func (*GetLogByOrganizationResponse) String

func (*GetLogByOrganizationResponse) UnmarshalJSON

func (m *GetLogByOrganizationResponse) UnmarshalJSON(b []byte) error

GetLogByOrganizationResponse implement json.Marshaler.

func (*GetLogByOrganizationResponse) UnmarshalURLValues

func (m *GetLogByOrganizationResponse) UnmarshalURLValues(prefix string, values url.Values) error

GetLogByOrganizationResponse implement urlenc.URLValuesUnmarshaler.

func (*GetLogByOrganizationResponse) Validate

func (this *GetLogByOrganizationResponse) Validate() error

type GetLogByRuntimeRequest

type GetLogByRuntimeRequest struct {
	Id            string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Source        string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` // job or container
	Stream        string `protobuf:"bytes,3,opt,name=stream,proto3" json:"stream,omitempty"`
	RequestId     string `protobuf:"bytes,4,opt,name=requestId,proto3" json:"requestId,omitempty"`
	Start         int64  `protobuf:"varint,5,opt,name=start,proto3" json:"start,omitempty"`
	End           int64  `protobuf:"varint,6,opt,name=end,proto3" json:"end,omitempty"`
	Count         int64  `protobuf:"varint,7,opt,name=count,proto3" json:"count,omitempty"`
	ApplicationId string `protobuf:"bytes,8,opt,name=applicationId,proto3" json:"applicationId,omitempty"`
	Pattern       string `protobuf:"bytes,9,opt,name=pattern,proto3" json:"pattern,omitempty"`
	Offset        int64  `protobuf:"varint,10,opt,name=offset,proto3" json:"offset,omitempty"`
	Live          bool   `protobuf:"varint,11,opt,name=live,proto3" json:"live,omitempty"`
	Debug         bool   `protobuf:"varint,12,opt,name=debug,proto3" json:"debug,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogByRuntimeRequest) Descriptor deprecated

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

Deprecated: Use GetLogByRuntimeRequest.ProtoReflect.Descriptor instead.

func (*GetLogByRuntimeRequest) GetApplicationId

func (x *GetLogByRuntimeRequest) GetApplicationId() string

func (*GetLogByRuntimeRequest) GetCount

func (x *GetLogByRuntimeRequest) GetCount() int64

func (*GetLogByRuntimeRequest) GetDebug added in v1.4.0

func (x *GetLogByRuntimeRequest) GetDebug() bool

func (*GetLogByRuntimeRequest) GetEnd

func (x *GetLogByRuntimeRequest) GetEnd() int64

func (*GetLogByRuntimeRequest) GetId

func (x *GetLogByRuntimeRequest) GetId() string

func (*GetLogByRuntimeRequest) GetLive added in v1.4.0

func (x *GetLogByRuntimeRequest) GetLive() bool

func (*GetLogByRuntimeRequest) GetOffset added in v1.4.0

func (x *GetLogByRuntimeRequest) GetOffset() int64

func (*GetLogByRuntimeRequest) GetPattern

func (x *GetLogByRuntimeRequest) GetPattern() string

func (*GetLogByRuntimeRequest) GetRequestId

func (x *GetLogByRuntimeRequest) GetRequestId() string

func (*GetLogByRuntimeRequest) GetSource

func (x *GetLogByRuntimeRequest) GetSource() string

func (*GetLogByRuntimeRequest) GetStart

func (x *GetLogByRuntimeRequest) GetStart() int64

func (*GetLogByRuntimeRequest) GetStream

func (x *GetLogByRuntimeRequest) GetStream() string

func (*GetLogByRuntimeRequest) MarshalJSON

func (m *GetLogByRuntimeRequest) MarshalJSON() ([]byte, error)

GetLogByRuntimeRequest implement json.Marshaler.

func (*GetLogByRuntimeRequest) ProtoMessage

func (*GetLogByRuntimeRequest) ProtoMessage()

func (*GetLogByRuntimeRequest) ProtoReflect

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

func (*GetLogByRuntimeRequest) Reset

func (x *GetLogByRuntimeRequest) Reset()

func (*GetLogByRuntimeRequest) String

func (x *GetLogByRuntimeRequest) String() string

func (*GetLogByRuntimeRequest) UnmarshalJSON

func (m *GetLogByRuntimeRequest) UnmarshalJSON(b []byte) error

GetLogByRuntimeRequest implement json.Marshaler.

func (*GetLogByRuntimeRequest) UnmarshalURLValues

func (m *GetLogByRuntimeRequest) UnmarshalURLValues(prefix string, values url.Values) error

GetLogByRuntimeRequest implement urlenc.URLValuesUnmarshaler.

func (*GetLogByRuntimeRequest) Validate

func (this *GetLogByRuntimeRequest) Validate() error

type GetLogByRuntimeResponse

type GetLogByRuntimeResponse struct {
	Lines []*LogItem `protobuf:"bytes,1,rep,name=lines,proto3" json:"lines,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogByRuntimeResponse) Descriptor deprecated

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

Deprecated: Use GetLogByRuntimeResponse.ProtoReflect.Descriptor instead.

func (*GetLogByRuntimeResponse) GetLines

func (x *GetLogByRuntimeResponse) GetLines() []*LogItem

func (*GetLogByRuntimeResponse) MarshalJSON

func (m *GetLogByRuntimeResponse) MarshalJSON() ([]byte, error)

GetLogByRuntimeResponse implement json.Marshaler.

func (*GetLogByRuntimeResponse) ProtoMessage

func (*GetLogByRuntimeResponse) ProtoMessage()

func (*GetLogByRuntimeResponse) ProtoReflect

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

func (*GetLogByRuntimeResponse) Reset

func (x *GetLogByRuntimeResponse) Reset()

func (*GetLogByRuntimeResponse) String

func (x *GetLogByRuntimeResponse) String() string

func (*GetLogByRuntimeResponse) UnmarshalJSON

func (m *GetLogByRuntimeResponse) UnmarshalJSON(b []byte) error

GetLogByRuntimeResponse implement json.Marshaler.

func (*GetLogByRuntimeResponse) UnmarshalURLValues

func (m *GetLogByRuntimeResponse) UnmarshalURLValues(prefix string, values url.Values) error

GetLogByRuntimeResponse implement urlenc.URLValuesUnmarshaler.

func (*GetLogByRuntimeResponse) Validate

func (this *GetLogByRuntimeResponse) Validate() error

type GetLogRequest

type GetLogRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Source    string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` // job or container
	Stream    string `protobuf:"bytes,3,opt,name=stream,proto3" json:"stream,omitempty"`
	RequestId string `protobuf:"bytes,4,opt,name=requestId,proto3" json:"requestId,omitempty"`
	Start     int64  `protobuf:"varint,5,opt,name=start,proto3" json:"start,omitempty"`
	End       int64  `protobuf:"varint,6,opt,name=end,proto3" json:"end,omitempty"`
	Count     int64  `protobuf:"varint,7,opt,name=count,proto3" json:"count,omitempty"`
	Pattern   string `protobuf:"bytes,8,opt,name=pattern,proto3" json:"pattern,omitempty"`
	Offset    int64  `protobuf:"varint,9,opt,name=offset,proto3" json:"offset,omitempty"`
	Live      bool   `protobuf:"varint,10,opt,name=live,proto3" json:"live,omitempty"`
	Debug     bool   `protobuf:"varint,11,opt,name=debug,proto3" json:"debug,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogRequest) Descriptor deprecated

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

Deprecated: Use GetLogRequest.ProtoReflect.Descriptor instead.

func (*GetLogRequest) GetCount

func (x *GetLogRequest) GetCount() int64

func (*GetLogRequest) GetDebug added in v1.4.0

func (x *GetLogRequest) GetDebug() bool

func (*GetLogRequest) GetEnd

func (x *GetLogRequest) GetEnd() int64

func (*GetLogRequest) GetId

func (x *GetLogRequest) GetId() string

func (*GetLogRequest) GetLive added in v1.4.0

func (x *GetLogRequest) GetLive() bool

func (*GetLogRequest) GetOffset added in v1.4.0

func (x *GetLogRequest) GetOffset() int64

func (*GetLogRequest) GetPattern

func (x *GetLogRequest) GetPattern() string

func (*GetLogRequest) GetRequestId

func (x *GetLogRequest) GetRequestId() string

func (*GetLogRequest) GetSource

func (x *GetLogRequest) GetSource() string

func (*GetLogRequest) GetStart

func (x *GetLogRequest) GetStart() int64

func (*GetLogRequest) GetStream

func (x *GetLogRequest) GetStream() string

func (*GetLogRequest) MarshalJSON

func (m *GetLogRequest) MarshalJSON() ([]byte, error)

GetLogRequest implement json.Marshaler.

func (*GetLogRequest) ProtoMessage

func (*GetLogRequest) ProtoMessage()

func (*GetLogRequest) ProtoReflect

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

func (*GetLogRequest) Reset

func (x *GetLogRequest) Reset()

func (*GetLogRequest) String

func (x *GetLogRequest) String() string

func (*GetLogRequest) UnmarshalJSON

func (m *GetLogRequest) UnmarshalJSON(b []byte) error

GetLogRequest implement json.Marshaler.

func (*GetLogRequest) UnmarshalURLValues

func (m *GetLogRequest) UnmarshalURLValues(prefix string, values url.Values) error

GetLogRequest implement urlenc.URLValuesUnmarshaler.

func (*GetLogRequest) Validate

func (this *GetLogRequest) Validate() error

type GetLogResponse

type GetLogResponse struct {
	Lines []*LogItem `protobuf:"bytes,1,rep,name=lines,proto3" json:"lines,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogResponse) Descriptor deprecated

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

Deprecated: Use GetLogResponse.ProtoReflect.Descriptor instead.

func (*GetLogResponse) GetLines

func (x *GetLogResponse) GetLines() []*LogItem

func (*GetLogResponse) MarshalJSON

func (m *GetLogResponse) MarshalJSON() ([]byte, error)

GetLogResponse implement json.Marshaler.

func (*GetLogResponse) ProtoMessage

func (*GetLogResponse) ProtoMessage()

func (*GetLogResponse) ProtoReflect

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

func (*GetLogResponse) Reset

func (x *GetLogResponse) Reset()

func (*GetLogResponse) String

func (x *GetLogResponse) String() string

func (*GetLogResponse) UnmarshalJSON

func (m *GetLogResponse) UnmarshalJSON(b []byte) error

GetLogResponse implement json.Marshaler.

func (*GetLogResponse) UnmarshalURLValues

func (m *GetLogResponse) UnmarshalURLValues(prefix string, values url.Values) error

GetLogResponse implement urlenc.URLValuesUnmarshaler.

func (*GetLogResponse) Validate

func (this *GetLogResponse) Validate() error

type LogItem

type LogItem struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Source    string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Stream    string `protobuf:"bytes,3,opt,name=stream,proto3" json:"stream,omitempty"`
	Timestamp string `protobuf:"bytes,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	UnixNano  int64  `protobuf:"varint,6,opt,name=unixNano,proto3" json:"unixNano,omitempty"`
	Offset    int64  `protobuf:"varint,7,opt,name=offset,proto3" json:"offset,omitempty"`
	Content   string `protobuf:"bytes,8,opt,name=content,proto3" json:"content,omitempty"`
	Level     string `protobuf:"bytes,9,opt,name=level,proto3" json:"level,omitempty"`
	RequestId string `protobuf:"bytes,10,opt,name=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

func (*LogItem) Descriptor deprecated

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

Deprecated: Use LogItem.ProtoReflect.Descriptor instead.

func (*LogItem) GetContent

func (x *LogItem) GetContent() string

func (*LogItem) GetId

func (x *LogItem) GetId() string

func (*LogItem) GetLevel

func (x *LogItem) GetLevel() string

func (*LogItem) GetOffset

func (x *LogItem) GetOffset() int64

func (*LogItem) GetRequestId

func (x *LogItem) GetRequestId() string

func (*LogItem) GetSource

func (x *LogItem) GetSource() string

func (*LogItem) GetStream

func (x *LogItem) GetStream() string

func (*LogItem) GetTimestamp

func (x *LogItem) GetTimestamp() string

func (*LogItem) GetUnixNano added in v1.4.0

func (x *LogItem) GetUnixNano() int64

func (*LogItem) MarshalJSON

func (m *LogItem) MarshalJSON() ([]byte, error)

LogItem implement json.Marshaler.

func (*LogItem) ProtoMessage

func (*LogItem) ProtoMessage()

func (*LogItem) ProtoReflect

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

func (*LogItem) Reset

func (x *LogItem) Reset()

func (*LogItem) String

func (x *LogItem) String() string

func (*LogItem) UnmarshalJSON

func (m *LogItem) UnmarshalJSON(b []byte) error

LogItem implement json.Marshaler.

func (*LogItem) UnmarshalURLValues

func (m *LogItem) UnmarshalURLValues(prefix string, values url.Values) error

LogItem implement urlenc.URLValuesUnmarshaler.

func (*LogItem) Validate

func (this *LogItem) Validate() error

type LogQueryServiceClient

type LogQueryServiceClient interface {
	// +private
	GetLog(ctx context.Context, in *GetLogRequest, opts ...grpc.CallOption) (*GetLogResponse, error)
	// for runtime log
	GetLogByRuntime(ctx context.Context, in *GetLogByRuntimeRequest, opts ...grpc.CallOption) (*GetLogByRuntimeResponse, error)
	// for organization log
	GetLogByOrganization(ctx context.Context, in *GetLogByOrganizationRequest, opts ...grpc.CallOption) (*GetLogByOrganizationResponse, error)
}

LogQueryServiceClient is the client API for LogQueryService 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.

type LogQueryServiceHandler

type LogQueryServiceHandler interface {
	// +private
	// GET /api/logs
	GetLog(context.Context, *GetLogRequest) (*GetLogResponse, error)
	// for runtime log
	// GET /api/runtime/logs
	GetLogByRuntime(context.Context, *GetLogByRuntimeRequest) (*GetLogByRuntimeResponse, error)
	// for organization log
	// GET /api/orgCenter/logs
	GetLogByOrganization(context.Context, *GetLogByOrganizationRequest) (*GetLogByOrganizationResponse, error)
}

LogQueryServiceHandler is the server API for LogQueryService service.

type LogQueryServiceServer

type LogQueryServiceServer interface {
	// +private
	GetLog(context.Context, *GetLogRequest) (*GetLogResponse, error)
	// for runtime log
	GetLogByRuntime(context.Context, *GetLogByRuntimeRequest) (*GetLogByRuntimeResponse, error)
	// for organization log
	GetLogByOrganization(context.Context, *GetLogByOrganizationRequest) (*GetLogByOrganizationResponse, error)
}

LogQueryServiceServer is the server API for LogQueryService service. All implementations should embed UnimplementedLogQueryServiceServer for forward compatibility

type UnimplementedLogQueryServiceServer

type UnimplementedLogQueryServiceServer struct {
}

UnimplementedLogQueryServiceServer should be embedded to have forward compatible implementations.

func (*UnimplementedLogQueryServiceServer) GetLog

func (*UnimplementedLogQueryServiceServer) GetLogByOrganization

func (*UnimplementedLogQueryServiceServer) GetLogByRuntime

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL