api

package
v0.0.0-...-a615612 Latest Latest
Warning

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

 Go to latest Published: Nov 12, 2019 License: MIT Imports: 14 Imported by: 0

Documentation

Overview

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterManagerServiceHandler 

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

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

func RegisterManagerServiceHandlerClient 

func RegisterManagerServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ManagerServiceClient) error

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

func RegisterManagerServiceHandlerFromEndpoint 

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

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

func RegisterManagerServiceHandlerServer 

func RegisterManagerServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ManagerServiceServer) error

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

func RegisterManagerServiceServer 

func RegisterManagerServiceServer(s *grpc.Server, srv ManagerServiceServer)

Types

type AddNodeRequest 

type AddNodeRequest struct {
	Node                 *NodeSpec `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*AddNodeRequest) Descriptor 

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

func (*AddNodeRequest) GetNode 

func (m *AddNodeRequest) GetNode() *NodeSpec

func (*AddNodeRequest) ProtoMessage 

func (*AddNodeRequest) ProtoMessage()

func (*AddNodeRequest) Reset 

func (m *AddNodeRequest) Reset()

func (*AddNodeRequest) String 

func (m *AddNodeRequest) String() string

func (*AddNodeRequest) XXX_DiscardUnknown 

func (m *AddNodeRequest) XXX_DiscardUnknown()

func (*AddNodeRequest) XXX_Marshal 

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

func (*AddNodeRequest) XXX_Merge 

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

func (*AddNodeRequest) XXX_Size 

func (m *AddNodeRequest) XXX_Size() int

func (*AddNodeRequest) XXX_Unmarshal 

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

type AddNodeResponse 

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

func (*AddNodeResponse) Descriptor 

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

func (*AddNodeResponse) ProtoMessage 

func (*AddNodeResponse) ProtoMessage()

func (*AddNodeResponse) Reset 

func (m *AddNodeResponse) Reset()

func (*AddNodeResponse) String 

func (m *AddNodeResponse) String() string

func (*AddNodeResponse) XXX_DiscardUnknown 

func (m *AddNodeResponse) XXX_DiscardUnknown()

func (*AddNodeResponse) XXX_Marshal 

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

func (*AddNodeResponse) XXX_Merge 

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

func (*AddNodeResponse) XXX_Size 

func (m *AddNodeResponse) XXX_Size() int

func (*AddNodeResponse) XXX_Unmarshal 

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

type AddNodesRequest 

type AddNodesRequest struct {
	Nodes                []*NodeSpec `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*AddNodesRequest) Descriptor 

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

func (*AddNodesRequest) GetNodes 

func (m *AddNodesRequest) GetNodes() []*NodeSpec

func (*AddNodesRequest) ProtoMessage 

func (*AddNodesRequest) ProtoMessage()

func (*AddNodesRequest) Reset 

func (m *AddNodesRequest) Reset()

func (*AddNodesRequest) String 

func (m *AddNodesRequest) String() string

func (*AddNodesRequest) XXX_DiscardUnknown 

func (m *AddNodesRequest) XXX_DiscardUnknown()

func (*AddNodesRequest) XXX_Marshal 

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

func (*AddNodesRequest) XXX_Merge 

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

func (*AddNodesRequest) XXX_Size 

func (m *AddNodesRequest) XXX_Size() int

func (*AddNodesRequest) XXX_Unmarshal 

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

type AddNodesResponse 

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

func (*AddNodesResponse) Descriptor 

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

func (*AddNodesResponse) ProtoMessage 

func (*AddNodesResponse) ProtoMessage()

func (*AddNodesResponse) Reset 

func (m *AddNodesResponse) Reset()

func (*AddNodesResponse) String 

func (m *AddNodesResponse) String() string

func (*AddNodesResponse) XXX_DiscardUnknown 

func (m *AddNodesResponse) XXX_DiscardUnknown()

func (*AddNodesResponse) XXX_Marshal 

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

func (*AddNodesResponse) XXX_Merge 

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

func (*AddNodesResponse) XXX_Size 

func (m *AddNodesResponse) XXX_Size() int

func (*AddNodesResponse) XXX_Unmarshal 

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

type DeleteNodeRequest 

type DeleteNodeRequest 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 (*DeleteNodeRequest) Descriptor 

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

func (*DeleteNodeRequest) GetId 

func (m *DeleteNodeRequest) GetId() string

func (*DeleteNodeRequest) ProtoMessage 

func (*DeleteNodeRequest) ProtoMessage()

func (*DeleteNodeRequest) Reset 

func (m *DeleteNodeRequest) Reset()

func (*DeleteNodeRequest) String 

func (m *DeleteNodeRequest) String() string

func (*DeleteNodeRequest) XXX_DiscardUnknown 

func (m *DeleteNodeRequest) XXX_DiscardUnknown()

func (*DeleteNodeRequest) XXX_Marshal 

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

func (*DeleteNodeRequest) XXX_Merge 

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

func (*DeleteNodeRequest) XXX_Size 

func (m *DeleteNodeRequest) XXX_Size() int

func (*DeleteNodeRequest) XXX_Unmarshal 

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

type DeleteNodeResponse 

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

func (*DeleteNodeResponse) Descriptor 

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

func (*DeleteNodeResponse) ProtoMessage 

func (*DeleteNodeResponse) ProtoMessage()

func (*DeleteNodeResponse) Reset 

func (m *DeleteNodeResponse) Reset()

func (*DeleteNodeResponse) String 

func (m *DeleteNodeResponse) String() string

func (*DeleteNodeResponse) XXX_DiscardUnknown 

func (m *DeleteNodeResponse) XXX_DiscardUnknown()

func (*DeleteNodeResponse) XXX_Marshal 

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

func (*DeleteNodeResponse) XXX_Merge 

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

func (*DeleteNodeResponse) XXX_Size 

func (m *DeleteNodeResponse) XXX_Size() int

func (*DeleteNodeResponse) XXX_Unmarshal 

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

type KeySpec 

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

func (*KeySpec) Descriptor 

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

func (*KeySpec) GetKey 

func (m *KeySpec) GetKey() string

func (*KeySpec) ProtoMessage 

func (*KeySpec) ProtoMessage()

func (*KeySpec) Reset 

func (m *KeySpec) Reset()

func (*KeySpec) String 

func (m *KeySpec) String() string

func (*KeySpec) XXX_DiscardUnknown 

func (m *KeySpec) XXX_DiscardUnknown()

func (*KeySpec) XXX_Marshal 

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

func (*KeySpec) XXX_Merge 

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

func (*KeySpec) XXX_Size 

func (m *KeySpec) XXX_Size() int

func (*KeySpec) XXX_Unmarshal 

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

type ListNodesRequest 

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

func (*ListNodesRequest) Descriptor 

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

func (*ListNodesRequest) ProtoMessage 

func (*ListNodesRequest) ProtoMessage()

func (*ListNodesRequest) Reset 

func (m *ListNodesRequest) Reset()

func (*ListNodesRequest) String 

func (m *ListNodesRequest) String() string

func (*ListNodesRequest) XXX_DiscardUnknown 

func (m *ListNodesRequest) XXX_DiscardUnknown()

func (*ListNodesRequest) XXX_Marshal 

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

func (*ListNodesRequest) XXX_Merge 

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

func (*ListNodesRequest) XXX_Size 

func (m *ListNodesRequest) XXX_Size() int

func (*ListNodesRequest) XXX_Unmarshal 

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

type ListNodesResponse 

type ListNodesResponse struct {
	Nodes                []*NodeSpec `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ListNodesResponse) Descriptor 

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

func (*ListNodesResponse) GetNodes 

func (m *ListNodesResponse) GetNodes() []*NodeSpec

func (*ListNodesResponse) ProtoMessage 

func (*ListNodesResponse) ProtoMessage()

func (*ListNodesResponse) Reset 

func (m *ListNodesResponse) Reset()

func (*ListNodesResponse) String 

func (m *ListNodesResponse) String() string

func (*ListNodesResponse) XXX_DiscardUnknown 

func (m *ListNodesResponse) XXX_DiscardUnknown()

func (*ListNodesResponse) XXX_Marshal 

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

func (*ListNodesResponse) XXX_Merge 

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

func (*ListNodesResponse) XXX_Size 

func (m *ListNodesResponse) XXX_Size() int

func (*ListNodesResponse) XXX_Unmarshal 

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

type ManagerServiceClient 

type ManagerServiceClient interface {
	AddNode(ctx context.Context, in *AddNodeRequest, opts ...grpc.CallOption) (*AddNodeResponse, error)
	AddNodes(ctx context.Context, in *AddNodesRequest, opts ...grpc.CallOption) (*AddNodesResponse, error)
	DeleteNode(ctx context.Context, in *DeleteNodeRequest, opts ...grpc.CallOption) (*DeleteNodeResponse, error)
	ListNodes(ctx context.Context, in *ListNodesRequest, opts ...grpc.CallOption) (*ListNodesResponse, error)
	MapKey(ctx context.Context, in *MapKeyRequest, opts ...grpc.CallOption) (*MapKeyResponse, error)
}

ManagerServiceClient is the client API for ManagerService service.

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

func NewManagerServiceClient 

func NewManagerServiceClient(cc *grpc.ClientConn) ManagerServiceClient

type ManagerServiceServer 

type ManagerServiceServer interface {
	AddNode(context.Context, *AddNodeRequest) (*AddNodeResponse, error)
	AddNodes(context.Context, *AddNodesRequest) (*AddNodesResponse, error)
	DeleteNode(context.Context, *DeleteNodeRequest) (*DeleteNodeResponse, error)
	ListNodes(context.Context, *ListNodesRequest) (*ListNodesResponse, error)
	MapKey(context.Context, *MapKeyRequest) (*MapKeyResponse, error)
}

ManagerServiceServer is the server API for ManagerService service.

type MapKeyRequest 

type MapKeyRequest struct {
	Key                  *KeySpec `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MapKeyRequest) Descriptor 

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

func (*MapKeyRequest) GetKey 

func (m *MapKeyRequest) GetKey() *KeySpec

func (*MapKeyRequest) ProtoMessage 

func (*MapKeyRequest) ProtoMessage()

func (*MapKeyRequest) Reset 

func (m *MapKeyRequest) Reset()

func (*MapKeyRequest) String 

func (m *MapKeyRequest) String() string

func (*MapKeyRequest) XXX_DiscardUnknown 

func (m *MapKeyRequest) XXX_DiscardUnknown()

func (*MapKeyRequest) XXX_Marshal 

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

func (*MapKeyRequest) XXX_Merge 

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

func (*MapKeyRequest) XXX_Size 

func (m *MapKeyRequest) XXX_Size() int

func (*MapKeyRequest) XXX_Unmarshal 

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

type MapKeyResponse 

type MapKeyResponse struct {
	Node                 *NodeSpec `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*MapKeyResponse) Descriptor 

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

func (*MapKeyResponse) GetNode 

func (m *MapKeyResponse) GetNode() *NodeSpec

func (*MapKeyResponse) ProtoMessage 

func (*MapKeyResponse) ProtoMessage()

func (*MapKeyResponse) Reset 

func (m *MapKeyResponse) Reset()

func (*MapKeyResponse) String 

func (m *MapKeyResponse) String() string

func (*MapKeyResponse) XXX_DiscardUnknown 

func (m *MapKeyResponse) XXX_DiscardUnknown()

func (*MapKeyResponse) XXX_Marshal 

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

func (*MapKeyResponse) XXX_Merge 

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

func (*MapKeyResponse) XXX_Size 

func (m *MapKeyResponse) XXX_Size() int

func (*MapKeyResponse) XXX_Unmarshal 

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

type NodeSpec 

type NodeSpec struct {
	Id                   string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Keys                 []*KeySpec `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*NodeSpec) Descriptor 

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

func (*NodeSpec) GetId 

func (m *NodeSpec) GetId() string

func (*NodeSpec) GetKeys 

func (m *NodeSpec) GetKeys() []*KeySpec

func (*NodeSpec) ProtoMessage 

func (*NodeSpec) ProtoMessage()

func (*NodeSpec) Reset 

func (m *NodeSpec) Reset()

func (*NodeSpec) String 

func (m *NodeSpec) String() string

func (*NodeSpec) XXX_DiscardUnknown 

func (m *NodeSpec) XXX_DiscardUnknown()

func (*NodeSpec) XXX_Marshal 

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

func (*NodeSpec) XXX_Merge 

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

func (*NodeSpec) XXX_Size 

func (m *NodeSpec) XXX_Size() int

func (*NodeSpec) XXX_Unmarshal 

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

type UnimplementedManagerServiceServer 

type UnimplementedManagerServiceServer struct {
}

UnimplementedManagerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedManagerServiceServer) AddNode 

func (*UnimplementedManagerServiceServer) AddNode(ctx context.Context, req *AddNodeRequest) (*AddNodeResponse, error)

func (*UnimplementedManagerServiceServer) AddNodes 

func (*UnimplementedManagerServiceServer) AddNodes(ctx context.Context, req *AddNodesRequest) (*AddNodesResponse, error)

func (*UnimplementedManagerServiceServer) DeleteNode 

func (*UnimplementedManagerServiceServer) DeleteNode(ctx context.Context, req *DeleteNodeRequest) (*DeleteNodeResponse, error)

func (*UnimplementedManagerServiceServer) ListNodes 

func (*UnimplementedManagerServiceServer) ListNodes(ctx context.Context, req *ListNodesRequest) (*ListNodesResponse, error)

func (*UnimplementedManagerServiceServer) MapKey 

func (*UnimplementedManagerServiceServer) MapKey(ctx context.Context, req *MapKeyRequest) (*MapKeyResponse, 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.