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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_label_proto protoreflect.FileDescriptor

Functions

func LabelServiceClientType 

func LabelServiceClientType() reflect.Type

LabelServiceClientType .

func LabelServiceHandlerType 

func LabelServiceHandlerType() reflect.Type

LabelServiceHandlerType .

func LabelServiceServerType 

func LabelServiceServerType() reflect.Type

LabelServiceServerType .

func RegisterLabelServiceHandler 

func RegisterLabelServiceHandler(r http.Router, srv LabelServiceHandler, opts ...http.HandleOption)

RegisterLabelServiceHandler register LabelServiceHandler to http.Router.

func RegisterLabelServiceImp 

func RegisterLabelServiceImp(regester transport.Register, srv LabelServiceServer, opts ...transport.ServiceOption)

RegisterLabelServiceImp label.proto

func RegisterLabelServiceServer 

func RegisterLabelServiceServer(s grpc1.ServiceRegistrar, srv LabelServiceServer, opts ...grpc1.HandleOption)

func ServiceNames 

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

ServiceNames return all service names

func Types 

func Types() []reflect.Type

Types

type LabelServiceClient 

type LabelServiceClient interface {
	PipelineLabelBatchInsert(ctx context.Context, in *PipelineLabelBatchInsertRequest, opts ...grpc.CallOption) (*PipelineLabelBatchInsertResponse, error)
	PipelineLabelList(ctx context.Context, in *PipelineLabelListRequest, opts ...grpc.CallOption) (*PipelineLabelListResponse, error)
}

LabelServiceClient is the client API for LabelService 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 NewLabelServiceClient 

func NewLabelServiceClient(cc grpc1.ClientConnInterface) LabelServiceClient

type LabelServiceHandler 

type LabelServiceHandler interface {
	// POST /api/pipelines-labels/actions/batch-insert-labels
	PipelineLabelBatchInsert(context.Context, *PipelineLabelBatchInsertRequest) (*PipelineLabelBatchInsertResponse, error)
	// POST /api/pipelines-labels
	PipelineLabelList(context.Context, *PipelineLabelListRequest) (*PipelineLabelListResponse, error)
}

LabelServiceHandler is the server API for LabelService service.

type LabelServiceServer 

type LabelServiceServer interface {
	PipelineLabelBatchInsert(context.Context, *PipelineLabelBatchInsertRequest) (*PipelineLabelBatchInsertResponse, error)
	PipelineLabelList(context.Context, *PipelineLabelListRequest) (*PipelineLabelListResponse, error)
}

LabelServiceServer is the server API for LabelService service. All implementations should embed UnimplementedLabelServiceServer for forward compatibility

type PipelineLabel 

type PipelineLabel struct {
	ID              uint64                 `protobuf:"varint,1,opt,name=ID,json=id,proto3" json:"ID,omitempty"`
	Type            string                 `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	TargetID        uint64                 `protobuf:"varint,3,opt,name=targetID,proto3" json:"targetID,omitempty"`
	PipelineSource  string                 `protobuf:"bytes,4,opt,name=pipelineSource,proto3" json:"pipelineSource,omitempty"`
	PipelineYmlName string                 `protobuf:"bytes,5,opt,name=pipelineYmlName,proto3" json:"pipelineYmlName,omitempty"`
	Key             string                 `protobuf:"bytes,6,opt,name=key,proto3" json:"key,omitempty"`
	Value           string                 `protobuf:"bytes,7,opt,name=value,proto3" json:"value,omitempty"`
	TimeCreated     *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=timeCreated,proto3" json:"timeCreated,omitempty"`
	TimeUpdated     *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=timeUpdated,proto3" json:"timeUpdated,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineLabel) Descriptor deprecated 

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

Deprecated: Use PipelineLabel.ProtoReflect.Descriptor instead.

func (*PipelineLabel) GetID 

func (x *PipelineLabel) GetID() uint64

func (*PipelineLabel) GetKey 

func (x *PipelineLabel) GetKey() string

func (*PipelineLabel) GetPipelineSource 

func (x *PipelineLabel) GetPipelineSource() string

func (*PipelineLabel) GetPipelineYmlName 

func (x *PipelineLabel) GetPipelineYmlName() string

func (*PipelineLabel) GetTargetID 

func (x *PipelineLabel) GetTargetID() uint64

func (*PipelineLabel) GetTimeCreated 

func (x *PipelineLabel) GetTimeCreated() *timestamppb.Timestamp

func (*PipelineLabel) GetTimeUpdated 

func (x *PipelineLabel) GetTimeUpdated() *timestamppb.Timestamp

func (*PipelineLabel) GetType 

func (x *PipelineLabel) GetType() string

func (*PipelineLabel) GetValue 

func (x *PipelineLabel) GetValue() string

func (*PipelineLabel) MarshalJSON 

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

PipelineLabel implement json.Marshaler.

func (*PipelineLabel) ProtoMessage 

func (*PipelineLabel) ProtoMessage()

func (*PipelineLabel) ProtoReflect 

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

func (*PipelineLabel) Reset 

func (x *PipelineLabel) Reset()

func (*PipelineLabel) String 

func (x *PipelineLabel) String() string

func (*PipelineLabel) UnmarshalJSON 

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

PipelineLabel implement json.Marshaler.

func (*PipelineLabel) UnmarshalURLValues 

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

PipelineLabel implement urlenc.URLValuesUnmarshaler.

func (*PipelineLabel) Validate 

func (this *PipelineLabel) Validate() error

type PipelineLabelBatchInsertRequest 

type PipelineLabelBatchInsertRequest struct {
	Labels []*PipelineLabel `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineLabelBatchInsertRequest) Descriptor deprecated 

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

Deprecated: Use PipelineLabelBatchInsertRequest.ProtoReflect.Descriptor instead.

func (*PipelineLabelBatchInsertRequest) GetLabels 

func (x *PipelineLabelBatchInsertRequest) GetLabels() []*PipelineLabel

func (*PipelineLabelBatchInsertRequest) MarshalJSON 

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

PipelineLabelBatchInsertRequest implement json.Marshaler.

func (*PipelineLabelBatchInsertRequest) ProtoMessage 

func (*PipelineLabelBatchInsertRequest) ProtoMessage()

func (*PipelineLabelBatchInsertRequest) ProtoReflect 

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

func (*PipelineLabelBatchInsertRequest) Reset 

func (x *PipelineLabelBatchInsertRequest) Reset()

func (*PipelineLabelBatchInsertRequest) String 

func (x *PipelineLabelBatchInsertRequest) String() string

func (*PipelineLabelBatchInsertRequest) UnmarshalJSON 

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

PipelineLabelBatchInsertRequest implement json.Marshaler.

func (*PipelineLabelBatchInsertRequest) UnmarshalURLValues 

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

PipelineLabelBatchInsertRequest implement urlenc.URLValuesUnmarshaler.

func (*PipelineLabelBatchInsertRequest) Validate 

func (this *PipelineLabelBatchInsertRequest) Validate() error

type PipelineLabelBatchInsertResponse 

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

func (*PipelineLabelBatchInsertResponse) Descriptor deprecated 

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

Deprecated: Use PipelineLabelBatchInsertResponse.ProtoReflect.Descriptor instead.

func (*PipelineLabelBatchInsertResponse) MarshalJSON 

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

PipelineLabelBatchInsertResponse implement json.Marshaler.

func (*PipelineLabelBatchInsertResponse) ProtoMessage 

func (*PipelineLabelBatchInsertResponse) ProtoMessage()

func (*PipelineLabelBatchInsertResponse) ProtoReflect 

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

func (*PipelineLabelBatchInsertResponse) Reset 

func (x *PipelineLabelBatchInsertResponse) Reset()

func (*PipelineLabelBatchInsertResponse) String 

func (x *PipelineLabelBatchInsertResponse) String() string

func (*PipelineLabelBatchInsertResponse) UnmarshalJSON 

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

PipelineLabelBatchInsertResponse implement json.Marshaler.

func (*PipelineLabelBatchInsertResponse) UnmarshalURLValues 

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

PipelineLabelBatchInsertResponse implement urlenc.URLValuesUnmarshaler.

func (*PipelineLabelBatchInsertResponse) Validate 

func (this *PipelineLabelBatchInsertResponse) Validate() error

type PipelineLabelListRequest 

type PipelineLabelListRequest struct {
	PipelineSource  string   `protobuf:"bytes,1,opt,name=pipelineSource,proto3" json:"pipelineSource,omitempty"`
	PipelineYmlName string   `protobuf:"bytes,2,opt,name=pipelineYmlName,proto3" json:"pipelineYmlName,omitempty"`
	TargetIDs       []uint64 `protobuf:"varint,3,rep,packed,name=targetIDs,proto3" json:"targetIDs,omitempty"`
	MatchKeys       []string `protobuf:"bytes,4,rep,name=matchKeys,proto3" json:"matchKeys,omitempty"`
	UnMatchKeys     []string `protobuf:"bytes,5,rep,name=unMatchKeys,proto3" json:"unMatchKeys,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineLabelListRequest) Descriptor deprecated 

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

Deprecated: Use PipelineLabelListRequest.ProtoReflect.Descriptor instead.

func (*PipelineLabelListRequest) GetMatchKeys 

func (x *PipelineLabelListRequest) GetMatchKeys() []string

func (*PipelineLabelListRequest) GetPipelineSource 

func (x *PipelineLabelListRequest) GetPipelineSource() string

func (*PipelineLabelListRequest) GetPipelineYmlName 

func (x *PipelineLabelListRequest) GetPipelineYmlName() string

func (*PipelineLabelListRequest) GetTargetIDs 

func (x *PipelineLabelListRequest) GetTargetIDs() []uint64

func (*PipelineLabelListRequest) GetUnMatchKeys 

func (x *PipelineLabelListRequest) GetUnMatchKeys() []string

func (*PipelineLabelListRequest) MarshalJSON 

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

PipelineLabelListRequest implement json.Marshaler.

func (*PipelineLabelListRequest) ProtoMessage 

func (*PipelineLabelListRequest) ProtoMessage()

func (*PipelineLabelListRequest) ProtoReflect 

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

func (*PipelineLabelListRequest) Reset 

func (x *PipelineLabelListRequest) Reset()

func (*PipelineLabelListRequest) String 

func (x *PipelineLabelListRequest) String() string

func (*PipelineLabelListRequest) UnmarshalJSON 

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

PipelineLabelListRequest implement json.Marshaler.

func (*PipelineLabelListRequest) UnmarshalURLValues 

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

PipelineLabelListRequest implement urlenc.URLValuesUnmarshaler.

func (*PipelineLabelListRequest) Validate 

func (this *PipelineLabelListRequest) Validate() error

type PipelineLabelListResponse 

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

func (*PipelineLabelListResponse) Descriptor deprecated 

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

Deprecated: Use PipelineLabelListResponse.ProtoReflect.Descriptor instead.

func (*PipelineLabelListResponse) GetLabels 

func (x *PipelineLabelListResponse) GetLabels() []*PipelineLabel

func (*PipelineLabelListResponse) GetTotal 

func (x *PipelineLabelListResponse) GetTotal() int64

func (*PipelineLabelListResponse) MarshalJSON 

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

PipelineLabelListResponse implement json.Marshaler.

func (*PipelineLabelListResponse) ProtoMessage 

func (*PipelineLabelListResponse) ProtoMessage()

func (*PipelineLabelListResponse) ProtoReflect 

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

func (*PipelineLabelListResponse) Reset 

func (x *PipelineLabelListResponse) Reset()

func (*PipelineLabelListResponse) String 

func (x *PipelineLabelListResponse) String() string

func (*PipelineLabelListResponse) UnmarshalJSON 

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

PipelineLabelListResponse implement json.Marshaler.

func (*PipelineLabelListResponse) UnmarshalURLValues 

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

PipelineLabelListResponse implement urlenc.URLValuesUnmarshaler.

func (*PipelineLabelListResponse) Validate 

func (this *PipelineLabelListResponse) Validate() error

type UnimplementedLabelServiceServer 

type UnimplementedLabelServiceServer struct {
}

UnimplementedLabelServiceServer should be embedded to have forward compatible implementations.

func (*UnimplementedLabelServiceServer) PipelineLabelBatchInsert 

func (*UnimplementedLabelServiceServer) PipelineLabelBatchInsert(context.Context, *PipelineLabelBatchInsertRequest) (*PipelineLabelBatchInsertResponse, error)

func (*UnimplementedLabelServiceServer) PipelineLabelList 

func (*UnimplementedLabelServiceServer) PipelineLabelList(context.Context, *PipelineLabelListRequest) (*PipelineLabelListResponse, error)

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.