proto

package
v0.0.0-...-665dfdd Latest Latest
Warning

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

 Go to latest Published: Dec 14, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_proto_pipeline_proto protoreflect.FileDescriptor
View Source 
var Pipeline_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pipeline.Pipeline",
	HandlerType: (*PipelineServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateGroup",
			Handler:    _Pipeline_CreateGroup_Handler,
		},
		{
			MethodName: "DeleteGroup",
			Handler:    _Pipeline_DeleteGroup_Handler,
		},
		{
			MethodName: "CreatePipeline",
			Handler:    _Pipeline_CreatePipeline_Handler,
		},
		{
			MethodName: "DeletePipeline",
			Handler:    _Pipeline_DeletePipeline_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/pipeline.proto",
}

Pipeline_ServiceDesc is the grpc.ServiceDesc for Pipeline service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterPipelineServer 

func RegisterPipelineServer(s grpc.ServiceRegistrar, srv PipelineServer)

Types

type CreateGroupRequest 

type CreateGroupRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateGroupRequest) Descriptor deprecated 

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

Deprecated: Use CreateGroupRequest.ProtoReflect.Descriptor instead.

func (*CreateGroupRequest) GetName 

func (x *CreateGroupRequest) GetName() string

func (*CreateGroupRequest) ProtoMessage 

func (*CreateGroupRequest) ProtoMessage()

func (*CreateGroupRequest) ProtoReflect 

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

func (*CreateGroupRequest) Reset 

func (x *CreateGroupRequest) Reset()

func (*CreateGroupRequest) String 

func (x *CreateGroupRequest) String() string

type CreatePipelineRequest 

type CreatePipelineRequest struct {
	Group string `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	Name  string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*CreatePipelineRequest) Descriptor deprecated 

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

Deprecated: Use CreatePipelineRequest.ProtoReflect.Descriptor instead.

func (*CreatePipelineRequest) GetGroup 

func (x *CreatePipelineRequest) GetGroup() string

func (*CreatePipelineRequest) GetName 

func (x *CreatePipelineRequest) GetName() string

func (*CreatePipelineRequest) ProtoMessage 

func (*CreatePipelineRequest) ProtoMessage()

func (*CreatePipelineRequest) ProtoReflect 

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

func (*CreatePipelineRequest) Reset 

func (x *CreatePipelineRequest) Reset()

func (*CreatePipelineRequest) String 

func (x *CreatePipelineRequest) String() string

type DeleteGroupRequest 

type DeleteGroupRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteGroupRequest) Descriptor deprecated 

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

Deprecated: Use DeleteGroupRequest.ProtoReflect.Descriptor instead.

func (*DeleteGroupRequest) GetId 

func (x *DeleteGroupRequest) GetId() string

func (*DeleteGroupRequest) ProtoMessage 

func (*DeleteGroupRequest) ProtoMessage()

func (*DeleteGroupRequest) ProtoReflect 

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

func (*DeleteGroupRequest) Reset 

func (x *DeleteGroupRequest) Reset()

func (*DeleteGroupRequest) String 

func (x *DeleteGroupRequest) String() string

type DeletePipelineRequest 

type DeletePipelineRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeletePipelineRequest) Descriptor deprecated 

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

Deprecated: Use DeletePipelineRequest.ProtoReflect.Descriptor instead.

func (*DeletePipelineRequest) GetId 

func (x *DeletePipelineRequest) GetId() string

func (*DeletePipelineRequest) ProtoMessage 

func (*DeletePipelineRequest) ProtoMessage()

func (*DeletePipelineRequest) ProtoReflect 

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

func (*DeletePipelineRequest) Reset 

func (x *DeletePipelineRequest) Reset()

func (*DeletePipelineRequest) String 

func (x *DeletePipelineRequest) String() string

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 GroupResponse 

type GroupResponse struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Kind   string `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"`
	Name   string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Parent string `protobuf:"bytes,4,opt,name=parent,proto3" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupResponse) Descriptor deprecated 

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

Deprecated: Use GroupResponse.ProtoReflect.Descriptor instead.

func (*GroupResponse) GetId 

func (x *GroupResponse) GetId() string

func (*GroupResponse) GetKind 

func (x *GroupResponse) GetKind() string

func (*GroupResponse) GetName 

func (x *GroupResponse) GetName() string

func (*GroupResponse) GetParent 

func (x *GroupResponse) GetParent() string

func (*GroupResponse) ProtoMessage 

func (*GroupResponse) ProtoMessage()

func (*GroupResponse) ProtoReflect 

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

func (*GroupResponse) Reset 

func (x *GroupResponse) Reset()

func (*GroupResponse) String 

func (x *GroupResponse) String() string

type PipelineClient 

type PipelineClient interface {
	CreateGroup(ctx context.Context, in *CreateGroupRequest, opts ...grpc.CallOption) (*GroupResponse, error)
	DeleteGroup(ctx context.Context, in *DeleteGroupRequest, opts ...grpc.CallOption) (*Empty, error)
	CreatePipeline(ctx context.Context, in *CreatePipelineRequest, opts ...grpc.CallOption) (*PipelineResponse, error)
	DeletePipeline(ctx context.Context, in *DeletePipelineRequest, opts ...grpc.CallOption) (*Empty, error)
}

PipelineClient is the client API for Pipeline 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 NewPipelineClient 

func NewPipelineClient(cc grpc.ClientConnInterface) PipelineClient

type PipelineResponse 

type PipelineResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineResponse) Descriptor deprecated 

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

Deprecated: Use PipelineResponse.ProtoReflect.Descriptor instead.

func (*PipelineResponse) GetId 

func (x *PipelineResponse) GetId() string

func (*PipelineResponse) ProtoMessage 

func (*PipelineResponse) ProtoMessage()

func (*PipelineResponse) ProtoReflect 

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

func (*PipelineResponse) Reset 

func (x *PipelineResponse) Reset()

func (*PipelineResponse) String 

func (x *PipelineResponse) String() string

type PipelineServer 

type PipelineServer interface {
	CreateGroup(context.Context, *CreateGroupRequest) (*GroupResponse, error)
	DeleteGroup(context.Context, *DeleteGroupRequest) (*Empty, error)
	CreatePipeline(context.Context, *CreatePipelineRequest) (*PipelineResponse, error)
	DeletePipeline(context.Context, *DeletePipelineRequest) (*Empty, error)
	// contains filtered or unexported methods
}

PipelineServer is the server API for Pipeline service. All implementations must embed UnimplementedPipelineServer for forward compatibility

type UnimplementedPipelineServer 

type UnimplementedPipelineServer struct {
}

UnimplementedPipelineServer must be embedded to have forward compatible implementations.

func (UnimplementedPipelineServer) CreateGroup 

func (UnimplementedPipelineServer) CreateGroup(context.Context, *CreateGroupRequest) (*GroupResponse, error)

func (UnimplementedPipelineServer) CreatePipeline 

func (UnimplementedPipelineServer) CreatePipeline(context.Context, *CreatePipelineRequest) (*PipelineResponse, error)

func (UnimplementedPipelineServer) DeleteGroup 

func (UnimplementedPipelineServer) DeleteGroup(context.Context, *DeleteGroupRequest) (*Empty, error)

func (UnimplementedPipelineServer) DeletePipeline 

func (UnimplementedPipelineServer) DeletePipeline(context.Context, *DeletePipelineRequest) (*Empty, error)

type UnsafePipelineServer 

type UnsafePipelineServer interface {
	// contains filtered or unexported methods
}

UnsafePipelineServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PipelineServer will result in compilation errors.

Source Files

View all Source files

Directories

Path Synopsis

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.