storage

package
v0.10.1 Latest Latest
Warning

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

 Go to latest Published: May 19, 2017 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Overview

Package storage is a generated protocol buffer package.

It is generated from these files: 

github.com/appcelerator/amp/api/rpc/storage/storage.proto

It has these top-level messages: 

StorageEntry
GetRequest
GetReply
PutRequest
PutReply
ListRequest
ListReply
DeleteRequest
DeleteReply

Package storage is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterStorageHandler 

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

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

func RegisterStorageHandlerFromEndpoint 

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

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

func RegisterStorageServer 

func RegisterStorageServer(s *grpc.Server, srv StorageServer)

Types

type DeleteReply added in v0.10.0 

type DeleteReply struct {
	Entry *StorageEntry `protobuf:"bytes,1,opt,name=entry" json:"entry,omitempty"`
}

func (*DeleteReply) Descriptor added in v0.10.0 

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

func (*DeleteReply) GetEntry added in v0.10.0 

func (m *DeleteReply) GetEntry() *StorageEntry

func (*DeleteReply) ProtoMessage added in v0.10.0 

func (*DeleteReply) ProtoMessage()

func (*DeleteReply) Reset added in v0.10.0 

func (m *DeleteReply) Reset()

func (*DeleteReply) String added in v0.10.0 

func (m *DeleteReply) String() string

type DeleteRequest added in v0.10.0 

type DeleteRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
}

func (*DeleteRequest) Descriptor added in v0.10.0 

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

func (*DeleteRequest) GetKey added in v0.10.0 

func (m *DeleteRequest) GetKey() string

func (*DeleteRequest) ProtoMessage added in v0.10.0 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset added in v0.10.0 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) String added in v0.10.0 

func (m *DeleteRequest) String() string

type GetReply added in v0.10.0 

type GetReply struct {
	Entry *StorageEntry `protobuf:"bytes,1,opt,name=entry" json:"entry,omitempty"`
}

func (*GetReply) Descriptor added in v0.10.0 

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

func (*GetReply) GetEntry added in v0.10.0 

func (m *GetReply) GetEntry() *StorageEntry

func (*GetReply) ProtoMessage added in v0.10.0 

func (*GetReply) ProtoMessage()

func (*GetReply) Reset added in v0.10.0 

func (m *GetReply) Reset()

func (*GetReply) String added in v0.10.0 

func (m *GetReply) String() string

type GetRequest added in v0.10.0 

type GetRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
}

func (*GetRequest) Descriptor added in v0.10.0 

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

func (*GetRequest) GetKey added in v0.10.0 

func (m *GetRequest) GetKey() string

func (*GetRequest) ProtoMessage added in v0.10.0 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset added in v0.10.0 

func (m *GetRequest) Reset()

func (*GetRequest) String added in v0.10.0 

func (m *GetRequest) String() string

type ListReply added in v0.10.0 

type ListReply struct {
	Entries []*StorageEntry `protobuf:"bytes,1,rep,name=entries" json:"entries,omitempty"`
}

func (*ListReply) Descriptor added in v0.10.0 

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

func (*ListReply) GetEntries added in v0.10.0 

func (m *ListReply) GetEntries() []*StorageEntry

func (*ListReply) ProtoMessage added in v0.10.0 

func (*ListReply) ProtoMessage()

func (*ListReply) Reset added in v0.10.0 

func (m *ListReply) Reset()

func (*ListReply) String added in v0.10.0 

func (m *ListReply) String() string

type ListRequest added in v0.10.0 

type ListRequest struct {
}

func (*ListRequest) Descriptor added in v0.10.0 

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

func (*ListRequest) ProtoMessage added in v0.10.0 

func (*ListRequest) ProtoMessage()

func (*ListRequest) Reset added in v0.10.0 

func (m *ListRequest) Reset()

func (*ListRequest) String added in v0.10.0 

func (m *ListRequest) String() string

type PutReply added in v0.10.0 

type PutReply struct {
	Entry *StorageEntry `protobuf:"bytes,1,opt,name=entry" json:"entry,omitempty"`
}

func (*PutReply) Descriptor added in v0.10.0 

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

func (*PutReply) GetEntry added in v0.10.0 

func (m *PutReply) GetEntry() *StorageEntry

func (*PutReply) ProtoMessage added in v0.10.0 

func (*PutReply) ProtoMessage()

func (*PutReply) Reset added in v0.10.0 

func (m *PutReply) Reset()

func (*PutReply) String added in v0.10.0 

func (m *PutReply) String() string

type PutRequest added in v0.10.0 

type PutRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Val string `protobuf:"bytes,2,opt,name=val" json:"val,omitempty"`
}

func (*PutRequest) Descriptor added in v0.10.0 

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

func (*PutRequest) GetKey added in v0.10.0 

func (m *PutRequest) GetKey() string

func (*PutRequest) GetVal added in v0.10.0 

func (m *PutRequest) GetVal() string

func (*PutRequest) ProtoMessage added in v0.10.0 

func (*PutRequest) ProtoMessage()

func (*PutRequest) Reset added in v0.10.0 

func (m *PutRequest) Reset()

func (*PutRequest) String added in v0.10.0 

func (m *PutRequest) String() string

type Server 

type Server struct {
	Store storage.Interface
}

Server is used to implement storage service

func (*Server) Delete 

func (s *Server) Delete(ctx context.Context, in *DeleteRequest) (*DeleteReply, error)

Delete implements Server API for Storage service

func (*Server) Get 

func (s *Server) Get(ctx context.Context, in *GetRequest) (*GetReply, error)

Get implements Server API for Storage service

func (*Server) List 

func (s *Server) List(ctx context.Context, in *ListRequest) (*ListReply, error)

List implements Server API for Storage service

func (*Server) Put 

func (s *Server) Put(ctx context.Context, in *PutRequest) (*PutReply, error)

Put implements Server API for Storage service

type StorageClient 

type StorageClient interface {
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetReply, error)
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutReply, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListReply, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteReply, error)
}

func NewStorageClient 

func NewStorageClient(cc *grpc.ClientConn) StorageClient

type StorageEntry added in v0.10.0 

type StorageEntry struct {
	Key string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Val string `protobuf:"bytes,2,opt,name=val" json:"val,omitempty"`
}

func (*StorageEntry) Descriptor added in v0.10.0 

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

func (*StorageEntry) GetKey added in v0.10.0 

func (m *StorageEntry) GetKey() string

func (*StorageEntry) GetVal added in v0.10.0 

func (m *StorageEntry) GetVal() string

func (*StorageEntry) ProtoMessage added in v0.10.0 

func (*StorageEntry) ProtoMessage()

func (*StorageEntry) Reset added in v0.10.0 

func (m *StorageEntry) Reset()

func (*StorageEntry) String added in v0.10.0 

func (m *StorageEntry) String() string

type StorageServer 

type StorageServer interface {
	Get(context.Context, *GetRequest) (*GetReply, error)
	Put(context.Context, *PutRequest) (*PutReply, error)
	List(context.Context, *ListRequest) (*ListReply, error)
	Delete(context.Context, *DeleteRequest) (*DeleteReply, 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.