Documentation ¶
Overview ¶
Package pb is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Package pb is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Package pb is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Package pb is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterShrimpingHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterShrimpingHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ShrimpingClient) error
- func RegisterShrimpingHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterShrimpingHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ShrimpingServer) error
- func RegisterShrimpingServer(s grpc.ServiceRegistrar, srv ShrimpingServer)
- func RegisterShritagramHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterShritagramHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ShritagramClient) error
- func RegisterShritagramHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterShritagramHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ShritagramServer) error
- func RegisterShritagramServer(s grpc.ServiceRegistrar, srv ShritagramServer)
- func RegisterVersioningHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterVersioningHandlerClient(ctx context.Context, mux *runtime.ServeMux, client VersioningClient) error
- func RegisterVersioningHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterVersioningHandlerServer(ctx context.Context, mux *runtime.ServeMux, server VersioningServer) error
- func RegisterVersioningServer(s grpc.ServiceRegistrar, srv VersioningServer)
- func RegisterWebhookCRUDHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterWebhookCRUDHandlerClient(ctx context.Context, mux *runtime.ServeMux, client WebhookCRUDClient) error
- func RegisterWebhookCRUDHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterWebhookCRUDHandlerServer(ctx context.Context, mux *runtime.ServeMux, server WebhookCRUDServer) error
- func RegisterWebhookCRUDServer(s grpc.ServiceRegistrar, srv WebhookCRUDServer)
- type CallbackRequest
- type DeleteWebhookRequest
- func (*DeleteWebhookRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteWebhookRequest) GetApiKeys() []string
- func (*DeleteWebhookRequest) ProtoMessage()
- func (x *DeleteWebhookRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteWebhookRequest) Reset()
- func (x *DeleteWebhookRequest) String() string
- type DeleteWebhookResponse
- type ListWebhookRequest
- type ListWebhookResponse
- func (*ListWebhookResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListWebhookResponse) GetList() []*WebhookData
- func (*ListWebhookResponse) ProtoMessage()
- func (x *ListWebhookResponse) ProtoReflect() protoreflect.Message
- func (x *ListWebhookResponse) Reset()
- func (x *ListWebhookResponse) String() string
- type LoginRequest
- func (*LoginRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LoginRequest) GetEmail() string
- func (x *LoginRequest) GetPassword() string
- func (x *LoginRequest) GetServiceType() string
- func (*LoginRequest) ProtoMessage()
- func (x *LoginRequest) ProtoReflect() protoreflect.Message
- func (x *LoginRequest) Reset()
- func (x *LoginRequest) String() string
- type LoginResponse
- type LookupItemByIDsRequest
- func (*LookupItemByIDsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LookupItemByIDsRequest) GetIds() []uint64
- func (*LookupItemByIDsRequest) ProtoMessage()
- func (x *LookupItemByIDsRequest) ProtoReflect() protoreflect.Message
- func (x *LookupItemByIDsRequest) Reset()
- func (x *LookupItemByIDsRequest) String() string
- type LookupItemBySalesRequest
- func (*LookupItemBySalesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LookupItemBySalesRequest) GetCategoryId() int32
- func (x *LookupItemBySalesRequest) GetCategoryName() string
- func (x *LookupItemBySalesRequest) GetDayCategory() string
- func (x *LookupItemBySalesRequest) GetLimit() int32
- func (*LookupItemBySalesRequest) ProtoMessage()
- func (x *LookupItemBySalesRequest) ProtoReflect() protoreflect.Message
- func (x *LookupItemBySalesRequest) Reset()
- func (x *LookupItemBySalesRequest) String() string
- type ObjectCompressionAlgorithm
- func (ObjectCompressionAlgorithm) Descriptor() protoreflect.EnumDescriptor
- func (x ObjectCompressionAlgorithm) Enum() *ObjectCompressionAlgorithm
- func (ObjectCompressionAlgorithm) EnumDescriptor() ([]byte, []int)deprecated
- func (x ObjectCompressionAlgorithm) Number() protoreflect.EnumNumber
- func (x ObjectCompressionAlgorithm) String() string
- func (ObjectCompressionAlgorithm) Type() protoreflect.EnumType
- type PostRequest
- func (*PostRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PostRequest) GetCacheControl() string
- func (x *PostRequest) GetPriority() string
- func (x *PostRequest) GetShortcodes() []string
- func (*PostRequest) ProtoMessage()
- func (x *PostRequest) ProtoReflect() protoreflect.Message
- func (x *PostRequest) Reset()
- func (x *PostRequest) String() string
- type ProfileRequest
- func (*ProfileRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ProfileRequest) GetCacheControl() string
- func (x *ProfileRequest) GetPriority() string
- func (x *ProfileRequest) GetUsernames() []string
- func (*ProfileRequest) ProtoMessage()
- func (x *ProfileRequest) ProtoReflect() protoreflect.Message
- func (x *ProfileRequest) Reset()
- func (x *ProfileRequest) String() string
- type RawObject
- type RawPostObject
- func (*RawPostObject) Descriptor() ([]byte, []int)deprecated
- func (x *RawPostObject) GetRawBytes() []byte
- func (x *RawPostObject) GetShortcode() string
- func (*RawPostObject) ProtoMessage()
- func (x *RawPostObject) ProtoReflect() protoreflect.Message
- func (x *RawPostObject) Reset()
- func (x *RawPostObject) String() string
- type RawProfileObject
- func (*RawProfileObject) Descriptor() ([]byte, []int)deprecated
- func (x *RawProfileObject) GetRawBytes() []byte
- func (x *RawProfileObject) GetUsername() string
- func (*RawProfileObject) ProtoMessage()
- func (x *RawProfileObject) ProtoReflect() protoreflect.Message
- func (x *RawProfileObject) Reset()
- func (x *RawProfileObject) String() string
- type RawResponse
- type RawTopSearchObject
- func (*RawTopSearchObject) Descriptor() ([]byte, []int)deprecated
- func (x *RawTopSearchObject) GetHashtag() string
- func (x *RawTopSearchObject) GetRawBytes() []byte
- func (*RawTopSearchObject) ProtoMessage()
- func (x *RawTopSearchObject) ProtoReflect() protoreflect.Message
- func (x *RawTopSearchObject) Reset()
- func (x *RawTopSearchObject) String() string
- type ShrimpingClient
- type ShrimpingServer
- type ShritagramClient
- type ShritagramResponse
- func (*ShritagramResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ShritagramResponse) GetCompression() ObjectCompressionAlgorithm
- func (x *ShritagramResponse) GetRawPosts() []*RawPostObject
- func (x *ShritagramResponse) GetRawProfiles() []*RawProfileObject
- func (x *ShritagramResponse) GetRawTopSearchs() []*RawTopSearchObject
- func (*ShritagramResponse) ProtoMessage()
- func (x *ShritagramResponse) ProtoReflect() protoreflect.Message
- func (x *ShritagramResponse) Reset()
- func (x *ShritagramResponse) String() string
- type ShritagramServer
- type Shritagram_CallbackClient
- type Shritagram_CallbackServer
- type SubscribeWebhookRequest
- func (*SubscribeWebhookRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeWebhookRequest) GetForceHttps() bool
- func (x *SubscribeWebhookRequest) GetWebhookAddress() string
- func (*SubscribeWebhookRequest) ProtoMessage()
- func (x *SubscribeWebhookRequest) ProtoReflect() protoreflect.Message
- func (x *SubscribeWebhookRequest) Reset()
- func (x *SubscribeWebhookRequest) String() string
- type SubscribeWebhookResponse
- func (*SubscribeWebhookResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeWebhookResponse) GetData() *WebhookData
- func (*SubscribeWebhookResponse) ProtoMessage()
- func (x *SubscribeWebhookResponse) ProtoReflect() protoreflect.Message
- func (x *SubscribeWebhookResponse) Reset()
- func (x *SubscribeWebhookResponse) String() string
- type TestWebhookRequest
- type TestWebhookResponse
- type TopSearchRequest
- func (*TopSearchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TopSearchRequest) GetCacheControl() string
- func (x *TopSearchRequest) GetHashtags() []string
- func (x *TopSearchRequest) GetPriority() string
- func (*TopSearchRequest) ProtoMessage()
- func (x *TopSearchRequest) ProtoReflect() protoreflect.Message
- func (x *TopSearchRequest) Reset()
- func (x *TopSearchRequest) String() string
- type UnimplementedShrimpingServer
- func (UnimplementedShrimpingServer) Login(context.Context, *LoginRequest) (*LoginResponse, error)
- func (UnimplementedShrimpingServer) LookupItemByIDs(context.Context, *LookupItemByIDsRequest) (*RawResponse, error)
- func (UnimplementedShrimpingServer) LookupItemBySales(context.Context, *LookupItemBySalesRequest) (*RawResponse, error)
- type UnimplementedShritagramServer
- func (UnimplementedShritagramServer) Callback(*CallbackRequest, Shritagram_CallbackServer) error
- func (UnimplementedShritagramServer) Posts(context.Context, *PostRequest) (*ShritagramResponse, error)
- func (UnimplementedShritagramServer) Profile(context.Context, *ProfileRequest) (*ShritagramResponse, error)
- func (UnimplementedShritagramServer) TopSearch(context.Context, *TopSearchRequest) (*ShritagramResponse, error)
- type UnimplementedVersioningServer
- type UnimplementedWebhookCRUDServer
- func (UnimplementedWebhookCRUDServer) DeleteWebhook(context.Context, *DeleteWebhookRequest) (*DeleteWebhookResponse, error)
- func (UnimplementedWebhookCRUDServer) ListWebhook(context.Context, *ListWebhookRequest) (*ListWebhookResponse, error)
- func (UnimplementedWebhookCRUDServer) SubscribeWebhook(context.Context, *SubscribeWebhookRequest) (*SubscribeWebhookResponse, error)
- func (UnimplementedWebhookCRUDServer) TestWebhook(context.Context, *TestWebhookRequest) (*TestWebhookResponse, error)
- func (UnimplementedWebhookCRUDServer) VerifySignature(context.Context, *VerifySignatureRequest) (*VerifySignatureResponse, error)
- type UnsafeShrimpingServer
- type UnsafeShritagramServer
- type UnsafeVersioningServer
- type UnsafeWebhookCRUDServer
- type VerifySignatureRequest
- func (*VerifySignatureRequest) Descriptor() ([]byte, []int)deprecated
- func (x *VerifySignatureRequest) GetBodyDigest() string
- func (x *VerifySignatureRequest) GetCreatedTs() int32
- func (x *VerifySignatureRequest) GetHmackey() string
- func (x *VerifySignatureRequest) GetHost() string
- func (*VerifySignatureRequest) ProtoMessage()
- func (x *VerifySignatureRequest) ProtoReflect() protoreflect.Message
- func (x *VerifySignatureRequest) Reset()
- func (x *VerifySignatureRequest) String() string
- type VerifySignatureResponse
- func (*VerifySignatureResponse) Descriptor() ([]byte, []int)deprecated
- func (x *VerifySignatureResponse) GetHttpHeaders() string
- func (x *VerifySignatureResponse) GetSignStr() string
- func (x *VerifySignatureResponse) GetSignature() string
- func (*VerifySignatureResponse) ProtoMessage()
- func (x *VerifySignatureResponse) ProtoReflect() protoreflect.Message
- func (x *VerifySignatureResponse) Reset()
- func (x *VerifySignatureResponse) String() string
- type VersionRequest
- type VersionResponse
- func (*VersionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *VersionResponse) GetCompatible() bool
- func (x *VersionResponse) GetServerVersion() string
- func (*VersionResponse) ProtoMessage()
- func (x *VersionResponse) ProtoReflect() protoreflect.Message
- func (x *VersionResponse) Reset()
- func (x *VersionResponse) String() string
- type VersioningClient
- type VersioningServer
- type WebhookCRUDClient
- type WebhookCRUDServer
- type WebhookData
- func (*WebhookData) Descriptor() ([]byte, []int)deprecated
- func (x *WebhookData) GetAddress() string
- func (x *WebhookData) GetApiKey() string
- func (x *WebhookData) GetCreatedAt() string
- func (x *WebhookData) GetSecretKey() string
- func (x *WebhookData) GetUpdatedAt() string
- func (*WebhookData) ProtoMessage()
- func (x *WebhookData) ProtoReflect() protoreflect.Message
- func (x *WebhookData) Reset()
- func (x *WebhookData) String() string
Constants ¶
This section is empty.
Variables ¶
var ( ObjectCompressionAlgorithm_name = map[int32]string{ 0: "NONE", 1: "GZIP", } ObjectCompressionAlgorithm_value = map[string]int32{ "NONE": 0, "GZIP": 1, } )
Enum value maps for ObjectCompressionAlgorithm.
var File_shrimping_proto protoreflect.FileDescriptor
var File_shritagram_proto protoreflect.FileDescriptor
var File_version_proto protoreflect.FileDescriptor
var File_webhook_crud_proto protoreflect.FileDescriptor
var Shrimping_ServiceDesc = grpc.ServiceDesc{ ServiceName: "pb.shrimping", HandlerType: (*ShrimpingServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Login", Handler: _Shrimping_Login_Handler, }, { MethodName: "LookupItemByIDs", Handler: _Shrimping_LookupItemByIDs_Handler, }, { MethodName: "LookupItemBySales", Handler: _Shrimping_LookupItemBySales_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "shrimping.proto", }
Shrimping_ServiceDesc is the grpc.ServiceDesc for Shrimping service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Shritagram_ServiceDesc = grpc.ServiceDesc{ ServiceName: "pb.shritagram", HandlerType: (*ShritagramServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Profile", Handler: _Shritagram_Profile_Handler, }, { MethodName: "Posts", Handler: _Shritagram_Posts_Handler, }, { MethodName: "TopSearch", Handler: _Shritagram_TopSearch_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Callback", Handler: _Shritagram_Callback_Handler, ServerStreams: true, }, }, Metadata: "shritagram.proto", }
Shritagram_ServiceDesc is the grpc.ServiceDesc for Shritagram service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Versioning_ServiceDesc = grpc.ServiceDesc{ ServiceName: "pb.versioning", HandlerType: (*VersioningServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Version", Handler: _Versioning_Version_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "version.proto", }
Versioning_ServiceDesc is the grpc.ServiceDesc for Versioning service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var WebhookCRUD_ServiceDesc = grpc.ServiceDesc{ ServiceName: "pb.WebhookCRUD", HandlerType: (*WebhookCRUDServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "TestWebhook", Handler: _WebhookCRUD_TestWebhook_Handler, }, { MethodName: "VerifySignature", Handler: _WebhookCRUD_VerifySignature_Handler, }, { MethodName: "SubscribeWebhook", Handler: _WebhookCRUD_SubscribeWebhook_Handler, }, { MethodName: "ListWebhook", Handler: _WebhookCRUD_ListWebhook_Handler, }, { MethodName: "DeleteWebhook", Handler: _WebhookCRUD_DeleteWebhook_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "webhook_crud.proto", }
WebhookCRUD_ServiceDesc is the grpc.ServiceDesc for WebhookCRUD service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterShrimpingHandler ¶
func RegisterShrimpingHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterShrimpingHandler registers the http handlers for service Shrimping to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterShrimpingHandlerClient ¶
func RegisterShrimpingHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ShrimpingClient) error
RegisterShrimpingHandlerClient registers the http handlers for service Shrimping to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ShrimpingClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ShrimpingClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ShrimpingClient" to call the correct interceptors.
func RegisterShrimpingHandlerFromEndpoint ¶
func RegisterShrimpingHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterShrimpingHandlerFromEndpoint is same as RegisterShrimpingHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterShrimpingHandlerServer ¶
func RegisterShrimpingHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ShrimpingServer) error
RegisterShrimpingHandlerServer registers the http handlers for service Shrimping to "mux". UnaryRPC :call ShrimpingServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterShrimpingHandlerFromEndpoint instead.
func RegisterShrimpingServer ¶
func RegisterShrimpingServer(s grpc.ServiceRegistrar, srv ShrimpingServer)
func RegisterShritagramHandler ¶
func RegisterShritagramHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterShritagramHandler registers the http handlers for service Shritagram to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterShritagramHandlerClient ¶
func RegisterShritagramHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ShritagramClient) error
RegisterShritagramHandlerClient registers the http handlers for service Shritagram to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ShritagramClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ShritagramClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ShritagramClient" to call the correct interceptors.
func RegisterShritagramHandlerFromEndpoint ¶
func RegisterShritagramHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterShritagramHandlerFromEndpoint is same as RegisterShritagramHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterShritagramHandlerServer ¶
func RegisterShritagramHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ShritagramServer) error
RegisterShritagramHandlerServer registers the http handlers for service Shritagram to "mux". UnaryRPC :call ShritagramServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterShritagramHandlerFromEndpoint instead.
func RegisterShritagramServer ¶
func RegisterShritagramServer(s grpc.ServiceRegistrar, srv ShritagramServer)
func RegisterVersioningHandler ¶
func RegisterVersioningHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterVersioningHandler registers the http handlers for service Versioning to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterVersioningHandlerClient ¶
func RegisterVersioningHandlerClient(ctx context.Context, mux *runtime.ServeMux, client VersioningClient) error
RegisterVersioningHandlerClient registers the http handlers for service Versioning to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "VersioningClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "VersioningClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "VersioningClient" to call the correct interceptors.
func RegisterVersioningHandlerFromEndpoint ¶
func RegisterVersioningHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterVersioningHandlerFromEndpoint is same as RegisterVersioningHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterVersioningHandlerServer ¶
func RegisterVersioningHandlerServer(ctx context.Context, mux *runtime.ServeMux, server VersioningServer) error
RegisterVersioningHandlerServer registers the http handlers for service Versioning to "mux". UnaryRPC :call VersioningServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterVersioningHandlerFromEndpoint instead.
func RegisterVersioningServer ¶
func RegisterVersioningServer(s grpc.ServiceRegistrar, srv VersioningServer)
func RegisterWebhookCRUDHandler ¶
func RegisterWebhookCRUDHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterWebhookCRUDHandler registers the http handlers for service WebhookCRUD to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterWebhookCRUDHandlerClient ¶
func RegisterWebhookCRUDHandlerClient(ctx context.Context, mux *runtime.ServeMux, client WebhookCRUDClient) error
RegisterWebhookCRUDHandlerClient registers the http handlers for service WebhookCRUD to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "WebhookCRUDClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "WebhookCRUDClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "WebhookCRUDClient" to call the correct interceptors.
func RegisterWebhookCRUDHandlerFromEndpoint ¶
func RegisterWebhookCRUDHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterWebhookCRUDHandlerFromEndpoint is same as RegisterWebhookCRUDHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterWebhookCRUDHandlerServer ¶
func RegisterWebhookCRUDHandlerServer(ctx context.Context, mux *runtime.ServeMux, server WebhookCRUDServer) error
RegisterWebhookCRUDHandlerServer registers the http handlers for service WebhookCRUD to "mux". UnaryRPC :call WebhookCRUDServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterWebhookCRUDHandlerFromEndpoint instead.
func RegisterWebhookCRUDServer ¶
func RegisterWebhookCRUDServer(s grpc.ServiceRegistrar, srv WebhookCRUDServer)
Types ¶
type CallbackRequest ¶
type CallbackRequest struct {
// contains filtered or unexported fields
}
func (*CallbackRequest) Descriptor
deprecated
func (*CallbackRequest) Descriptor() ([]byte, []int)
Deprecated: Use CallbackRequest.ProtoReflect.Descriptor instead.
func (*CallbackRequest) ProtoMessage ¶
func (*CallbackRequest) ProtoMessage()
func (*CallbackRequest) ProtoReflect ¶
func (x *CallbackRequest) ProtoReflect() protoreflect.Message
func (*CallbackRequest) Reset ¶
func (x *CallbackRequest) Reset()
func (*CallbackRequest) String ¶
func (x *CallbackRequest) String() string
type DeleteWebhookRequest ¶
type DeleteWebhookRequest struct { ApiKeys []string `protobuf:"bytes,1,rep,name=apiKeys,proto3" json:"apiKeys,omitempty"` // contains filtered or unexported fields }
func (*DeleteWebhookRequest) Descriptor
deprecated
func (*DeleteWebhookRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteWebhookRequest.ProtoReflect.Descriptor instead.
func (*DeleteWebhookRequest) GetApiKeys ¶
func (x *DeleteWebhookRequest) GetApiKeys() []string
func (*DeleteWebhookRequest) ProtoMessage ¶
func (*DeleteWebhookRequest) ProtoMessage()
func (*DeleteWebhookRequest) ProtoReflect ¶
func (x *DeleteWebhookRequest) ProtoReflect() protoreflect.Message
func (*DeleteWebhookRequest) Reset ¶
func (x *DeleteWebhookRequest) Reset()
func (*DeleteWebhookRequest) String ¶
func (x *DeleteWebhookRequest) String() string
type DeleteWebhookResponse ¶
type DeleteWebhookResponse struct {
// contains filtered or unexported fields
}
func (*DeleteWebhookResponse) Descriptor
deprecated
func (*DeleteWebhookResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteWebhookResponse.ProtoReflect.Descriptor instead.
func (*DeleteWebhookResponse) ProtoMessage ¶
func (*DeleteWebhookResponse) ProtoMessage()
func (*DeleteWebhookResponse) ProtoReflect ¶
func (x *DeleteWebhookResponse) ProtoReflect() protoreflect.Message
func (*DeleteWebhookResponse) Reset ¶
func (x *DeleteWebhookResponse) Reset()
func (*DeleteWebhookResponse) String ¶
func (x *DeleteWebhookResponse) String() string
type ListWebhookRequest ¶
type ListWebhookRequest struct {
// contains filtered or unexported fields
}
func (*ListWebhookRequest) Descriptor
deprecated
func (*ListWebhookRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListWebhookRequest.ProtoReflect.Descriptor instead.
func (*ListWebhookRequest) ProtoMessage ¶
func (*ListWebhookRequest) ProtoMessage()
func (*ListWebhookRequest) ProtoReflect ¶
func (x *ListWebhookRequest) ProtoReflect() protoreflect.Message
func (*ListWebhookRequest) Reset ¶
func (x *ListWebhookRequest) Reset()
func (*ListWebhookRequest) String ¶
func (x *ListWebhookRequest) String() string
type ListWebhookResponse ¶
type ListWebhookResponse struct { List []*WebhookData `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"` // contains filtered or unexported fields }
func (*ListWebhookResponse) Descriptor
deprecated
func (*ListWebhookResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListWebhookResponse.ProtoReflect.Descriptor instead.
func (*ListWebhookResponse) GetList ¶
func (x *ListWebhookResponse) GetList() []*WebhookData
func (*ListWebhookResponse) ProtoMessage ¶
func (*ListWebhookResponse) ProtoMessage()
func (*ListWebhookResponse) ProtoReflect ¶
func (x *ListWebhookResponse) ProtoReflect() protoreflect.Message
func (*ListWebhookResponse) Reset ¶
func (x *ListWebhookResponse) Reset()
func (*ListWebhookResponse) String ¶
func (x *ListWebhookResponse) String() string
type LoginRequest ¶
type LoginRequest struct { ServiceType string `protobuf:"bytes,1,opt,name=serviceType,proto3" json:"serviceType,omitempty"` Email string `protobuf:"bytes,2,opt,name=email,proto3" json:"email,omitempty"` Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"` // contains filtered or unexported fields }
func (*LoginRequest) Descriptor
deprecated
func (*LoginRequest) Descriptor() ([]byte, []int)
Deprecated: Use LoginRequest.ProtoReflect.Descriptor instead.
func (*LoginRequest) GetEmail ¶
func (x *LoginRequest) GetEmail() string
func (*LoginRequest) GetPassword ¶
func (x *LoginRequest) GetPassword() string
func (*LoginRequest) GetServiceType ¶
func (x *LoginRequest) GetServiceType() string
func (*LoginRequest) ProtoMessage ¶
func (*LoginRequest) ProtoMessage()
func (*LoginRequest) ProtoReflect ¶
func (x *LoginRequest) ProtoReflect() protoreflect.Message
func (*LoginRequest) Reset ¶
func (x *LoginRequest) Reset()
func (*LoginRequest) String ¶
func (x *LoginRequest) String() string
type LoginResponse ¶
type LoginResponse struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` // contains filtered or unexported fields }
func (*LoginResponse) Descriptor
deprecated
func (*LoginResponse) Descriptor() ([]byte, []int)
Deprecated: Use LoginResponse.ProtoReflect.Descriptor instead.
func (*LoginResponse) GetToken ¶
func (x *LoginResponse) GetToken() string
func (*LoginResponse) ProtoMessage ¶
func (*LoginResponse) ProtoMessage()
func (*LoginResponse) ProtoReflect ¶
func (x *LoginResponse) ProtoReflect() protoreflect.Message
func (*LoginResponse) Reset ¶
func (x *LoginResponse) Reset()
func (*LoginResponse) String ¶
func (x *LoginResponse) String() string
type LookupItemByIDsRequest ¶
type LookupItemByIDsRequest struct { Ids []uint64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"` // contains filtered or unexported fields }
func (*LookupItemByIDsRequest) Descriptor
deprecated
func (*LookupItemByIDsRequest) Descriptor() ([]byte, []int)
Deprecated: Use LookupItemByIDsRequest.ProtoReflect.Descriptor instead.
func (*LookupItemByIDsRequest) GetIds ¶
func (x *LookupItemByIDsRequest) GetIds() []uint64
func (*LookupItemByIDsRequest) ProtoMessage ¶
func (*LookupItemByIDsRequest) ProtoMessage()
func (*LookupItemByIDsRequest) ProtoReflect ¶
func (x *LookupItemByIDsRequest) ProtoReflect() protoreflect.Message
func (*LookupItemByIDsRequest) Reset ¶
func (x *LookupItemByIDsRequest) Reset()
func (*LookupItemByIDsRequest) String ¶
func (x *LookupItemByIDsRequest) String() string
type LookupItemBySalesRequest ¶
type LookupItemBySalesRequest struct { DayCategory string `protobuf:"bytes,1,opt,name=dayCategory,proto3" json:"dayCategory,omitempty"` CategoryId *int32 `protobuf:"varint,2,opt,name=categoryId,proto3,oneof" json:"categoryId,omitempty"` CategoryName *string `protobuf:"bytes,3,opt,name=categoryName,proto3,oneof" json:"categoryName,omitempty"` Limit *int32 `protobuf:"varint,4,opt,name=limit,proto3,oneof" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*LookupItemBySalesRequest) Descriptor
deprecated
func (*LookupItemBySalesRequest) Descriptor() ([]byte, []int)
Deprecated: Use LookupItemBySalesRequest.ProtoReflect.Descriptor instead.
func (*LookupItemBySalesRequest) GetCategoryId ¶
func (x *LookupItemBySalesRequest) GetCategoryId() int32
func (*LookupItemBySalesRequest) GetCategoryName ¶
func (x *LookupItemBySalesRequest) GetCategoryName() string
func (*LookupItemBySalesRequest) GetDayCategory ¶
func (x *LookupItemBySalesRequest) GetDayCategory() string
func (*LookupItemBySalesRequest) GetLimit ¶
func (x *LookupItemBySalesRequest) GetLimit() int32
func (*LookupItemBySalesRequest) ProtoMessage ¶
func (*LookupItemBySalesRequest) ProtoMessage()
func (*LookupItemBySalesRequest) ProtoReflect ¶
func (x *LookupItemBySalesRequest) ProtoReflect() protoreflect.Message
func (*LookupItemBySalesRequest) Reset ¶
func (x *LookupItemBySalesRequest) Reset()
func (*LookupItemBySalesRequest) String ¶
func (x *LookupItemBySalesRequest) String() string
type ObjectCompressionAlgorithm ¶
type ObjectCompressionAlgorithm int32
const ( ObjectCompressionAlgorithm_NONE ObjectCompressionAlgorithm = 0 ObjectCompressionAlgorithm_GZIP ObjectCompressionAlgorithm = 1 )
func (ObjectCompressionAlgorithm) Descriptor ¶
func (ObjectCompressionAlgorithm) Descriptor() protoreflect.EnumDescriptor
func (ObjectCompressionAlgorithm) Enum ¶
func (x ObjectCompressionAlgorithm) Enum() *ObjectCompressionAlgorithm
func (ObjectCompressionAlgorithm) EnumDescriptor
deprecated
func (ObjectCompressionAlgorithm) EnumDescriptor() ([]byte, []int)
Deprecated: Use ObjectCompressionAlgorithm.Descriptor instead.
func (ObjectCompressionAlgorithm) Number ¶
func (x ObjectCompressionAlgorithm) Number() protoreflect.EnumNumber
func (ObjectCompressionAlgorithm) String ¶
func (x ObjectCompressionAlgorithm) String() string
func (ObjectCompressionAlgorithm) Type ¶
func (ObjectCompressionAlgorithm) Type() protoreflect.EnumType
type PostRequest ¶
type PostRequest struct { Shortcodes []string `protobuf:"bytes,1,rep,name=shortcodes,proto3" json:"shortcodes,omitempty"` // cacheControl has possible values: // no-cache: the request won't go through backend server's cache, it is revalidated with the actualy service (i.g. instagram) // max-age=604800: the request's result will be kept in cache with the duration(in s) specified // // default value is max-age=86400 CacheControl string `protobuf:"bytes,2,opt,name=cacheControl,proto3" json:"cacheControl,omitempty"` // priority has three possible values: high/median/low. // the server will execute jobs according to its priority. Priority string `protobuf:"bytes,3,opt,name=priority,proto3" json:"priority,omitempty"` // contains filtered or unexported fields }
func (*PostRequest) Descriptor
deprecated
func (*PostRequest) Descriptor() ([]byte, []int)
Deprecated: Use PostRequest.ProtoReflect.Descriptor instead.
func (*PostRequest) GetCacheControl ¶
func (x *PostRequest) GetCacheControl() string
func (*PostRequest) GetPriority ¶
func (x *PostRequest) GetPriority() string
func (*PostRequest) GetShortcodes ¶
func (x *PostRequest) GetShortcodes() []string
func (*PostRequest) ProtoMessage ¶
func (*PostRequest) ProtoMessage()
func (*PostRequest) ProtoReflect ¶
func (x *PostRequest) ProtoReflect() protoreflect.Message
func (*PostRequest) Reset ¶
func (x *PostRequest) Reset()
func (*PostRequest) String ¶
func (x *PostRequest) String() string
type ProfileRequest ¶
type ProfileRequest struct { Usernames []string `protobuf:"bytes,1,rep,name=usernames,proto3" json:"usernames,omitempty"` // cacheControl has possible values: // no-cache: the request won't go through backend server's cache, it is revalidated with the actualy service (i.g. instagram) // max-age=604800: the request's result will be kept in cache with the duration(in s) specified // // default value is max-age=86400 CacheControl string `protobuf:"bytes,2,opt,name=cacheControl,proto3" json:"cacheControl,omitempty"` // priority has three possible values: high/median/low. // the server will execute jobs according to its priority. Priority string `protobuf:"bytes,3,opt,name=priority,proto3" json:"priority,omitempty"` // contains filtered or unexported fields }
func (*ProfileRequest) Descriptor
deprecated
func (*ProfileRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProfileRequest.ProtoReflect.Descriptor instead.
func (*ProfileRequest) GetCacheControl ¶
func (x *ProfileRequest) GetCacheControl() string
func (*ProfileRequest) GetPriority ¶
func (x *ProfileRequest) GetPriority() string
func (*ProfileRequest) GetUsernames ¶
func (x *ProfileRequest) GetUsernames() []string
func (*ProfileRequest) ProtoMessage ¶
func (*ProfileRequest) ProtoMessage()
func (*ProfileRequest) ProtoReflect ¶
func (x *ProfileRequest) ProtoReflect() protoreflect.Message
func (*ProfileRequest) Reset ¶
func (x *ProfileRequest) Reset()
func (*ProfileRequest) String ¶
func (x *ProfileRequest) String() string
type RawObject ¶
type RawObject struct { Item []byte `protobuf:"bytes,1,opt,name=item,proto3,oneof" json:"item,omitempty"` // contains filtered or unexported fields }
func (*RawObject) Descriptor
deprecated
func (*RawObject) ProtoMessage ¶
func (*RawObject) ProtoMessage()
func (*RawObject) ProtoReflect ¶
func (x *RawObject) ProtoReflect() protoreflect.Message
type RawPostObject ¶
type RawPostObject struct { Shortcode string `protobuf:"bytes,1,opt,name=shortcode,proto3" json:"shortcode,omitempty"` RawBytes []byte `protobuf:"bytes,2,opt,name=rawBytes,proto3" json:"rawBytes,omitempty"` // contains filtered or unexported fields }
func (*RawPostObject) Descriptor
deprecated
func (*RawPostObject) Descriptor() ([]byte, []int)
Deprecated: Use RawPostObject.ProtoReflect.Descriptor instead.
func (*RawPostObject) GetRawBytes ¶
func (x *RawPostObject) GetRawBytes() []byte
func (*RawPostObject) GetShortcode ¶
func (x *RawPostObject) GetShortcode() string
func (*RawPostObject) ProtoMessage ¶
func (*RawPostObject) ProtoMessage()
func (*RawPostObject) ProtoReflect ¶
func (x *RawPostObject) ProtoReflect() protoreflect.Message
func (*RawPostObject) Reset ¶
func (x *RawPostObject) Reset()
func (*RawPostObject) String ¶
func (x *RawPostObject) String() string
type RawProfileObject ¶
type RawProfileObject struct { Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` RawBytes []byte `protobuf:"bytes,2,opt,name=rawBytes,proto3" json:"rawBytes,omitempty"` // contains filtered or unexported fields }
func (*RawProfileObject) Descriptor
deprecated
func (*RawProfileObject) Descriptor() ([]byte, []int)
Deprecated: Use RawProfileObject.ProtoReflect.Descriptor instead.
func (*RawProfileObject) GetRawBytes ¶
func (x *RawProfileObject) GetRawBytes() []byte
func (*RawProfileObject) GetUsername ¶
func (x *RawProfileObject) GetUsername() string
func (*RawProfileObject) ProtoMessage ¶
func (*RawProfileObject) ProtoMessage()
func (*RawProfileObject) ProtoReflect ¶
func (x *RawProfileObject) ProtoReflect() protoreflect.Message
func (*RawProfileObject) Reset ¶
func (x *RawProfileObject) Reset()
func (*RawProfileObject) String ¶
func (x *RawProfileObject) String() string
type RawResponse ¶
type RawResponse struct { RawObjects []*RawObject `protobuf:"bytes,1,rep,name=rawObjects,proto3" json:"rawObjects,omitempty"` // contains filtered or unexported fields }
func (*RawResponse) Descriptor
deprecated
func (*RawResponse) Descriptor() ([]byte, []int)
Deprecated: Use RawResponse.ProtoReflect.Descriptor instead.
func (*RawResponse) GetRawObjects ¶
func (x *RawResponse) GetRawObjects() []*RawObject
func (*RawResponse) ProtoMessage ¶
func (*RawResponse) ProtoMessage()
func (*RawResponse) ProtoReflect ¶
func (x *RawResponse) ProtoReflect() protoreflect.Message
func (*RawResponse) Reset ¶
func (x *RawResponse) Reset()
func (*RawResponse) String ¶
func (x *RawResponse) String() string
type RawTopSearchObject ¶
type RawTopSearchObject struct { Hashtag string `protobuf:"bytes,1,opt,name=hashtag,proto3" json:"hashtag,omitempty"` RawBytes []byte `protobuf:"bytes,2,opt,name=rawBytes,proto3" json:"rawBytes,omitempty"` // contains filtered or unexported fields }
func (*RawTopSearchObject) Descriptor
deprecated
func (*RawTopSearchObject) Descriptor() ([]byte, []int)
Deprecated: Use RawTopSearchObject.ProtoReflect.Descriptor instead.
func (*RawTopSearchObject) GetHashtag ¶
func (x *RawTopSearchObject) GetHashtag() string
func (*RawTopSearchObject) GetRawBytes ¶
func (x *RawTopSearchObject) GetRawBytes() []byte
func (*RawTopSearchObject) ProtoMessage ¶
func (*RawTopSearchObject) ProtoMessage()
func (*RawTopSearchObject) ProtoReflect ¶
func (x *RawTopSearchObject) ProtoReflect() protoreflect.Message
func (*RawTopSearchObject) Reset ¶
func (x *RawTopSearchObject) Reset()
func (*RawTopSearchObject) String ¶
func (x *RawTopSearchObject) String() string
type ShrimpingClient ¶
type ShrimpingClient interface { Login(ctx context.Context, in *LoginRequest, opts ...grpc.CallOption) (*LoginResponse, error) LookupItemByIDs(ctx context.Context, in *LookupItemByIDsRequest, opts ...grpc.CallOption) (*RawResponse, error) LookupItemBySales(ctx context.Context, in *LookupItemBySalesRequest, opts ...grpc.CallOption) (*RawResponse, error) }
ShrimpingClient is the client API for Shrimping service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewShrimpingClient ¶
func NewShrimpingClient(cc grpc.ClientConnInterface) ShrimpingClient
type ShrimpingServer ¶
type ShrimpingServer interface { Login(context.Context, *LoginRequest) (*LoginResponse, error) LookupItemByIDs(context.Context, *LookupItemByIDsRequest) (*RawResponse, error) LookupItemBySales(context.Context, *LookupItemBySalesRequest) (*RawResponse, error) // contains filtered or unexported methods }
ShrimpingServer is the server API for Shrimping service. All implementations must embed UnimplementedShrimpingServer for forward compatibility
type ShritagramClient ¶
type ShritagramClient interface { Callback(ctx context.Context, in *CallbackRequest, opts ...grpc.CallOption) (Shritagram_CallbackClient, error) Profile(ctx context.Context, in *ProfileRequest, opts ...grpc.CallOption) (*ShritagramResponse, error) Posts(ctx context.Context, in *PostRequest, opts ...grpc.CallOption) (*ShritagramResponse, error) TopSearch(ctx context.Context, in *TopSearchRequest, opts ...grpc.CallOption) (*ShritagramResponse, error) }
ShritagramClient is the client API for Shritagram service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewShritagramClient ¶
func NewShritagramClient(cc grpc.ClientConnInterface) ShritagramClient
type ShritagramResponse ¶
type ShritagramResponse struct { Compression ObjectCompressionAlgorithm `protobuf:"varint,1,opt,name=compression,proto3,enum=pb.ObjectCompressionAlgorithm" json:"compression,omitempty"` RawProfiles []*RawProfileObject `protobuf:"bytes,2,rep,name=rawProfiles,proto3" json:"rawProfiles,omitempty"` RawPosts []*RawPostObject `protobuf:"bytes,3,rep,name=rawPosts,proto3" json:"rawPosts,omitempty"` RawTopSearchs []*RawTopSearchObject `protobuf:"bytes,4,rep,name=rawTopSearchs,proto3" json:"rawTopSearchs,omitempty"` // contains filtered or unexported fields }
func (*ShritagramResponse) Descriptor
deprecated
func (*ShritagramResponse) Descriptor() ([]byte, []int)
Deprecated: Use ShritagramResponse.ProtoReflect.Descriptor instead.
func (*ShritagramResponse) GetCompression ¶
func (x *ShritagramResponse) GetCompression() ObjectCompressionAlgorithm
func (*ShritagramResponse) GetRawPosts ¶
func (x *ShritagramResponse) GetRawPosts() []*RawPostObject
func (*ShritagramResponse) GetRawProfiles ¶
func (x *ShritagramResponse) GetRawProfiles() []*RawProfileObject
func (*ShritagramResponse) GetRawTopSearchs ¶
func (x *ShritagramResponse) GetRawTopSearchs() []*RawTopSearchObject
func (*ShritagramResponse) ProtoMessage ¶
func (*ShritagramResponse) ProtoMessage()
func (*ShritagramResponse) ProtoReflect ¶
func (x *ShritagramResponse) ProtoReflect() protoreflect.Message
func (*ShritagramResponse) Reset ¶
func (x *ShritagramResponse) Reset()
func (*ShritagramResponse) String ¶
func (x *ShritagramResponse) String() string
type ShritagramServer ¶
type ShritagramServer interface { Callback(*CallbackRequest, Shritagram_CallbackServer) error Profile(context.Context, *ProfileRequest) (*ShritagramResponse, error) Posts(context.Context, *PostRequest) (*ShritagramResponse, error) TopSearch(context.Context, *TopSearchRequest) (*ShritagramResponse, error) // contains filtered or unexported methods }
ShritagramServer is the server API for Shritagram service. All implementations must embed UnimplementedShritagramServer for forward compatibility
type Shritagram_CallbackClient ¶
type Shritagram_CallbackClient interface { Recv() (*ShritagramResponse, error) grpc.ClientStream }
type Shritagram_CallbackServer ¶
type Shritagram_CallbackServer interface { Send(*ShritagramResponse) error grpc.ServerStream }
type SubscribeWebhookRequest ¶
type SubscribeWebhookRequest struct { WebhookAddress string `protobuf:"bytes,1,opt,name=webhookAddress,proto3" json:"webhookAddress,omitempty"` ForceHttps *bool `protobuf:"varint,2,opt,name=forceHttps,proto3,oneof" json:"forceHttps,omitempty"` // contains filtered or unexported fields }
func (*SubscribeWebhookRequest) Descriptor
deprecated
func (*SubscribeWebhookRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeWebhookRequest.ProtoReflect.Descriptor instead.
func (*SubscribeWebhookRequest) GetForceHttps ¶
func (x *SubscribeWebhookRequest) GetForceHttps() bool
func (*SubscribeWebhookRequest) GetWebhookAddress ¶
func (x *SubscribeWebhookRequest) GetWebhookAddress() string
func (*SubscribeWebhookRequest) ProtoMessage ¶
func (*SubscribeWebhookRequest) ProtoMessage()
func (*SubscribeWebhookRequest) ProtoReflect ¶
func (x *SubscribeWebhookRequest) ProtoReflect() protoreflect.Message
func (*SubscribeWebhookRequest) Reset ¶
func (x *SubscribeWebhookRequest) Reset()
func (*SubscribeWebhookRequest) String ¶
func (x *SubscribeWebhookRequest) String() string
type SubscribeWebhookResponse ¶
type SubscribeWebhookResponse struct { Data *WebhookData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*SubscribeWebhookResponse) Descriptor
deprecated
func (*SubscribeWebhookResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeWebhookResponse.ProtoReflect.Descriptor instead.
func (*SubscribeWebhookResponse) GetData ¶
func (x *SubscribeWebhookResponse) GetData() *WebhookData
func (*SubscribeWebhookResponse) ProtoMessage ¶
func (*SubscribeWebhookResponse) ProtoMessage()
func (*SubscribeWebhookResponse) ProtoReflect ¶
func (x *SubscribeWebhookResponse) ProtoReflect() protoreflect.Message
func (*SubscribeWebhookResponse) Reset ¶
func (x *SubscribeWebhookResponse) Reset()
func (*SubscribeWebhookResponse) String ¶
func (x *SubscribeWebhookResponse) String() string
type TestWebhookRequest ¶
type TestWebhookRequest struct {
// contains filtered or unexported fields
}
func (*TestWebhookRequest) Descriptor
deprecated
func (*TestWebhookRequest) Descriptor() ([]byte, []int)
Deprecated: Use TestWebhookRequest.ProtoReflect.Descriptor instead.
func (*TestWebhookRequest) ProtoMessage ¶
func (*TestWebhookRequest) ProtoMessage()
func (*TestWebhookRequest) ProtoReflect ¶
func (x *TestWebhookRequest) ProtoReflect() protoreflect.Message
func (*TestWebhookRequest) Reset ¶
func (x *TestWebhookRequest) Reset()
func (*TestWebhookRequest) String ¶
func (x *TestWebhookRequest) String() string
type TestWebhookResponse ¶
type TestWebhookResponse struct {
// contains filtered or unexported fields
}
func (*TestWebhookResponse) Descriptor
deprecated
func (*TestWebhookResponse) Descriptor() ([]byte, []int)
Deprecated: Use TestWebhookResponse.ProtoReflect.Descriptor instead.
func (*TestWebhookResponse) ProtoMessage ¶
func (*TestWebhookResponse) ProtoMessage()
func (*TestWebhookResponse) ProtoReflect ¶
func (x *TestWebhookResponse) ProtoReflect() protoreflect.Message
func (*TestWebhookResponse) Reset ¶
func (x *TestWebhookResponse) Reset()
func (*TestWebhookResponse) String ¶
func (x *TestWebhookResponse) String() string
type TopSearchRequest ¶
type TopSearchRequest struct { // cacheControl has possible values: // no-cache: the request won't go through backend server's cache, it is revalidated with the actualy service (i.g. instagram) // max-age=604800: the request's result will be kept in cache with the duration(in s) specified // // default value is max-age=86400 CacheControl string `protobuf:"bytes,2,opt,name=cacheControl,proto3" json:"cacheControl,omitempty"` // priority has three possible values: high/median/low. // the server will execute jobs according to its priority. Priority string `protobuf:"bytes,3,opt,name=priority,proto3" json:"priority,omitempty"` // contains filtered or unexported fields }
func (*TopSearchRequest) Descriptor
deprecated
func (*TopSearchRequest) Descriptor() ([]byte, []int)
Deprecated: Use TopSearchRequest.ProtoReflect.Descriptor instead.
func (*TopSearchRequest) GetCacheControl ¶
func (x *TopSearchRequest) GetCacheControl() string
func (*TopSearchRequest) GetHashtags ¶
func (x *TopSearchRequest) GetHashtags() []string
func (*TopSearchRequest) GetPriority ¶
func (x *TopSearchRequest) GetPriority() string
func (*TopSearchRequest) ProtoMessage ¶
func (*TopSearchRequest) ProtoMessage()
func (*TopSearchRequest) ProtoReflect ¶
func (x *TopSearchRequest) ProtoReflect() protoreflect.Message
func (*TopSearchRequest) Reset ¶
func (x *TopSearchRequest) Reset()
func (*TopSearchRequest) String ¶
func (x *TopSearchRequest) String() string
type UnimplementedShrimpingServer ¶
type UnimplementedShrimpingServer struct { }
UnimplementedShrimpingServer must be embedded to have forward compatible implementations.
func (UnimplementedShrimpingServer) Login ¶
func (UnimplementedShrimpingServer) Login(context.Context, *LoginRequest) (*LoginResponse, error)
func (UnimplementedShrimpingServer) LookupItemByIDs ¶
func (UnimplementedShrimpingServer) LookupItemByIDs(context.Context, *LookupItemByIDsRequest) (*RawResponse, error)
func (UnimplementedShrimpingServer) LookupItemBySales ¶
func (UnimplementedShrimpingServer) LookupItemBySales(context.Context, *LookupItemBySalesRequest) (*RawResponse, error)
type UnimplementedShritagramServer ¶
type UnimplementedShritagramServer struct { }
UnimplementedShritagramServer must be embedded to have forward compatible implementations.
func (UnimplementedShritagramServer) Callback ¶
func (UnimplementedShritagramServer) Callback(*CallbackRequest, Shritagram_CallbackServer) error
func (UnimplementedShritagramServer) Posts ¶
func (UnimplementedShritagramServer) Posts(context.Context, *PostRequest) (*ShritagramResponse, error)
func (UnimplementedShritagramServer) Profile ¶
func (UnimplementedShritagramServer) Profile(context.Context, *ProfileRequest) (*ShritagramResponse, error)
func (UnimplementedShritagramServer) TopSearch ¶
func (UnimplementedShritagramServer) TopSearch(context.Context, *TopSearchRequest) (*ShritagramResponse, error)
type UnimplementedVersioningServer ¶
type UnimplementedVersioningServer struct { }
UnimplementedVersioningServer must be embedded to have forward compatible implementations.
func (UnimplementedVersioningServer) Version ¶
func (UnimplementedVersioningServer) Version(context.Context, *VersionRequest) (*VersionResponse, error)
type UnimplementedWebhookCRUDServer ¶
type UnimplementedWebhookCRUDServer struct { }
UnimplementedWebhookCRUDServer must be embedded to have forward compatible implementations.
func (UnimplementedWebhookCRUDServer) DeleteWebhook ¶
func (UnimplementedWebhookCRUDServer) DeleteWebhook(context.Context, *DeleteWebhookRequest) (*DeleteWebhookResponse, error)
func (UnimplementedWebhookCRUDServer) ListWebhook ¶
func (UnimplementedWebhookCRUDServer) ListWebhook(context.Context, *ListWebhookRequest) (*ListWebhookResponse, error)
func (UnimplementedWebhookCRUDServer) SubscribeWebhook ¶
func (UnimplementedWebhookCRUDServer) SubscribeWebhook(context.Context, *SubscribeWebhookRequest) (*SubscribeWebhookResponse, error)
func (UnimplementedWebhookCRUDServer) TestWebhook ¶
func (UnimplementedWebhookCRUDServer) TestWebhook(context.Context, *TestWebhookRequest) (*TestWebhookResponse, error)
func (UnimplementedWebhookCRUDServer) VerifySignature ¶
func (UnimplementedWebhookCRUDServer) VerifySignature(context.Context, *VerifySignatureRequest) (*VerifySignatureResponse, error)
type UnsafeShrimpingServer ¶
type UnsafeShrimpingServer interface {
// contains filtered or unexported methods
}
UnsafeShrimpingServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ShrimpingServer will result in compilation errors.
type UnsafeShritagramServer ¶
type UnsafeShritagramServer interface {
// contains filtered or unexported methods
}
UnsafeShritagramServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ShritagramServer will result in compilation errors.
type UnsafeVersioningServer ¶
type UnsafeVersioningServer interface {
// contains filtered or unexported methods
}
UnsafeVersioningServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to VersioningServer will result in compilation errors.
type UnsafeWebhookCRUDServer ¶
type UnsafeWebhookCRUDServer interface {
// contains filtered or unexported methods
}
UnsafeWebhookCRUDServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WebhookCRUDServer will result in compilation errors.
type VerifySignatureRequest ¶
type VerifySignatureRequest struct { Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` Hmackey string `protobuf:"bytes,2,opt,name=hmackey,proto3" json:"hmackey,omitempty"` BodyDigest string `protobuf:"bytes,3,opt,name=bodyDigest,proto3" json:"bodyDigest,omitempty"` CreatedTs *int32 `protobuf:"varint,4,opt,name=createdTs,proto3,oneof" json:"createdTs,omitempty"` // contains filtered or unexported fields }
func (*VerifySignatureRequest) Descriptor
deprecated
func (*VerifySignatureRequest) Descriptor() ([]byte, []int)
Deprecated: Use VerifySignatureRequest.ProtoReflect.Descriptor instead.
func (*VerifySignatureRequest) GetBodyDigest ¶
func (x *VerifySignatureRequest) GetBodyDigest() string
func (*VerifySignatureRequest) GetCreatedTs ¶
func (x *VerifySignatureRequest) GetCreatedTs() int32
func (*VerifySignatureRequest) GetHmackey ¶
func (x *VerifySignatureRequest) GetHmackey() string
func (*VerifySignatureRequest) GetHost ¶
func (x *VerifySignatureRequest) GetHost() string
func (*VerifySignatureRequest) ProtoMessage ¶
func (*VerifySignatureRequest) ProtoMessage()
func (*VerifySignatureRequest) ProtoReflect ¶
func (x *VerifySignatureRequest) ProtoReflect() protoreflect.Message
func (*VerifySignatureRequest) Reset ¶
func (x *VerifySignatureRequest) Reset()
func (*VerifySignatureRequest) String ¶
func (x *VerifySignatureRequest) String() string
type VerifySignatureResponse ¶
type VerifySignatureResponse struct { SignStr string `protobuf:"bytes,1,opt,name=signStr,proto3" json:"signStr,omitempty"` Signature string `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` HttpHeaders string `protobuf:"bytes,3,opt,name=httpHeaders,proto3" json:"httpHeaders,omitempty"` // contains filtered or unexported fields }
func (*VerifySignatureResponse) Descriptor
deprecated
func (*VerifySignatureResponse) Descriptor() ([]byte, []int)
Deprecated: Use VerifySignatureResponse.ProtoReflect.Descriptor instead.
func (*VerifySignatureResponse) GetHttpHeaders ¶
func (x *VerifySignatureResponse) GetHttpHeaders() string
func (*VerifySignatureResponse) GetSignStr ¶
func (x *VerifySignatureResponse) GetSignStr() string
func (*VerifySignatureResponse) GetSignature ¶
func (x *VerifySignatureResponse) GetSignature() string
func (*VerifySignatureResponse) ProtoMessage ¶
func (*VerifySignatureResponse) ProtoMessage()
func (*VerifySignatureResponse) ProtoReflect ¶
func (x *VerifySignatureResponse) ProtoReflect() protoreflect.Message
func (*VerifySignatureResponse) Reset ¶
func (x *VerifySignatureResponse) Reset()
func (*VerifySignatureResponse) String ¶
func (x *VerifySignatureResponse) String() string
type VersionRequest ¶
type VersionRequest struct { ClientVersion string `protobuf:"bytes,1,opt,name=clientVersion,proto3" json:"clientVersion,omitempty"` // contains filtered or unexported fields }
func (*VersionRequest) Descriptor
deprecated
func (*VersionRequest) Descriptor() ([]byte, []int)
Deprecated: Use VersionRequest.ProtoReflect.Descriptor instead.
func (*VersionRequest) GetClientVersion ¶
func (x *VersionRequest) GetClientVersion() string
func (*VersionRequest) ProtoMessage ¶
func (*VersionRequest) ProtoMessage()
func (*VersionRequest) ProtoReflect ¶
func (x *VersionRequest) ProtoReflect() protoreflect.Message
func (*VersionRequest) Reset ¶
func (x *VersionRequest) Reset()
func (*VersionRequest) String ¶
func (x *VersionRequest) String() string
type VersionResponse ¶
type VersionResponse struct { ServerVersion string `protobuf:"bytes,1,opt,name=serverVersion,proto3" json:"serverVersion,omitempty"` Compatible bool `protobuf:"varint,2,opt,name=compatible,proto3" json:"compatible,omitempty"` // contains filtered or unexported fields }
func (*VersionResponse) Descriptor
deprecated
func (*VersionResponse) Descriptor() ([]byte, []int)
Deprecated: Use VersionResponse.ProtoReflect.Descriptor instead.
func (*VersionResponse) GetCompatible ¶
func (x *VersionResponse) GetCompatible() bool
func (*VersionResponse) GetServerVersion ¶
func (x *VersionResponse) GetServerVersion() string
func (*VersionResponse) ProtoMessage ¶
func (*VersionResponse) ProtoMessage()
func (*VersionResponse) ProtoReflect ¶
func (x *VersionResponse) ProtoReflect() protoreflect.Message
func (*VersionResponse) Reset ¶
func (x *VersionResponse) Reset()
func (*VersionResponse) String ¶
func (x *VersionResponse) String() string
type VersioningClient ¶
type VersioningClient interface {
Version(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionResponse, error)
}
VersioningClient is the client API for Versioning service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewVersioningClient ¶
func NewVersioningClient(cc grpc.ClientConnInterface) VersioningClient
type VersioningServer ¶
type VersioningServer interface { Version(context.Context, *VersionRequest) (*VersionResponse, error) // contains filtered or unexported methods }
VersioningServer is the server API for Versioning service. All implementations must embed UnimplementedVersioningServer for forward compatibility
type WebhookCRUDClient ¶
type WebhookCRUDClient interface { TestWebhook(ctx context.Context, in *TestWebhookRequest, opts ...grpc.CallOption) (*TestWebhookResponse, error) VerifySignature(ctx context.Context, in *VerifySignatureRequest, opts ...grpc.CallOption) (*VerifySignatureResponse, error) SubscribeWebhook(ctx context.Context, in *SubscribeWebhookRequest, opts ...grpc.CallOption) (*SubscribeWebhookResponse, error) ListWebhook(ctx context.Context, in *ListWebhookRequest, opts ...grpc.CallOption) (*ListWebhookResponse, error) DeleteWebhook(ctx context.Context, in *DeleteWebhookRequest, opts ...grpc.CallOption) (*DeleteWebhookResponse, error) }
WebhookCRUDClient is the client API for WebhookCRUD service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewWebhookCRUDClient ¶
func NewWebhookCRUDClient(cc grpc.ClientConnInterface) WebhookCRUDClient
type WebhookCRUDServer ¶
type WebhookCRUDServer interface { TestWebhook(context.Context, *TestWebhookRequest) (*TestWebhookResponse, error) VerifySignature(context.Context, *VerifySignatureRequest) (*VerifySignatureResponse, error) SubscribeWebhook(context.Context, *SubscribeWebhookRequest) (*SubscribeWebhookResponse, error) ListWebhook(context.Context, *ListWebhookRequest) (*ListWebhookResponse, error) DeleteWebhook(context.Context, *DeleteWebhookRequest) (*DeleteWebhookResponse, error) // contains filtered or unexported methods }
WebhookCRUDServer is the server API for WebhookCRUD service. All implementations must embed UnimplementedWebhookCRUDServer for forward compatibility
type WebhookData ¶
type WebhookData struct { ApiKey string `protobuf:"bytes,1,opt,name=apiKey,proto3" json:"apiKey,omitempty"` SecretKey string `protobuf:"bytes,2,opt,name=secretKey,proto3" json:"secretKey,omitempty"` Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` CreatedAt string `protobuf:"bytes,4,opt,name=createdAt,proto3" json:"createdAt,omitempty"` UpdatedAt string `protobuf:"bytes,5,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"` // contains filtered or unexported fields }
func (*WebhookData) Descriptor
deprecated
func (*WebhookData) Descriptor() ([]byte, []int)
Deprecated: Use WebhookData.ProtoReflect.Descriptor instead.
func (*WebhookData) GetAddress ¶
func (x *WebhookData) GetAddress() string
func (*WebhookData) GetApiKey ¶
func (x *WebhookData) GetApiKey() string
func (*WebhookData) GetCreatedAt ¶
func (x *WebhookData) GetCreatedAt() string
func (*WebhookData) GetSecretKey ¶
func (x *WebhookData) GetSecretKey() string
func (*WebhookData) GetUpdatedAt ¶
func (x *WebhookData) GetUpdatedAt() string
func (*WebhookData) ProtoMessage ¶
func (*WebhookData) ProtoMessage()
func (*WebhookData) ProtoReflect ¶
func (x *WebhookData) ProtoReflect() protoreflect.Message
func (*WebhookData) Reset ¶
func (x *WebhookData) Reset()
func (*WebhookData) String ¶
func (x *WebhookData) String() string