cronworkflow

package
v2.5.0-rc2+incompatible Latest Latest
Warning

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

Go to latest
Published: Jan 24, 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

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) DeleteCronWorkflow

func (*UnimplementedCronWorkflowServiceServer) GetCronWorkflow

func (*UnimplementedCronWorkflowServiceServer) ListCronWorkflows

func (*UnimplementedCronWorkflowServiceServer) UpdateCronWorkflow

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

Jump to

Keyboard shortcuts

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