workflowarchive

package
v0.0.0-...-d372783 Latest Latest
Warning

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

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

Documentation

Overview

Package workflowarchive is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthWorkflowArchive        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWorkflowArchive          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWorkflowArchive = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterArchivedWorkflowServiceHandler

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

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

func RegisterArchivedWorkflowServiceHandlerClient

func RegisterArchivedWorkflowServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ArchivedWorkflowServiceClient) error

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

func RegisterArchivedWorkflowServiceHandlerFromEndpoint

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

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

func RegisterArchivedWorkflowServiceHandlerServer

func RegisterArchivedWorkflowServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ArchivedWorkflowServiceServer) error

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

func RegisterArchivedWorkflowServiceServer

func RegisterArchivedWorkflowServiceServer(s *grpc.Server, srv ArchivedWorkflowServiceServer)

Types

type ArchivedWorkflowDeletedResponse

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

func (*ArchivedWorkflowDeletedResponse) Descriptor

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

func (*ArchivedWorkflowDeletedResponse) Marshal

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

func (*ArchivedWorkflowDeletedResponse) MarshalTo

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

func (*ArchivedWorkflowDeletedResponse) MarshalToSizedBuffer

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

func (*ArchivedWorkflowDeletedResponse) ProtoMessage

func (*ArchivedWorkflowDeletedResponse) ProtoMessage()

func (*ArchivedWorkflowDeletedResponse) Reset

func (*ArchivedWorkflowDeletedResponse) Size

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

func (*ArchivedWorkflowDeletedResponse) String

func (*ArchivedWorkflowDeletedResponse) Unmarshal

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

func (*ArchivedWorkflowDeletedResponse) XXX_DiscardUnknown

func (m *ArchivedWorkflowDeletedResponse) XXX_DiscardUnknown()

func (*ArchivedWorkflowDeletedResponse) XXX_Marshal

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

func (*ArchivedWorkflowDeletedResponse) XXX_Merge

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

func (*ArchivedWorkflowDeletedResponse) XXX_Size

func (m *ArchivedWorkflowDeletedResponse) XXX_Size() int

func (*ArchivedWorkflowDeletedResponse) XXX_Unmarshal

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

type ArchivedWorkflowServiceClient

type ArchivedWorkflowServiceClient interface {
	ListArchivedWorkflows(ctx context.Context, in *ListArchivedWorkflowsRequest, opts ...grpc.CallOption) (*v1alpha1.WorkflowList, error)
	GetArchivedWorkflow(ctx context.Context, in *GetArchivedWorkflowRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	DeleteArchivedWorkflow(ctx context.Context, in *DeleteArchivedWorkflowRequest, opts ...grpc.CallOption) (*ArchivedWorkflowDeletedResponse, error)
}

ArchivedWorkflowServiceClient is the client API for ArchivedWorkflowService service.

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

func NewArchivedWorkflowServiceClient

func NewArchivedWorkflowServiceClient(cc *grpc.ClientConn) ArchivedWorkflowServiceClient

type ArchivedWorkflowServiceServer

type ArchivedWorkflowServiceServer interface {
	ListArchivedWorkflows(context.Context, *ListArchivedWorkflowsRequest) (*v1alpha1.WorkflowList, error)
	GetArchivedWorkflow(context.Context, *GetArchivedWorkflowRequest) (*v1alpha1.Workflow, error)
	DeleteArchivedWorkflow(context.Context, *DeleteArchivedWorkflowRequest) (*ArchivedWorkflowDeletedResponse, error)
}

ArchivedWorkflowServiceServer is the server API for ArchivedWorkflowService service.

func NewWorkflowArchiveServer

func NewWorkflowArchiveServer(wfArchive sqldb.WorkflowArchive) ArchivedWorkflowServiceServer

type DeleteArchivedWorkflowRequest

type DeleteArchivedWorkflowRequest struct {
	Uid                  string   `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteArchivedWorkflowRequest) Descriptor

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

func (*DeleteArchivedWorkflowRequest) GetUid

func (*DeleteArchivedWorkflowRequest) Marshal

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

func (*DeleteArchivedWorkflowRequest) MarshalTo

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

func (*DeleteArchivedWorkflowRequest) MarshalToSizedBuffer

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

func (*DeleteArchivedWorkflowRequest) ProtoMessage

func (*DeleteArchivedWorkflowRequest) ProtoMessage()

func (*DeleteArchivedWorkflowRequest) Reset

func (m *DeleteArchivedWorkflowRequest) Reset()

func (*DeleteArchivedWorkflowRequest) Size

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

func (*DeleteArchivedWorkflowRequest) String

func (*DeleteArchivedWorkflowRequest) Unmarshal

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

func (*DeleteArchivedWorkflowRequest) XXX_DiscardUnknown

func (m *DeleteArchivedWorkflowRequest) XXX_DiscardUnknown()

func (*DeleteArchivedWorkflowRequest) XXX_Marshal

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

func (*DeleteArchivedWorkflowRequest) XXX_Merge

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

func (*DeleteArchivedWorkflowRequest) XXX_Size

func (m *DeleteArchivedWorkflowRequest) XXX_Size() int

func (*DeleteArchivedWorkflowRequest) XXX_Unmarshal

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

type GetArchivedWorkflowRequest

type GetArchivedWorkflowRequest struct {
	Uid                  string   `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetArchivedWorkflowRequest) Descriptor

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

func (*GetArchivedWorkflowRequest) GetUid

func (m *GetArchivedWorkflowRequest) GetUid() string

func (*GetArchivedWorkflowRequest) Marshal

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

func (*GetArchivedWorkflowRequest) MarshalTo

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

func (*GetArchivedWorkflowRequest) MarshalToSizedBuffer

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

func (*GetArchivedWorkflowRequest) ProtoMessage

func (*GetArchivedWorkflowRequest) ProtoMessage()

func (*GetArchivedWorkflowRequest) Reset

func (m *GetArchivedWorkflowRequest) Reset()

func (*GetArchivedWorkflowRequest) Size

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

func (*GetArchivedWorkflowRequest) String

func (m *GetArchivedWorkflowRequest) String() string

func (*GetArchivedWorkflowRequest) Unmarshal

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

func (*GetArchivedWorkflowRequest) XXX_DiscardUnknown

func (m *GetArchivedWorkflowRequest) XXX_DiscardUnknown()

func (*GetArchivedWorkflowRequest) XXX_Marshal

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

func (*GetArchivedWorkflowRequest) XXX_Merge

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

func (*GetArchivedWorkflowRequest) XXX_Size

func (m *GetArchivedWorkflowRequest) XXX_Size() int

func (*GetArchivedWorkflowRequest) XXX_Unmarshal

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

type ListArchivedWorkflowsRequest

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

func (*ListArchivedWorkflowsRequest) Descriptor

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

func (*ListArchivedWorkflowsRequest) GetListOptions

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

func (*ListArchivedWorkflowsRequest) Marshal

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

func (*ListArchivedWorkflowsRequest) MarshalTo

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

func (*ListArchivedWorkflowsRequest) MarshalToSizedBuffer

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

func (*ListArchivedWorkflowsRequest) ProtoMessage

func (*ListArchivedWorkflowsRequest) ProtoMessage()

func (*ListArchivedWorkflowsRequest) Reset

func (m *ListArchivedWorkflowsRequest) Reset()

func (*ListArchivedWorkflowsRequest) Size

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

func (*ListArchivedWorkflowsRequest) String

func (*ListArchivedWorkflowsRequest) Unmarshal

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

func (*ListArchivedWorkflowsRequest) XXX_DiscardUnknown

func (m *ListArchivedWorkflowsRequest) XXX_DiscardUnknown()

func (*ListArchivedWorkflowsRequest) XXX_Marshal

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

func (*ListArchivedWorkflowsRequest) XXX_Merge

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

func (*ListArchivedWorkflowsRequest) XXX_Size

func (m *ListArchivedWorkflowsRequest) XXX_Size() int

func (*ListArchivedWorkflowsRequest) XXX_Unmarshal

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

type UnimplementedArchivedWorkflowServiceServer

type UnimplementedArchivedWorkflowServiceServer struct {
}

UnimplementedArchivedWorkflowServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedArchivedWorkflowServiceServer) DeleteArchivedWorkflow

func (*UnimplementedArchivedWorkflowServiceServer) GetArchivedWorkflow

func (*UnimplementedArchivedWorkflowServiceServer) ListArchivedWorkflows

Jump to

Keyboard shortcuts

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