controlplane

package
v0.0.0-...-a93a756 Latest Latest
Warning

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

 Go to latest Published: Sep 15, 2020 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Package controlplane is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterControlPlaneHandler 

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

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

func RegisterControlPlaneHandlerClient 

func RegisterControlPlaneHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ControlPlaneClient) error

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

func RegisterControlPlaneHandlerFromEndpoint 

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

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

func RegisterControlPlaneHandlerServer 

func RegisterControlPlaneHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ControlPlaneServer) error

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

func RegisterControlPlaneServer 

func RegisterControlPlaneServer(s *grpc.Server, srv ControlPlaneServer)

Types

type ControlPlaneClient 

type ControlPlaneClient interface {
	Stats(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption) (*StatsResponse, error)
	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)
	ListRuns(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListRunsResponse, error)
	Inspect(ctx context.Context, in *InspectRequest, opts ...grpc.CallOption) (*InspectResponse, error)
	ListAgents(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListAgentsResponse, error)
}

ControlPlaneClient is the client API for ControlPlane service.

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

func NewControlPlaneClient 

func NewControlPlaneClient(cc *grpc.ClientConn) ControlPlaneClient

type ControlPlaneServer 

type ControlPlaneServer interface {
	Stats(context.Context, *StatsRequest) (*StatsResponse, error)
	Start(context.Context, *StartRequest) (*StartResponse, error)
	ListRuns(context.Context, *ListRequest) (*ListRunsResponse, error)
	Inspect(context.Context, *InspectRequest) (*InspectResponse, error)
	ListAgents(context.Context, *ListRequest) (*ListAgentsResponse, error)
}

ControlPlaneServer is the server API for ControlPlane service.

type InspectRequest 

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

func (*InspectRequest) Descriptor 

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

func (*InspectRequest) GetId 

func (m *InspectRequest) GetId() string

func (*InspectRequest) ProtoMessage 

func (*InspectRequest) ProtoMessage()

func (*InspectRequest) Reset 

func (m *InspectRequest) Reset()

func (*InspectRequest) String 

func (m *InspectRequest) String() string

func (*InspectRequest) XXX_DiscardUnknown 

func (m *InspectRequest) XXX_DiscardUnknown()

func (*InspectRequest) XXX_Marshal 

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

func (*InspectRequest) XXX_Merge 

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

func (*InspectRequest) XXX_Size 

func (m *InspectRequest) XXX_Size() int

func (*InspectRequest) XXX_Unmarshal 

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

type InspectResponse 

type InspectResponse struct {
	Run                  *adagio.Run `protobuf:"bytes,1,opt,name=run,proto3" json:"run,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*InspectResponse) Descriptor 

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

func (*InspectResponse) GetRun 

func (m *InspectResponse) GetRun() *adagio.Run

func (*InspectResponse) ProtoMessage 

func (*InspectResponse) ProtoMessage()

func (*InspectResponse) Reset 

func (m *InspectResponse) Reset()

func (*InspectResponse) String 

func (m *InspectResponse) String() string

func (*InspectResponse) XXX_DiscardUnknown 

func (m *InspectResponse) XXX_DiscardUnknown()

func (*InspectResponse) XXX_Marshal 

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

func (*InspectResponse) XXX_Merge 

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

func (*InspectResponse) XXX_Size 

func (m *InspectResponse) XXX_Size() int

func (*InspectResponse) XXX_Unmarshal 

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

type ListAgentsResponse 

type ListAgentsResponse struct {
	Agents               []*adagio.Agent `protobuf:"bytes,1,rep,name=agents,proto3" json:"agents,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ListAgentsResponse) Descriptor 

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

func (*ListAgentsResponse) GetAgents 

func (m *ListAgentsResponse) GetAgents() []*adagio.Agent

func (*ListAgentsResponse) ProtoMessage 

func (*ListAgentsResponse) ProtoMessage()

func (*ListAgentsResponse) Reset 

func (m *ListAgentsResponse) Reset()

func (*ListAgentsResponse) String 

func (m *ListAgentsResponse) String() string

func (*ListAgentsResponse) XXX_DiscardUnknown 

func (m *ListAgentsResponse) XXX_DiscardUnknown()

func (*ListAgentsResponse) XXX_Marshal 

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

func (*ListAgentsResponse) XXX_Merge 

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

func (*ListAgentsResponse) XXX_Size 

func (m *ListAgentsResponse) XXX_Size() int

func (*ListAgentsResponse) XXX_Unmarshal 

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

type ListRequest 

type ListRequest struct {
	StartNs              int64    `protobuf:"varint,1,opt,name=start_ns,json=startNs,proto3" json:"start_ns,omitempty"`
	FinishNs             int64    `protobuf:"varint,2,opt,name=finish_ns,json=finishNs,proto3" json:"finish_ns,omitempty"`
	Limit                uint64   `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListRequest) Descriptor 

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

func (*ListRequest) GetFinishNs 

func (m *ListRequest) GetFinishNs() int64

func (*ListRequest) GetLimit 

func (m *ListRequest) GetLimit() uint64

func (*ListRequest) GetStartNs 

func (m *ListRequest) GetStartNs() int64

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) Reset 

func (m *ListRequest) Reset()

func (*ListRequest) String 

func (m *ListRequest) String() string

func (*ListRequest) XXX_DiscardUnknown 

func (m *ListRequest) XXX_DiscardUnknown()

func (*ListRequest) XXX_Marshal 

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

func (*ListRequest) XXX_Merge 

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

func (*ListRequest) XXX_Size 

func (m *ListRequest) XXX_Size() int

func (*ListRequest) XXX_Unmarshal 

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

type ListRunsResponse 

type ListRunsResponse struct {
	Runs                 []*adagio.Run `protobuf:"bytes,1,rep,name=runs,proto3" json:"runs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ListRunsResponse) Descriptor 

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

func (*ListRunsResponse) GetRuns 

func (m *ListRunsResponse) GetRuns() []*adagio.Run

func (*ListRunsResponse) ProtoMessage 

func (*ListRunsResponse) ProtoMessage()

func (*ListRunsResponse) Reset 

func (m *ListRunsResponse) Reset()

func (*ListRunsResponse) String 

func (m *ListRunsResponse) String() string

func (*ListRunsResponse) XXX_DiscardUnknown 

func (m *ListRunsResponse) XXX_DiscardUnknown()

func (*ListRunsResponse) XXX_Marshal 

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

func (*ListRunsResponse) XXX_Merge 

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

func (*ListRunsResponse) XXX_Size 

func (m *ListRunsResponse) XXX_Size() int

func (*ListRunsResponse) XXX_Unmarshal 

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

type StartRequest 

type StartRequest struct {
	Spec                 *adagio.GraphSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*StartRequest) Descriptor 

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

func (*StartRequest) GetSpec 

func (m *StartRequest) GetSpec() *adagio.GraphSpec

func (*StartRequest) ProtoMessage 

func (*StartRequest) ProtoMessage()

func (*StartRequest) Reset 

func (m *StartRequest) Reset()

func (*StartRequest) String 

func (m *StartRequest) String() string

func (*StartRequest) XXX_DiscardUnknown 

func (m *StartRequest) XXX_DiscardUnknown()

func (*StartRequest) XXX_Marshal 

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

func (*StartRequest) XXX_Merge 

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

func (*StartRequest) XXX_Size 

func (m *StartRequest) XXX_Size() int

func (*StartRequest) XXX_Unmarshal 

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

type StartResponse 

type StartResponse struct {
	Run                  *adagio.Run `protobuf:"bytes,1,opt,name=run,proto3" json:"run,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*StartResponse) Descriptor 

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

func (*StartResponse) GetRun 

func (m *StartResponse) GetRun() *adagio.Run

func (*StartResponse) ProtoMessage 

func (*StartResponse) ProtoMessage()

func (*StartResponse) Reset 

func (m *StartResponse) Reset()

func (*StartResponse) String 

func (m *StartResponse) String() string

func (*StartResponse) XXX_DiscardUnknown 

func (m *StartResponse) XXX_DiscardUnknown()

func (*StartResponse) XXX_Marshal 

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

func (*StartResponse) XXX_Merge 

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

func (*StartResponse) XXX_Size 

func (m *StartResponse) XXX_Size() int

func (*StartResponse) XXX_Unmarshal 

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

type StatsRequest 

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

func (*StatsRequest) Descriptor 

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

func (*StatsRequest) ProtoMessage 

func (*StatsRequest) ProtoMessage()

func (*StatsRequest) Reset 

func (m *StatsRequest) Reset()

func (*StatsRequest) String 

func (m *StatsRequest) String() string

func (*StatsRequest) XXX_DiscardUnknown 

func (m *StatsRequest) XXX_DiscardUnknown()

func (*StatsRequest) XXX_Marshal 

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

func (*StatsRequest) XXX_Merge 

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

func (*StatsRequest) XXX_Size 

func (m *StatsRequest) XXX_Size() int

func (*StatsRequest) XXX_Unmarshal 

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

type StatsResponse 

type StatsResponse struct {
	Stats                *adagio.Stats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*StatsResponse) Descriptor 

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

func (*StatsResponse) GetStats 

func (m *StatsResponse) GetStats() *adagio.Stats

func (*StatsResponse) ProtoMessage 

func (*StatsResponse) ProtoMessage()

func (*StatsResponse) Reset 

func (m *StatsResponse) Reset()

func (*StatsResponse) String 

func (m *StatsResponse) String() string

func (*StatsResponse) XXX_DiscardUnknown 

func (m *StatsResponse) XXX_DiscardUnknown()

func (*StatsResponse) XXX_Marshal 

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

func (*StatsResponse) XXX_Merge 

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

func (*StatsResponse) XXX_Size 

func (m *StatsResponse) XXX_Size() int

func (*StatsResponse) XXX_Unmarshal 

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

type UnimplementedControlPlaneServer 

type UnimplementedControlPlaneServer struct {
}

UnimplementedControlPlaneServer can be embedded to have forward compatible implementations.

func (*UnimplementedControlPlaneServer) Inspect 

func (*UnimplementedControlPlaneServer) Inspect(ctx context.Context, req *InspectRequest) (*InspectResponse, error)

func (*UnimplementedControlPlaneServer) ListAgents 

func (*UnimplementedControlPlaneServer) ListAgents(ctx context.Context, req *ListRequest) (*ListAgentsResponse, error)

func (*UnimplementedControlPlaneServer) ListRuns 

func (*UnimplementedControlPlaneServer) ListRuns(ctx context.Context, req *ListRequest) (*ListRunsResponse, error)

func (*UnimplementedControlPlaneServer) Start 

func (*UnimplementedControlPlaneServer) Start(ctx context.Context, req *StartRequest) (*StartResponse, error)

func (*UnimplementedControlPlaneServer) Stats 

func (*UnimplementedControlPlaneServer) Stats(ctx context.Context, req *StatsRequest) (*StatsResponse, 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.