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: 26 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_definition_proto protoreflect.FileDescriptor

Functions

func DefinitionServiceClientType 

func DefinitionServiceClientType() reflect.Type

DefinitionServiceClientType .

func DefinitionServiceHandlerType 

func DefinitionServiceHandlerType() reflect.Type

DefinitionServiceHandlerType .

func DefinitionServiceServerType 

func DefinitionServiceServerType() reflect.Type

DefinitionServiceServerType .

func RegisterDefinitionServiceHandler 

func RegisterDefinitionServiceHandler(r http.Router, srv DefinitionServiceHandler, opts ...http.HandleOption)

RegisterDefinitionServiceHandler register DefinitionServiceHandler to http.Router.

func RegisterDefinitionServiceImp 

func RegisterDefinitionServiceImp(regester transport.Register, srv DefinitionServiceServer, opts ...transport.ServiceOption)

RegisterDefinitionServiceImp definition.proto

func RegisterDefinitionServiceServer 

func RegisterDefinitionServiceServer(s grpc1.ServiceRegistrar, srv DefinitionServiceServer, opts ...grpc1.HandleOption)

func ServiceNames 

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

ServiceNames return all service names

func Types 

func Types() []reflect.Type

Types

type DefinitionServiceClient 

type DefinitionServiceClient interface {
	Process(ctx context.Context, in *PipelineDefinitionProcessRequest, opts ...grpc.CallOption) (*PipelineDefinitionProcessResponse, error)
	Version(ctx context.Context, in *PipelineDefinitionProcessVersionRequest, opts ...grpc.CallOption) (*PipelineDefinitionProcessVersionResponse, error)
}

DefinitionServiceClient is the client API for DefinitionService 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 NewDefinitionServiceClient 

func NewDefinitionServiceClient(cc grpc1.ClientConnInterface) DefinitionServiceClient

type DefinitionServiceHandler 

type DefinitionServiceHandler interface {
	// POST /api/pipeline-definitions/actions/process
	Process(context.Context, *PipelineDefinitionProcessRequest) (*PipelineDefinitionProcessResponse, error)
	// GET /api/pipeline-definitions/actions/version
	Version(context.Context, *PipelineDefinitionProcessVersionRequest) (*PipelineDefinitionProcessVersionResponse, error)
}

DefinitionServiceHandler is the server API for DefinitionService service.

type DefinitionServiceServer 

type DefinitionServiceServer interface {
	Process(context.Context, *PipelineDefinitionProcessRequest) (*PipelineDefinitionProcessResponse, error)
	Version(context.Context, *PipelineDefinitionProcessVersionRequest) (*PipelineDefinitionProcessVersionResponse, error)
}

DefinitionServiceServer is the server API for DefinitionService service. All implementations should embed UnimplementedDefinitionServiceServer for forward compatibility

type PipelineDefinitionProcessRequest 

type PipelineDefinitionProcessRequest struct {

	// pipeline yml source
	PipelineSource string `protobuf:"bytes,1,opt,name=pipelineSource,proto3" json:"pipelineSource,omitempty"`
	// pipeline yml name
	PipelineYmlName string `protobuf:"bytes,2,opt,name=pipelineYmlName,proto3" json:"pipelineYmlName,omitempty"`
	// pipeline yml content
	PipelineYml string `protobuf:"bytes,3,opt,name=pipelineYml,proto3" json:"pipelineYml,omitempty"`
	// snippetConfig means definition can be quoted by snippet
	SnippetConfig *structpb.Value `protobuf:"bytes,4,opt,name=snippetConfig,proto3" json:"snippetConfig,omitempty"`
	// versionLock means db optimistic lock
	VersionLock uint64 `protobuf:"varint,5,opt,name=versionLock,proto3" json:"versionLock,omitempty"`
	// isDelete
	// - if = true send With pipelineSource and pipelineYmlName to request
	IsDelete bool `protobuf:"varint,6,opt,name=isDelete,proto3" json:"isDelete,omitempty"`
	// pipelineCreateRequest means definition can autoRun
	PipelineCreateRequest *structpb.Value `protobuf:"bytes,7,opt,name=pipelineCreateRequest,proto3" json:"pipelineCreateRequest,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineDefinitionProcessRequest) Descriptor deprecated 

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

Deprecated: Use PipelineDefinitionProcessRequest.ProtoReflect.Descriptor instead.

func (*PipelineDefinitionProcessRequest) GetIsDelete 

func (x *PipelineDefinitionProcessRequest) GetIsDelete() bool

func (*PipelineDefinitionProcessRequest) GetPipelineCreateRequest 

func (x *PipelineDefinitionProcessRequest) GetPipelineCreateRequest() *structpb.Value

func (*PipelineDefinitionProcessRequest) GetPipelineSource 

func (x *PipelineDefinitionProcessRequest) GetPipelineSource() string

func (*PipelineDefinitionProcessRequest) GetPipelineYml 

func (x *PipelineDefinitionProcessRequest) GetPipelineYml() string

func (*PipelineDefinitionProcessRequest) GetPipelineYmlName 

func (x *PipelineDefinitionProcessRequest) GetPipelineYmlName() string

func (*PipelineDefinitionProcessRequest) GetSnippetConfig 

func (x *PipelineDefinitionProcessRequest) GetSnippetConfig() *structpb.Value

func (*PipelineDefinitionProcessRequest) GetVersionLock 

func (x *PipelineDefinitionProcessRequest) GetVersionLock() uint64

func (*PipelineDefinitionProcessRequest) MarshalJSON 

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

PipelineDefinitionProcessRequest implement json.Marshaler.

func (*PipelineDefinitionProcessRequest) ProtoMessage 

func (*PipelineDefinitionProcessRequest) ProtoMessage()

func (*PipelineDefinitionProcessRequest) ProtoReflect 

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

func (*PipelineDefinitionProcessRequest) Reset 

func (x *PipelineDefinitionProcessRequest) Reset()

func (*PipelineDefinitionProcessRequest) String 

func (x *PipelineDefinitionProcessRequest) String() string

func (*PipelineDefinitionProcessRequest) UnmarshalJSON 

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

PipelineDefinitionProcessRequest implement json.Marshaler.

func (*PipelineDefinitionProcessRequest) UnmarshalURLValues 

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

PipelineDefinitionProcessRequest implement urlenc.URLValuesUnmarshaler.

func (*PipelineDefinitionProcessRequest) Validate 

func (this *PipelineDefinitionProcessRequest) Validate() error

type PipelineDefinitionProcessResponse 

type PipelineDefinitionProcessResponse struct {
	Id              uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	PipelineSource  string `protobuf:"bytes,2,opt,name=pipelineSource,proto3" json:"pipelineSource,omitempty"`
	PipelineYmlName string `protobuf:"bytes,3,opt,name=pipelineYmlName,proto3" json:"pipelineYmlName,omitempty"`
	PipelineYml     string `protobuf:"bytes,4,opt,name=pipelineYml,proto3" json:"pipelineYml,omitempty"`
	VersionLock     uint64 `protobuf:"varint,5,opt,name=versionLock,proto3" json:"versionLock,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineDefinitionProcessResponse) Descriptor deprecated 

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

Deprecated: Use PipelineDefinitionProcessResponse.ProtoReflect.Descriptor instead.

func (*PipelineDefinitionProcessResponse) GetId 

func (x *PipelineDefinitionProcessResponse) GetId() uint64

func (*PipelineDefinitionProcessResponse) GetPipelineSource 

func (x *PipelineDefinitionProcessResponse) GetPipelineSource() string

func (*PipelineDefinitionProcessResponse) GetPipelineYml 

func (x *PipelineDefinitionProcessResponse) GetPipelineYml() string

func (*PipelineDefinitionProcessResponse) GetPipelineYmlName 

func (x *PipelineDefinitionProcessResponse) GetPipelineYmlName() string

func (*PipelineDefinitionProcessResponse) GetVersionLock 

func (x *PipelineDefinitionProcessResponse) GetVersionLock() uint64

func (*PipelineDefinitionProcessResponse) MarshalJSON 

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

PipelineDefinitionProcessResponse implement json.Marshaler.

func (*PipelineDefinitionProcessResponse) ProtoMessage 

func (*PipelineDefinitionProcessResponse) ProtoMessage()

func (*PipelineDefinitionProcessResponse) ProtoReflect 

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

func (*PipelineDefinitionProcessResponse) Reset 

func (x *PipelineDefinitionProcessResponse) Reset()

func (*PipelineDefinitionProcessResponse) String 

func (x *PipelineDefinitionProcessResponse) String() string

func (*PipelineDefinitionProcessResponse) UnmarshalJSON 

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

PipelineDefinitionProcessResponse implement json.Marshaler.

func (*PipelineDefinitionProcessResponse) UnmarshalURLValues 

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

PipelineDefinitionProcessResponse implement urlenc.URLValuesUnmarshaler.

func (*PipelineDefinitionProcessResponse) Validate 

func (this *PipelineDefinitionProcessResponse) Validate() error

type PipelineDefinitionProcessVersionRequest 

type PipelineDefinitionProcessVersionRequest struct {

	// pipeline yml source
	PipelineSource string `protobuf:"bytes,1,opt,name=pipelineSource,proto3" json:"pipelineSource,omitempty"`
	// pipeline yml name
	PipelineYmlName string `protobuf:"bytes,2,opt,name=pipelineYmlName,proto3" json:"pipelineYmlName,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineDefinitionProcessVersionRequest) Descriptor deprecated 

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

Deprecated: Use PipelineDefinitionProcessVersionRequest.ProtoReflect.Descriptor instead.

func (*PipelineDefinitionProcessVersionRequest) GetPipelineSource 

func (x *PipelineDefinitionProcessVersionRequest) GetPipelineSource() string

func (*PipelineDefinitionProcessVersionRequest) GetPipelineYmlName 

func (x *PipelineDefinitionProcessVersionRequest) GetPipelineYmlName() string

func (*PipelineDefinitionProcessVersionRequest) MarshalJSON 

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

PipelineDefinitionProcessVersionRequest implement json.Marshaler.

func (*PipelineDefinitionProcessVersionRequest) ProtoMessage 

func (*PipelineDefinitionProcessVersionRequest) ProtoMessage()

func (*PipelineDefinitionProcessVersionRequest) ProtoReflect 

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

func (*PipelineDefinitionProcessVersionRequest) Reset 

func (x *PipelineDefinitionProcessVersionRequest) Reset()

func (*PipelineDefinitionProcessVersionRequest) String 

func (x *PipelineDefinitionProcessVersionRequest) String() string

func (*PipelineDefinitionProcessVersionRequest) UnmarshalJSON 

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

PipelineDefinitionProcessVersionRequest implement json.Marshaler.

func (*PipelineDefinitionProcessVersionRequest) UnmarshalURLValues 

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

PipelineDefinitionProcessVersionRequest implement urlenc.URLValuesUnmarshaler.

func (*PipelineDefinitionProcessVersionRequest) Validate 

func (this *PipelineDefinitionProcessVersionRequest) Validate() error

type PipelineDefinitionProcessVersionResponse 

type PipelineDefinitionProcessVersionResponse struct {
	VersionLock uint64 `protobuf:"varint,1,opt,name=versionLock,proto3" json:"versionLock,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineDefinitionProcessVersionResponse) Descriptor deprecated 

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

Deprecated: Use PipelineDefinitionProcessVersionResponse.ProtoReflect.Descriptor instead.

func (*PipelineDefinitionProcessVersionResponse) GetVersionLock 

func (x *PipelineDefinitionProcessVersionResponse) GetVersionLock() uint64

func (*PipelineDefinitionProcessVersionResponse) MarshalJSON 

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

PipelineDefinitionProcessVersionResponse implement json.Marshaler.

func (*PipelineDefinitionProcessVersionResponse) ProtoMessage 

func (*PipelineDefinitionProcessVersionResponse) ProtoMessage()

func (*PipelineDefinitionProcessVersionResponse) ProtoReflect 

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

func (*PipelineDefinitionProcessVersionResponse) Reset 

func (x *PipelineDefinitionProcessVersionResponse) Reset()

func (*PipelineDefinitionProcessVersionResponse) String 

func (x *PipelineDefinitionProcessVersionResponse) String() string

func (*PipelineDefinitionProcessVersionResponse) UnmarshalJSON 

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

PipelineDefinitionProcessVersionResponse implement json.Marshaler.

func (*PipelineDefinitionProcessVersionResponse) UnmarshalURLValues 

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

PipelineDefinitionProcessVersionResponse implement urlenc.URLValuesUnmarshaler.

func (*PipelineDefinitionProcessVersionResponse) Validate 

func (this *PipelineDefinitionProcessVersionResponse) Validate() error

type UnimplementedDefinitionServiceServer 

type UnimplementedDefinitionServiceServer struct {
}

UnimplementedDefinitionServiceServer should be embedded to have forward compatible implementations.

func (*UnimplementedDefinitionServiceServer) Process 

func (*UnimplementedDefinitionServiceServer) Process(context.Context, *PipelineDefinitionProcessRequest) (*PipelineDefinitionProcessResponse, error)

func (*UnimplementedDefinitionServiceServer) Version 

func (*UnimplementedDefinitionServiceServer) Version(context.Context, *PipelineDefinitionProcessVersionRequest) (*PipelineDefinitionProcessVersionResponse, 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.