grpcapi

package
v0.0.0-...-535ab37 Latest Latest
Warning

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

Go to latest
Published: May 23, 2020 License: GPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewCacheClientImpl

func NewCacheClientImpl(host string, port int) interfaces.CacheClient

func RegisterCacheServer

func RegisterCacheServer(s *grpc.Server, srv CacheServer)

Types

type CacheClient

type CacheClient interface {
	SavePreview(ctx context.Context, in *SavePreviewRequest, opts ...grpc.CallOption) (*SavePreviewResponse, error)
	GetPreview(ctx context.Context, in *GetPreviewRequest, opts ...grpc.CallOption) (*GetPreviewResponse, error)
}

CacheClient is the client API for Cache service.

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

func NewCacheClient

func NewCacheClient(cc grpc.ClientConnInterface) CacheClient

type CacheClientImpl

type CacheClientImpl struct {
	// contains filtered or unexported fields
}

func (*CacheClientImpl) Get

Get preview from cache via gRPC

func (*CacheClientImpl) Save

func (c *CacheClientImpl) Save(preview *entities.Preview) error

Save preview to cache via gRPC

type CacheServer

type CacheServer interface {
	SavePreview(context.Context, *SavePreviewRequest) (*SavePreviewResponse, error)
	GetPreview(context.Context, *GetPreviewRequest) (*GetPreviewResponse, error)
}

CacheServer is the server API for Cache service.

func NewCacheServerImpl

func NewCacheServerImpl(cache interfaces.Cache) CacheServer

NewCacheServerImpl constructor

type CacheServerImpl

type CacheServerImpl struct {
	// contains filtered or unexported fields
}

CacheServerImpl implementation for gRPC API

func (*CacheServerImpl) GetPreview

func (s *CacheServerImpl) GetPreview(ctx context.Context, request *GetPreviewRequest) (*GetPreviewResponse, error)

GetPreview gRPC call handler returns preview from internal cache

func (*CacheServerImpl) SavePreview

func (s *CacheServerImpl) SavePreview(ctx context.Context, request *SavePreviewRequest) (*SavePreviewResponse, error)

SavePreview gRPC call handler saves preview in the internal cache

type GetPreviewRequest

type GetPreviewRequest struct {
	Url                  string   `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Width                uint32   `protobuf:"varint,2,opt,name=width,proto3" json:"width,omitempty"`
	Height               uint32   `protobuf:"varint,3,opt,name=height,proto3" json:"height,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetPreviewRequest) Descriptor

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

func (*GetPreviewRequest) GetHeight

func (m *GetPreviewRequest) GetHeight() uint32

func (*GetPreviewRequest) GetUrl

func (m *GetPreviewRequest) GetUrl() string

func (*GetPreviewRequest) GetWidth

func (m *GetPreviewRequest) GetWidth() uint32

func (*GetPreviewRequest) ProtoMessage

func (*GetPreviewRequest) ProtoMessage()

func (*GetPreviewRequest) Reset

func (m *GetPreviewRequest) Reset()

func (*GetPreviewRequest) String

func (m *GetPreviewRequest) String() string

func (*GetPreviewRequest) XXX_DiscardUnknown

func (m *GetPreviewRequest) XXX_DiscardUnknown()

func (*GetPreviewRequest) XXX_Marshal

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

func (*GetPreviewRequest) XXX_Merge

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

func (*GetPreviewRequest) XXX_Size

func (m *GetPreviewRequest) XXX_Size() int

func (*GetPreviewRequest) XXX_Unmarshal

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

type GetPreviewResponse

type GetPreviewResponse struct {
	// Types that are valid to be assigned to Result:
	//	*GetPreviewResponse_Preview
	//	*GetPreviewResponse_Error
	Result               isGetPreviewResponse_Result `protobuf_oneof:"result"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*GetPreviewResponse) Descriptor

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

func (*GetPreviewResponse) GetError

func (m *GetPreviewResponse) GetError() string

func (*GetPreviewResponse) GetPreview

func (m *GetPreviewResponse) GetPreview() *Preview

func (*GetPreviewResponse) GetResult

func (m *GetPreviewResponse) GetResult() isGetPreviewResponse_Result

func (*GetPreviewResponse) ProtoMessage

func (*GetPreviewResponse) ProtoMessage()

func (*GetPreviewResponse) Reset

func (m *GetPreviewResponse) Reset()

func (*GetPreviewResponse) String

func (m *GetPreviewResponse) String() string

func (*GetPreviewResponse) XXX_DiscardUnknown

func (m *GetPreviewResponse) XXX_DiscardUnknown()

func (*GetPreviewResponse) XXX_Marshal

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

func (*GetPreviewResponse) XXX_Merge

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

func (*GetPreviewResponse) XXX_OneofWrappers

func (*GetPreviewResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GetPreviewResponse) XXX_Size

func (m *GetPreviewResponse) XXX_Size() int

func (*GetPreviewResponse) XXX_Unmarshal

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

type GetPreviewResponse_Error

type GetPreviewResponse_Error struct {
	Error string `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type GetPreviewResponse_Preview

type GetPreviewResponse_Preview struct {
	Preview *Preview `protobuf:"bytes,1,opt,name=preview,proto3,oneof"`
}

type MakePreviewRequest

type MakePreviewRequest struct {
	Params               *PreviewParams    `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
	Headers              map[string]string `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*MakePreviewRequest) Descriptor

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

func (*MakePreviewRequest) GetHeaders

func (m *MakePreviewRequest) GetHeaders() map[string]string

func (*MakePreviewRequest) GetParams

func (m *MakePreviewRequest) GetParams() *PreviewParams

func (*MakePreviewRequest) ProtoMessage

func (*MakePreviewRequest) ProtoMessage()

func (*MakePreviewRequest) Reset

func (m *MakePreviewRequest) Reset()

func (*MakePreviewRequest) String

func (m *MakePreviewRequest) String() string

func (*MakePreviewRequest) XXX_DiscardUnknown

func (m *MakePreviewRequest) XXX_DiscardUnknown()

func (*MakePreviewRequest) XXX_Marshal

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

func (*MakePreviewRequest) XXX_Merge

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

func (*MakePreviewRequest) XXX_Size

func (m *MakePreviewRequest) XXX_Size() int

func (*MakePreviewRequest) XXX_Unmarshal

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

type MakePreviewResponse

type MakePreviewResponse struct {
	Preview              *Preview `protobuf:"bytes,1,opt,name=preview,proto3" json:"preview,omitempty"`
	Status               *Status  `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MakePreviewResponse) Descriptor

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

func (*MakePreviewResponse) GetPreview

func (m *MakePreviewResponse) GetPreview() *Preview

func (*MakePreviewResponse) GetStatus

func (m *MakePreviewResponse) GetStatus() *Status

func (*MakePreviewResponse) ProtoMessage

func (*MakePreviewResponse) ProtoMessage()

func (*MakePreviewResponse) Reset

func (m *MakePreviewResponse) Reset()

func (*MakePreviewResponse) String

func (m *MakePreviewResponse) String() string

func (*MakePreviewResponse) XXX_DiscardUnknown

func (m *MakePreviewResponse) XXX_DiscardUnknown()

func (*MakePreviewResponse) XXX_Marshal

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

func (*MakePreviewResponse) XXX_Merge

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

func (*MakePreviewResponse) XXX_Size

func (m *MakePreviewResponse) XXX_Size() int

func (*MakePreviewResponse) XXX_Unmarshal

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

type Preview

type Preview struct {
	Params               *PreviewParams `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
	Image                []byte         `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Preview) Descriptor

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

func (*Preview) GetImage

func (m *Preview) GetImage() []byte

func (*Preview) GetParams

func (m *Preview) GetParams() *PreviewParams

func (*Preview) ProtoMessage

func (*Preview) ProtoMessage()

func (*Preview) Reset

func (m *Preview) Reset()

func (*Preview) String

func (m *Preview) String() string

func (*Preview) XXX_DiscardUnknown

func (m *Preview) XXX_DiscardUnknown()

func (*Preview) XXX_Marshal

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

func (*Preview) XXX_Merge

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

func (*Preview) XXX_Size

func (m *Preview) XXX_Size() int

func (*Preview) XXX_Unmarshal

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

type PreviewParams

type PreviewParams struct {
	Url                  string   `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Width                uint32   `protobuf:"varint,2,opt,name=width,proto3" json:"width,omitempty"`
	Height               uint32   `protobuf:"varint,3,opt,name=height,proto3" json:"height,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PreviewParams) Descriptor

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

func (*PreviewParams) GetHeight

func (m *PreviewParams) GetHeight() uint32

func (*PreviewParams) GetUrl

func (m *PreviewParams) GetUrl() string

func (*PreviewParams) GetWidth

func (m *PreviewParams) GetWidth() uint32

func (*PreviewParams) ProtoMessage

func (*PreviewParams) ProtoMessage()

func (*PreviewParams) Reset

func (m *PreviewParams) Reset()

func (*PreviewParams) String

func (m *PreviewParams) String() string

func (*PreviewParams) XXX_DiscardUnknown

func (m *PreviewParams) XXX_DiscardUnknown()

func (*PreviewParams) XXX_Marshal

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

func (*PreviewParams) XXX_Merge

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

func (*PreviewParams) XXX_Size

func (m *PreviewParams) XXX_Size() int

func (*PreviewParams) XXX_Unmarshal

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

type SavePreviewRequest

type SavePreviewRequest struct {
	Preview              *Preview `protobuf:"bytes,1,opt,name=preview,proto3" json:"preview,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SavePreviewRequest) Descriptor

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

func (*SavePreviewRequest) GetPreview

func (m *SavePreviewRequest) GetPreview() *Preview

func (*SavePreviewRequest) ProtoMessage

func (*SavePreviewRequest) ProtoMessage()

func (*SavePreviewRequest) Reset

func (m *SavePreviewRequest) Reset()

func (*SavePreviewRequest) String

func (m *SavePreviewRequest) String() string

func (*SavePreviewRequest) XXX_DiscardUnknown

func (m *SavePreviewRequest) XXX_DiscardUnknown()

func (*SavePreviewRequest) XXX_Marshal

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

func (*SavePreviewRequest) XXX_Merge

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

func (*SavePreviewRequest) XXX_Size

func (m *SavePreviewRequest) XXX_Size() int

func (*SavePreviewRequest) XXX_Unmarshal

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

type SavePreviewResponse

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

func (*SavePreviewResponse) Descriptor

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

func (*SavePreviewResponse) GetError

func (m *SavePreviewResponse) GetError() string

func (*SavePreviewResponse) ProtoMessage

func (*SavePreviewResponse) ProtoMessage()

func (*SavePreviewResponse) Reset

func (m *SavePreviewResponse) Reset()

func (*SavePreviewResponse) String

func (m *SavePreviewResponse) String() string

func (*SavePreviewResponse) XXX_DiscardUnknown

func (m *SavePreviewResponse) XXX_DiscardUnknown()

func (*SavePreviewResponse) XXX_Marshal

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

func (*SavePreviewResponse) XXX_Merge

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

func (*SavePreviewResponse) XXX_Size

func (m *SavePreviewResponse) XXX_Size() int

func (*SavePreviewResponse) XXX_Unmarshal

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

type Status

type Status struct {
	Code                 uint32   `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Text                 string   `protobuf:"bytes,2,opt,name=text,proto3" json:"text,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Status) Descriptor

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

func (*Status) GetCode

func (m *Status) GetCode() uint32

func (*Status) GetText

func (m *Status) GetText() string

func (*Status) ProtoMessage

func (*Status) ProtoMessage()

func (*Status) Reset

func (m *Status) Reset()

func (*Status) String

func (m *Status) String() string

func (*Status) XXX_DiscardUnknown

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal

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

func (*Status) XXX_Merge

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

func (*Status) XXX_Size

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal

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

type UnimplementedCacheServer

type UnimplementedCacheServer struct {
}

UnimplementedCacheServer can be embedded to have forward compatible implementations.

func (*UnimplementedCacheServer) GetPreview

func (*UnimplementedCacheServer) SavePreview

Jump to

Keyboard shortcuts

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