cronworkflow

package
v2.5.0-rc1+incompatible Latest Latest
Warning

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

 Go to latest Published: Jan 23, 2020 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Overview

Package cronworkflow is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCronWorkflow        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCronWorkflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCronWorkflow = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterCronWorkflowServiceHandler 

func RegisterCronWorkflowServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterCronWorkflowServiceHandler registers the http handlers for service CronWorkflowService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterCronWorkflowServiceHandlerClient 

func RegisterCronWorkflowServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client CronWorkflowServiceClient) error

RegisterCronWorkflowServiceHandlerClient registers the http handlers for service CronWorkflowService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "CronWorkflowServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "CronWorkflowServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "CronWorkflowServiceClient" to call the correct interceptors.

func RegisterCronWorkflowServiceHandlerFromEndpoint 

func RegisterCronWorkflowServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterCronWorkflowServiceHandlerFromEndpoint is same as RegisterCronWorkflowServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterCronWorkflowServiceHandlerServer 

func RegisterCronWorkflowServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server CronWorkflowServiceServer) error

RegisterCronWorkflowServiceHandlerServer registers the http handlers for service CronWorkflowService to "mux". UnaryRPC :call CronWorkflowServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterCronWorkflowServiceServer 

func RegisterCronWorkflowServiceServer(s *grpc.Server, srv CronWorkflowServiceServer)

Types

type CreateCronWorkflowRequest 

type CreateCronWorkflowRequest struct {
	Namespace            string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	CronWorkflow         *v1alpha1.CronWorkflow `protobuf:"bytes,2,opt,name=cronWorkflow,proto3" json:"cronWorkflow,omitempty"`
	CreateOptions        *v1.CreateOptions      `protobuf:"bytes,3,opt,name=createOptions,proto3" json:"createOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*CreateCronWorkflowRequest) Descriptor 

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

func (*CreateCronWorkflowRequest) GetCreateOptions 

func (m *CreateCronWorkflowRequest) GetCreateOptions() *v1.CreateOptions

func (*CreateCronWorkflowRequest) GetCronWorkflow 

func (m *CreateCronWorkflowRequest) GetCronWorkflow() *v1alpha1.CronWorkflow

func (*CreateCronWorkflowRequest) GetNamespace 

func (m *CreateCronWorkflowRequest) GetNamespace() string

func (*CreateCronWorkflowRequest) Marshal 

func (m *CreateCronWorkflowRequest) Marshal() (dAtA []byte, err error)

func (*CreateCronWorkflowRequest) MarshalTo 

func (m *CreateCronWorkflowRequest) MarshalTo(dAtA []byte) (int, error)

func (*CreateCronWorkflowRequest) MarshalToSizedBuffer 

func (m *CreateCronWorkflowRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateCronWorkflowRequest) ProtoMessage 

func (*CreateCronWorkflowRequest) ProtoMessage()

func (*CreateCronWorkflowRequest) Reset 

func (m *CreateCronWorkflowRequest) Reset()

func (*CreateCronWorkflowRequest) Size 

func (m *CreateCronWorkflowRequest) Size() (n int)

func (*CreateCronWorkflowRequest) String 

func (m *CreateCronWorkflowRequest) String() string

func (*CreateCronWorkflowRequest) Unmarshal 

func (m *CreateCronWorkflowRequest) Unmarshal(dAtA []byte) error

func (*CreateCronWorkflowRequest) XXX_DiscardUnknown 

func (m *CreateCronWorkflowRequest) XXX_DiscardUnknown()

func (*CreateCronWorkflowRequest) XXX_Marshal 

func (m *CreateCronWorkflowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateCronWorkflowRequest) XXX_Merge 

func (m *CreateCronWorkflowRequest) XXX_Merge(src proto.Message)

func (*CreateCronWorkflowRequest) XXX_Size 

func (m *CreateCronWorkflowRequest) XXX_Size() int

func (*CreateCronWorkflowRequest) XXX_Unmarshal 

func (m *CreateCronWorkflowRequest) XXX_Unmarshal(b []byte) error

type CronWorkflowDeletedResponse 

type CronWorkflowDeletedResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CronWorkflowDeletedResponse) Descriptor 

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

func (*CronWorkflowDeletedResponse) Marshal 

func (m *CronWorkflowDeletedResponse) Marshal() (dAtA []byte, err error)

func (*CronWorkflowDeletedResponse) MarshalTo 

func (m *CronWorkflowDeletedResponse) MarshalTo(dAtA []byte) (int, error)

func (*CronWorkflowDeletedResponse) MarshalToSizedBuffer 

func (m *CronWorkflowDeletedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CronWorkflowDeletedResponse) ProtoMessage 

func (*CronWorkflowDeletedResponse) ProtoMessage()

func (*CronWorkflowDeletedResponse) Reset 

func (m *CronWorkflowDeletedResponse) Reset()

func (*CronWorkflowDeletedResponse) Size 

func (m *CronWorkflowDeletedResponse) Size() (n int)

func (*CronWorkflowDeletedResponse) String 

func (m *CronWorkflowDeletedResponse) String() string

func (*CronWorkflowDeletedResponse) Unmarshal 

func (m *CronWorkflowDeletedResponse) Unmarshal(dAtA []byte) error

func (*CronWorkflowDeletedResponse) XXX_DiscardUnknown 

func (m *CronWorkflowDeletedResponse) XXX_DiscardUnknown()

func (*CronWorkflowDeletedResponse) XXX_Marshal 

func (m *CronWorkflowDeletedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CronWorkflowDeletedResponse) XXX_Merge 

func (m *CronWorkflowDeletedResponse) XXX_Merge(src proto.Message)

func (*CronWorkflowDeletedResponse) XXX_Size 

func (m *CronWorkflowDeletedResponse) XXX_Size() int

func (*CronWorkflowDeletedResponse) XXX_Unmarshal 

func (m *CronWorkflowDeletedResponse) XXX_Unmarshal(b []byte) error

type CronWorkflowServiceClient 

type CronWorkflowServiceClient interface {
	CreateCronWorkflow(ctx context.Context, in *CreateCronWorkflowRequest, opts ...grpc.CallOption) (*v1alpha1.CronWorkflow, error)
	ListCronWorkflows(ctx context.Context, in *ListCronWorkflowsRequest, opts ...grpc.CallOption) (*v1alpha1.CronWorkflowList, error)
	GetCronWorkflow(ctx context.Context, in *GetCronWorkflowRequest, opts ...grpc.CallOption) (*v1alpha1.CronWorkflow, error)
	UpdateCronWorkflow(ctx context.Context, in *UpdateCronWorkflowRequest, opts ...grpc.CallOption) (*v1alpha1.CronWorkflow, error)
	DeleteCronWorkflow(ctx context.Context, in *DeleteCronWorkflowRequest, opts ...grpc.CallOption) (*CronWorkflowDeletedResponse, error)
}

CronWorkflowServiceClient is the client API for CronWorkflowService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCronWorkflowServiceClient 

func NewCronWorkflowServiceClient(cc *grpc.ClientConn) CronWorkflowServiceClient

type CronWorkflowServiceServer 

type CronWorkflowServiceServer interface {
	CreateCronWorkflow(context.Context, *CreateCronWorkflowRequest) (*v1alpha1.CronWorkflow, error)
	ListCronWorkflows(context.Context, *ListCronWorkflowsRequest) (*v1alpha1.CronWorkflowList, error)
	GetCronWorkflow(context.Context, *GetCronWorkflowRequest) (*v1alpha1.CronWorkflow, error)
	UpdateCronWorkflow(context.Context, *UpdateCronWorkflowRequest) (*v1alpha1.CronWorkflow, error)
	DeleteCronWorkflow(context.Context, *DeleteCronWorkflowRequest) (*CronWorkflowDeletedResponse, error)
}

CronWorkflowServiceServer is the server API for CronWorkflowService service.

func NewCronWorkflowServer 

func NewCronWorkflowServer() CronWorkflowServiceServer

type DeleteCronWorkflowRequest 

type DeleteCronWorkflowRequest struct {
	CronWorkflowName     string            `protobuf:"bytes,1,opt,name=cronWorkflowName,proto3" json:"cronWorkflowName,omitempty"`
	Namespace            string            `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	DeleteOptions        *v1.DeleteOptions `protobuf:"bytes,3,opt,name=deleteOptions,proto3" json:"deleteOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DeleteCronWorkflowRequest) Descriptor 

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

func (*DeleteCronWorkflowRequest) GetCronWorkflowName 

func (m *DeleteCronWorkflowRequest) GetCronWorkflowName() string

func (*DeleteCronWorkflowRequest) GetDeleteOptions 

func (m *DeleteCronWorkflowRequest) GetDeleteOptions() *v1.DeleteOptions

func (*DeleteCronWorkflowRequest) GetNamespace 

func (m *DeleteCronWorkflowRequest) GetNamespace() string

func (*DeleteCronWorkflowRequest) Marshal 

func (m *DeleteCronWorkflowRequest) Marshal() (dAtA []byte, err error)

func (*DeleteCronWorkflowRequest) MarshalTo 

func (m *DeleteCronWorkflowRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeleteCronWorkflowRequest) MarshalToSizedBuffer 

func (m *DeleteCronWorkflowRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteCronWorkflowRequest) ProtoMessage 

func (*DeleteCronWorkflowRequest) ProtoMessage()

func (*DeleteCronWorkflowRequest) Reset 

func (m *DeleteCronWorkflowRequest) Reset()

func (*DeleteCronWorkflowRequest) Size 

func (m *DeleteCronWorkflowRequest) Size() (n int)

func (*DeleteCronWorkflowRequest) String 

func (m *DeleteCronWorkflowRequest) String() string

func (*DeleteCronWorkflowRequest) Unmarshal 

func (m *DeleteCronWorkflowRequest) Unmarshal(dAtA []byte) error

func (*DeleteCronWorkflowRequest) XXX_DiscardUnknown 

func (m *DeleteCronWorkflowRequest) XXX_DiscardUnknown()

func (*DeleteCronWorkflowRequest) XXX_Marshal 

func (m *DeleteCronWorkflowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteCronWorkflowRequest) XXX_Merge 

func (m *DeleteCronWorkflowRequest) XXX_Merge(src proto.Message)

func (*DeleteCronWorkflowRequest) XXX_Size 

func (m *DeleteCronWorkflowRequest) XXX_Size() int

func (*DeleteCronWorkflowRequest) XXX_Unmarshal 

func (m *DeleteCronWorkflowRequest) XXX_Unmarshal(b []byte) error

type GetCronWorkflowRequest 

type GetCronWorkflowRequest struct {
	CronWorkflowName     string         `protobuf:"bytes,1,opt,name=cronWorkflowName,proto3" json:"cronWorkflowName,omitempty"`
	Namespace            string         `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	GetOptions           *v1.GetOptions `protobuf:"bytes,3,opt,name=getOptions,proto3" json:"getOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetCronWorkflowRequest) Descriptor 

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

func (*GetCronWorkflowRequest) GetCronWorkflowName 

func (m *GetCronWorkflowRequest) GetCronWorkflowName() string

func (*GetCronWorkflowRequest) GetGetOptions 

func (m *GetCronWorkflowRequest) GetGetOptions() *v1.GetOptions

func (*GetCronWorkflowRequest) GetNamespace 

func (m *GetCronWorkflowRequest) GetNamespace() string

func (*GetCronWorkflowRequest) Marshal 

func (m *GetCronWorkflowRequest) Marshal() (dAtA []byte, err error)

func (*GetCronWorkflowRequest) MarshalTo 

func (m *GetCronWorkflowRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetCronWorkflowRequest) MarshalToSizedBuffer 

func (m *GetCronWorkflowRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetCronWorkflowRequest) ProtoMessage 

func (*GetCronWorkflowRequest) ProtoMessage()

func (*GetCronWorkflowRequest) Reset 

func (m *GetCronWorkflowRequest) Reset()

func (*GetCronWorkflowRequest) Size 

func (m *GetCronWorkflowRequest) Size() (n int)

func (*GetCronWorkflowRequest) String 

func (m *GetCronWorkflowRequest) String() string

func (*GetCronWorkflowRequest) Unmarshal 

func (m *GetCronWorkflowRequest) Unmarshal(dAtA []byte) error

func (*GetCronWorkflowRequest) XXX_DiscardUnknown 

func (m *GetCronWorkflowRequest) XXX_DiscardUnknown()

func (*GetCronWorkflowRequest) XXX_Marshal 

func (m *GetCronWorkflowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCronWorkflowRequest) XXX_Merge 

func (m *GetCronWorkflowRequest) XXX_Merge(src proto.Message)

func (*GetCronWorkflowRequest) XXX_Size 

func (m *GetCronWorkflowRequest) XXX_Size() int

func (*GetCronWorkflowRequest) XXX_Unmarshal 

func (m *GetCronWorkflowRequest) XXX_Unmarshal(b []byte) error

type ListCronWorkflowsRequest 

type ListCronWorkflowsRequest struct {
	Namespace            string          `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ListOptions          *v1.ListOptions `protobuf:"bytes,2,opt,name=listOptions,proto3" json:"listOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ListCronWorkflowsRequest) Descriptor 

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

func (*ListCronWorkflowsRequest) GetListOptions 

func (m *ListCronWorkflowsRequest) GetListOptions() *v1.ListOptions

func (*ListCronWorkflowsRequest) GetNamespace 

func (m *ListCronWorkflowsRequest) GetNamespace() string

func (*ListCronWorkflowsRequest) Marshal 

func (m *ListCronWorkflowsRequest) Marshal() (dAtA []byte, err error)

func (*ListCronWorkflowsRequest) MarshalTo 

func (m *ListCronWorkflowsRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListCronWorkflowsRequest) MarshalToSizedBuffer 

func (m *ListCronWorkflowsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListCronWorkflowsRequest) ProtoMessage 

func (*ListCronWorkflowsRequest) ProtoMessage()

func (*ListCronWorkflowsRequest) Reset 

func (m *ListCronWorkflowsRequest) Reset()

func (*ListCronWorkflowsRequest) Size 

func (m *ListCronWorkflowsRequest) Size() (n int)

func (*ListCronWorkflowsRequest) String 

func (m *ListCronWorkflowsRequest) String() string

func (*ListCronWorkflowsRequest) Unmarshal 

func (m *ListCronWorkflowsRequest) Unmarshal(dAtA []byte) error

func (*ListCronWorkflowsRequest) XXX_DiscardUnknown 

func (m *ListCronWorkflowsRequest) XXX_DiscardUnknown()

func (*ListCronWorkflowsRequest) XXX_Marshal 

func (m *ListCronWorkflowsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListCronWorkflowsRequest) XXX_Merge 

func (m *ListCronWorkflowsRequest) XXX_Merge(src proto.Message)

func (*ListCronWorkflowsRequest) XXX_Size 

func (m *ListCronWorkflowsRequest) XXX_Size() int

func (*ListCronWorkflowsRequest) XXX_Unmarshal 

func (m *ListCronWorkflowsRequest) XXX_Unmarshal(b []byte) error

type UnimplementedCronWorkflowServiceServer 

type UnimplementedCronWorkflowServiceServer struct {
}

UnimplementedCronWorkflowServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedCronWorkflowServiceServer) CreateCronWorkflow 

func (*UnimplementedCronWorkflowServiceServer) CreateCronWorkflow(ctx context.Context, req *CreateCronWorkflowRequest) (*v1alpha1.CronWorkflow, error)

func (*UnimplementedCronWorkflowServiceServer) DeleteCronWorkflow 

func (*UnimplementedCronWorkflowServiceServer) DeleteCronWorkflow(ctx context.Context, req *DeleteCronWorkflowRequest) (*CronWorkflowDeletedResponse, error)

func (*UnimplementedCronWorkflowServiceServer) GetCronWorkflow 

func (*UnimplementedCronWorkflowServiceServer) GetCronWorkflow(ctx context.Context, req *GetCronWorkflowRequest) (*v1alpha1.CronWorkflow, error)

func (*UnimplementedCronWorkflowServiceServer) ListCronWorkflows 

func (*UnimplementedCronWorkflowServiceServer) ListCronWorkflows(ctx context.Context, req *ListCronWorkflowsRequest) (*v1alpha1.CronWorkflowList, error)

func (*UnimplementedCronWorkflowServiceServer) UpdateCronWorkflow 

func (*UnimplementedCronWorkflowServiceServer) UpdateCronWorkflow(ctx context.Context, req *UpdateCronWorkflowRequest) (*v1alpha1.CronWorkflow, error)

type UpdateCronWorkflowRequest 

type UpdateCronWorkflowRequest struct {
	CronWorkflowName     string                 `protobuf:"bytes,1,opt,name=cronWorkflowName,proto3" json:"cronWorkflowName,omitempty"`
	Namespace            string                 `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	CronWorkflow         *v1alpha1.CronWorkflow `protobuf:"bytes,3,opt,name=cronWorkflow,proto3" json:"cronWorkflow,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*UpdateCronWorkflowRequest) Descriptor 

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

func (*UpdateCronWorkflowRequest) GetCronWorkflow 

func (m *UpdateCronWorkflowRequest) GetCronWorkflow() *v1alpha1.CronWorkflow

func (*UpdateCronWorkflowRequest) GetCronWorkflowName 

func (m *UpdateCronWorkflowRequest) GetCronWorkflowName() string

func (*UpdateCronWorkflowRequest) GetNamespace 

func (m *UpdateCronWorkflowRequest) GetNamespace() string

func (*UpdateCronWorkflowRequest) Marshal 

func (m *UpdateCronWorkflowRequest) Marshal() (dAtA []byte, err error)

func (*UpdateCronWorkflowRequest) MarshalTo 

func (m *UpdateCronWorkflowRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateCronWorkflowRequest) MarshalToSizedBuffer 

func (m *UpdateCronWorkflowRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateCronWorkflowRequest) ProtoMessage 

func (*UpdateCronWorkflowRequest) ProtoMessage()

func (*UpdateCronWorkflowRequest) Reset 

func (m *UpdateCronWorkflowRequest) Reset()

func (*UpdateCronWorkflowRequest) Size 

func (m *UpdateCronWorkflowRequest) Size() (n int)

func (*UpdateCronWorkflowRequest) String 

func (m *UpdateCronWorkflowRequest) String() string

func (*UpdateCronWorkflowRequest) Unmarshal 

func (m *UpdateCronWorkflowRequest) Unmarshal(dAtA []byte) error

func (*UpdateCronWorkflowRequest) XXX_DiscardUnknown 

func (m *UpdateCronWorkflowRequest) XXX_DiscardUnknown()

func (*UpdateCronWorkflowRequest) XXX_Marshal 

func (m *UpdateCronWorkflowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateCronWorkflowRequest) XXX_Merge 

func (m *UpdateCronWorkflowRequest) XXX_Merge(src proto.Message)

func (*UpdateCronWorkflowRequest) XXX_Size 

func (m *UpdateCronWorkflowRequest) XXX_Size() int

func (*UpdateCronWorkflowRequest) XXX_Unmarshal 

func (m *UpdateCronWorkflowRequest) XXX_Unmarshal(b []byte) 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.