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: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_report_proto protoreflect.FileDescriptor

Functions

func RegisterReportServiceHandler

func RegisterReportServiceHandler(r http.Router, srv ReportServiceHandler, opts ...http.HandleOption)

RegisterReportServiceHandler register ReportServiceHandler to http.Router.

func RegisterReportServiceImp

func RegisterReportServiceImp(regester transport.Register, srv ReportServiceServer, opts ...transport.ServiceOption)

RegisterReportServiceImp report.proto

func RegisterReportServiceServer

func RegisterReportServiceServer(s grpc1.ServiceRegistrar, srv ReportServiceServer, opts ...grpc1.HandleOption)

func ReportServiceClientType

func ReportServiceClientType() reflect.Type

ReportServiceClientType .

func ReportServiceHandlerType

func ReportServiceHandlerType() reflect.Type

ReportServiceHandlerType .

func ReportServiceServerType

func ReportServiceServerType() reflect.Type

ReportServiceServerType .

func ServiceNames

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

ServiceNames return all service names

func Types

func Types() []reflect.Type

Types

type PipelineReport

type PipelineReport struct {
	ID         uint64                 `protobuf:"varint,1,opt,name=ID,json=id,proto3" json:"ID,omitempty"`
	PipelineID uint64                 `protobuf:"varint,2,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"`
	Type       string                 `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Meta       *structpb.Struct       `protobuf:"bytes,4,opt,name=meta,proto3" json:"meta,omitempty"`
	CreatorID  string                 `protobuf:"bytes,5,opt,name=creatorID,proto3" json:"creatorID,omitempty"`
	UpdaterID  string                 `protobuf:"bytes,6,opt,name=updaterID,proto3" json:"updaterID,omitempty"`
	CreatedAt  *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	UpdatedAt  *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineReport) Descriptor deprecated

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

Deprecated: Use PipelineReport.ProtoReflect.Descriptor instead.

func (*PipelineReport) GetCreatedAt

func (x *PipelineReport) GetCreatedAt() *timestamppb.Timestamp

func (*PipelineReport) GetCreatorID

func (x *PipelineReport) GetCreatorID() string

func (*PipelineReport) GetID

func (x *PipelineReport) GetID() uint64

func (*PipelineReport) GetMeta

func (x *PipelineReport) GetMeta() *structpb.Struct

func (*PipelineReport) GetPipelineID

func (x *PipelineReport) GetPipelineID() uint64

func (*PipelineReport) GetType

func (x *PipelineReport) GetType() string

func (*PipelineReport) GetUpdatedAt

func (x *PipelineReport) GetUpdatedAt() *timestamppb.Timestamp

func (*PipelineReport) GetUpdaterID

func (x *PipelineReport) GetUpdaterID() string

func (*PipelineReport) MarshalJSON

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

PipelineReport implement json.Marshaler.

func (*PipelineReport) ProtoMessage

func (*PipelineReport) ProtoMessage()

func (*PipelineReport) ProtoReflect

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

func (*PipelineReport) Reset

func (x *PipelineReport) Reset()

func (*PipelineReport) String

func (x *PipelineReport) String() string

func (*PipelineReport) UnmarshalJSON

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

PipelineReport implement json.Marshaler.

func (*PipelineReport) UnmarshalURLValues

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

PipelineReport implement urlenc.URLValuesUnmarshaler.

func (*PipelineReport) Validate

func (this *PipelineReport) Validate() error

type PipelineReportCreateRequest

type PipelineReportCreateRequest struct {
	PipelineID   uint64           `protobuf:"varint,1,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"`
	Type         string           `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Meta         *structpb.Struct `protobuf:"bytes,3,opt,name=meta,proto3" json:"meta,omitempty"`
	IdentityInfo *pb.IdentityInfo `protobuf:"bytes,4,opt,name=identityInfo,proto3" json:"identityInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineReportCreateRequest) Descriptor deprecated

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

Deprecated: Use PipelineReportCreateRequest.ProtoReflect.Descriptor instead.

func (*PipelineReportCreateRequest) GetIdentityInfo

func (x *PipelineReportCreateRequest) GetIdentityInfo() *pb.IdentityInfo

func (*PipelineReportCreateRequest) GetMeta

func (*PipelineReportCreateRequest) GetPipelineID

func (x *PipelineReportCreateRequest) GetPipelineID() uint64

func (*PipelineReportCreateRequest) GetType

func (x *PipelineReportCreateRequest) GetType() string

func (*PipelineReportCreateRequest) MarshalJSON

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

PipelineReportCreateRequest implement json.Marshaler.

func (*PipelineReportCreateRequest) ProtoMessage

func (*PipelineReportCreateRequest) ProtoMessage()

func (*PipelineReportCreateRequest) ProtoReflect

func (*PipelineReportCreateRequest) Reset

func (x *PipelineReportCreateRequest) Reset()

func (*PipelineReportCreateRequest) String

func (x *PipelineReportCreateRequest) String() string

func (*PipelineReportCreateRequest) UnmarshalJSON

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

PipelineReportCreateRequest implement json.Marshaler.

func (*PipelineReportCreateRequest) UnmarshalURLValues

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

PipelineReportCreateRequest implement urlenc.URLValuesUnmarshaler.

func (*PipelineReportCreateRequest) Validate

func (this *PipelineReportCreateRequest) Validate() error

type PipelineReportCreateResponse

type PipelineReportCreateResponse struct {
	Data *PipelineReport `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineReportCreateResponse) Descriptor deprecated

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

Deprecated: Use PipelineReportCreateResponse.ProtoReflect.Descriptor instead.

func (*PipelineReportCreateResponse) GetData

func (*PipelineReportCreateResponse) MarshalJSON

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

PipelineReportCreateResponse implement json.Marshaler.

func (*PipelineReportCreateResponse) ProtoMessage

func (*PipelineReportCreateResponse) ProtoMessage()

func (*PipelineReportCreateResponse) ProtoReflect

func (*PipelineReportCreateResponse) Reset

func (x *PipelineReportCreateResponse) Reset()

func (*PipelineReportCreateResponse) String

func (*PipelineReportCreateResponse) UnmarshalJSON

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

PipelineReportCreateResponse implement json.Marshaler.

func (*PipelineReportCreateResponse) UnmarshalURLValues

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

PipelineReportCreateResponse implement urlenc.URLValuesUnmarshaler.

func (*PipelineReportCreateResponse) Validate

func (this *PipelineReportCreateResponse) Validate() error

type PipelineReportSet

type PipelineReportSet struct {
	PipelineID uint64            `protobuf:"varint,1,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"`
	Reports    []*PipelineReport `protobuf:"bytes,2,rep,name=reports,proto3" json:"reports,omitempty"`
	// contains filtered or unexported fields
}

PipelineReportSet 流水线报告集,一条流水线可能会有多个报告,称为报告集

func (*PipelineReportSet) Descriptor deprecated

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

Deprecated: Use PipelineReportSet.ProtoReflect.Descriptor instead.

func (*PipelineReportSet) GetPipelineID

func (x *PipelineReportSet) GetPipelineID() uint64

func (*PipelineReportSet) GetReports

func (x *PipelineReportSet) GetReports() []*PipelineReport

func (*PipelineReportSet) MarshalJSON

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

PipelineReportSet implement json.Marshaler.

func (*PipelineReportSet) ProtoMessage

func (*PipelineReportSet) ProtoMessage()

func (*PipelineReportSet) ProtoReflect

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

func (*PipelineReportSet) Reset

func (x *PipelineReportSet) Reset()

func (*PipelineReportSet) String

func (x *PipelineReportSet) String() string

func (*PipelineReportSet) UnmarshalJSON

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

PipelineReportSet implement json.Marshaler.

func (*PipelineReportSet) UnmarshalURLValues

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

PipelineReportSet implement urlenc.URLValuesUnmarshaler.

func (*PipelineReportSet) Validate

func (this *PipelineReportSet) Validate() error

type PipelineReportSetPagingRequest

type PipelineReportSetPagingRequest struct {
	PipelineIDs []uint64 `protobuf:"varint,1,rep,packed,name=pipelineIDs,json=-,proto3" json:"pipelineIDs,omitempty"`
	Sources     []string `protobuf:"bytes,2,rep,name=sources,proto3" json:"sources,omitempty"`
	Types       []string `protobuf:"bytes,3,rep,name=types,proto3" json:"types,omitempty"`
	/////////////////////////
	// pipeline 分页查询参数 //
	/////////////////////////
	// labels
	// &mustMatchLabel=key2=value3
	MustMatchLabelsQueryParams []string `protobuf:"bytes,4,rep,name=mustMatchLabelsQueryParams,proto3" json:"mustMatchLabelsQueryParams,omitempty"`
	// times
	// 开始执行时间 左闭区间
	StartTimeBeginTimestamp int64 `protobuf:"varint,5,opt,name=startTimeBeginTimestamp,proto3" json:"startTimeBeginTimestamp,omitempty"`
	// 开始执行时间 右闭区间
	EndTimeBeginTimestamp int64 `protobuf:"varint,6,opt,name=endTimeBeginTimestamp,proto3" json:"endTimeBeginTimestamp,omitempty"`
	// 创建时间 左闭区间
	StartTimeCreatedTimestamp int64 `protobuf:"varint,7,opt,name=startTimeCreatedTimestamp,proto3" json:"startTimeCreatedTimestamp,omitempty"`
	// 创建时间 右闭区间
	EndTimeCreatedTimestamp int64 `protobuf:"varint,8,opt,name=endTimeCreatedTimestamp,proto3" json:"endTimeCreatedTimestamp,omitempty"`
	PageNum                 int64 `protobuf:"varint,9,opt,name=pageNum,proto3" json:"pageNum,omitempty"`
	PageSize                int64 `protobuf:"varint,10,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineReportSetPagingRequest) Descriptor deprecated

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

Deprecated: Use PipelineReportSetPagingRequest.ProtoReflect.Descriptor instead.

func (*PipelineReportSetPagingRequest) GetEndTimeBeginTimestamp

func (x *PipelineReportSetPagingRequest) GetEndTimeBeginTimestamp() int64

func (*PipelineReportSetPagingRequest) GetEndTimeCreatedTimestamp

func (x *PipelineReportSetPagingRequest) GetEndTimeCreatedTimestamp() int64

func (*PipelineReportSetPagingRequest) GetMustMatchLabelsQueryParams

func (x *PipelineReportSetPagingRequest) GetMustMatchLabelsQueryParams() []string

func (*PipelineReportSetPagingRequest) GetPageNum

func (x *PipelineReportSetPagingRequest) GetPageNum() int64

func (*PipelineReportSetPagingRequest) GetPageSize

func (x *PipelineReportSetPagingRequest) GetPageSize() int64

func (*PipelineReportSetPagingRequest) GetPipelineIDs

func (x *PipelineReportSetPagingRequest) GetPipelineIDs() []uint64

func (*PipelineReportSetPagingRequest) GetSources

func (x *PipelineReportSetPagingRequest) GetSources() []string

func (*PipelineReportSetPagingRequest) GetStartTimeBeginTimestamp

func (x *PipelineReportSetPagingRequest) GetStartTimeBeginTimestamp() int64

func (*PipelineReportSetPagingRequest) GetStartTimeCreatedTimestamp

func (x *PipelineReportSetPagingRequest) GetStartTimeCreatedTimestamp() int64

func (*PipelineReportSetPagingRequest) GetTypes

func (x *PipelineReportSetPagingRequest) GetTypes() []string

func (*PipelineReportSetPagingRequest) MarshalJSON

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

PipelineReportSetPagingRequest implement json.Marshaler.

func (*PipelineReportSetPagingRequest) ProtoMessage

func (*PipelineReportSetPagingRequest) ProtoMessage()

func (*PipelineReportSetPagingRequest) ProtoReflect

func (*PipelineReportSetPagingRequest) Reset

func (x *PipelineReportSetPagingRequest) Reset()

func (*PipelineReportSetPagingRequest) String

func (*PipelineReportSetPagingRequest) UnmarshalJSON

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

PipelineReportSetPagingRequest implement json.Marshaler.

func (*PipelineReportSetPagingRequest) UnmarshalURLValues

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

PipelineReportSetPagingRequest implement urlenc.URLValuesUnmarshaler.

func (*PipelineReportSetPagingRequest) Validate

func (this *PipelineReportSetPagingRequest) Validate() error

type PipelineReportSetPagingResponse

type PipelineReportSetPagingResponse struct {
	Total int64                `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Data  []*PipelineReportSet `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineReportSetPagingResponse) Descriptor deprecated

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

Deprecated: Use PipelineReportSetPagingResponse.ProtoReflect.Descriptor instead.

func (*PipelineReportSetPagingResponse) GetData

func (*PipelineReportSetPagingResponse) GetTotal

func (x *PipelineReportSetPagingResponse) GetTotal() int64

func (*PipelineReportSetPagingResponse) MarshalJSON

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

PipelineReportSetPagingResponse implement json.Marshaler.

func (*PipelineReportSetPagingResponse) ProtoMessage

func (*PipelineReportSetPagingResponse) ProtoMessage()

func (*PipelineReportSetPagingResponse) ProtoReflect

func (*PipelineReportSetPagingResponse) Reset

func (*PipelineReportSetPagingResponse) String

func (*PipelineReportSetPagingResponse) UnmarshalJSON

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

PipelineReportSetPagingResponse implement json.Marshaler.

func (*PipelineReportSetPagingResponse) UnmarshalURLValues

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

PipelineReportSetPagingResponse implement urlenc.URLValuesUnmarshaler.

func (*PipelineReportSetPagingResponse) Validate

func (this *PipelineReportSetPagingResponse) Validate() error

type PipelineReportSetQueryRequest

type PipelineReportSetQueryRequest struct {
	PipelineID uint64   `protobuf:"varint,1,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"`
	Types      []string `protobuf:"bytes,2,rep,name=types,proto3" json:"types,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineReportSetQueryRequest) Descriptor deprecated

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

Deprecated: Use PipelineReportSetQueryRequest.ProtoReflect.Descriptor instead.

func (*PipelineReportSetQueryRequest) GetPipelineID

func (x *PipelineReportSetQueryRequest) GetPipelineID() uint64

func (*PipelineReportSetQueryRequest) GetTypes

func (x *PipelineReportSetQueryRequest) GetTypes() []string

func (*PipelineReportSetQueryRequest) MarshalJSON

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

PipelineReportSetQueryRequest implement json.Marshaler.

func (*PipelineReportSetQueryRequest) ProtoMessage

func (*PipelineReportSetQueryRequest) ProtoMessage()

func (*PipelineReportSetQueryRequest) ProtoReflect

func (*PipelineReportSetQueryRequest) Reset

func (x *PipelineReportSetQueryRequest) Reset()

func (*PipelineReportSetQueryRequest) String

func (*PipelineReportSetQueryRequest) UnmarshalJSON

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

PipelineReportSetQueryRequest implement json.Marshaler.

func (*PipelineReportSetQueryRequest) UnmarshalURLValues

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

PipelineReportSetQueryRequest implement urlenc.URLValuesUnmarshaler.

func (*PipelineReportSetQueryRequest) Validate

func (this *PipelineReportSetQueryRequest) Validate() error

type PipelineReportSetQueryResponse

type PipelineReportSetQueryResponse struct {
	Data *PipelineReportSet `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineReportSetQueryResponse) Descriptor deprecated

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

Deprecated: Use PipelineReportSetQueryResponse.ProtoReflect.Descriptor instead.

func (*PipelineReportSetQueryResponse) GetData

func (*PipelineReportSetQueryResponse) MarshalJSON

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

PipelineReportSetQueryResponse implement json.Marshaler.

func (*PipelineReportSetQueryResponse) ProtoMessage

func (*PipelineReportSetQueryResponse) ProtoMessage()

func (*PipelineReportSetQueryResponse) ProtoReflect

func (*PipelineReportSetQueryResponse) Reset

func (x *PipelineReportSetQueryResponse) Reset()

func (*PipelineReportSetQueryResponse) String

func (*PipelineReportSetQueryResponse) UnmarshalJSON

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

PipelineReportSetQueryResponse implement json.Marshaler.

func (*PipelineReportSetQueryResponse) UnmarshalURLValues

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

PipelineReportSetQueryResponse implement urlenc.URLValuesUnmarshaler.

func (*PipelineReportSetQueryResponse) Validate

func (this *PipelineReportSetQueryResponse) Validate() error

type ReportServiceClient

type ReportServiceClient interface {
	QueryPipelineReportSet(ctx context.Context, in *PipelineReportSetQueryRequest, opts ...grpc.CallOption) (*PipelineReportSetQueryResponse, error)
	PagingPipelineReportSet(ctx context.Context, in *PipelineReportSetPagingRequest, opts ...grpc.CallOption) (*PipelineReportSetPagingResponse, error)
}

ReportServiceClient is the client API for ReportService 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 ReportServiceHandler

type ReportServiceHandler interface {
	// GET /api/pipeline-reportsets/{pipelineID}
	QueryPipelineReportSet(context.Context, *PipelineReportSetQueryRequest) (*PipelineReportSetQueryResponse, error)
	// GET /api/pipeline-reportsets
	PagingPipelineReportSet(context.Context, *PipelineReportSetPagingRequest) (*PipelineReportSetPagingResponse, error)
}

ReportServiceHandler is the server API for ReportService service.

type ReportServiceServer

type ReportServiceServer interface {
	QueryPipelineReportSet(context.Context, *PipelineReportSetQueryRequest) (*PipelineReportSetQueryResponse, error)
	PagingPipelineReportSet(context.Context, *PipelineReportSetPagingRequest) (*PipelineReportSetPagingResponse, error)
}

ReportServiceServer is the server API for ReportService service. All implementations should embed UnimplementedReportServiceServer for forward compatibility

type UnimplementedReportServiceServer

type UnimplementedReportServiceServer struct {
}

UnimplementedReportServiceServer should be embedded to have forward compatible implementations.

Jump to

Keyboard shortcuts

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