pb

package
v0.0.0-...-44abded Latest Latest
Warning

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

Go to latest
Published: May 13, 2022 License: AGPL-3.0 Imports: 17 Imported by: 0

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

Constants

This section is empty.

Variables

View Source
var (
	ObjectCompressionAlgorithm_name = map[int32]string{
		0: "NONE",
		1: "GZIP",
	}
	ObjectCompressionAlgorithm_value = map[string]int32{
		"NONE": 0,
		"GZIP": 1,
	}
)

Enum value maps for ObjectCompressionAlgorithm.

View Source
var File_shrimping_proto protoreflect.FileDescriptor
View Source
var File_shritagram_proto protoreflect.FileDescriptor
View Source
var File_version_proto protoreflect.FileDescriptor
View Source
var File_webhook_crud_proto protoreflect.FileDescriptor
View Source
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)

View Source
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)

View Source
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)

View Source
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) Enum

func (ObjectCompressionAlgorithm) EnumDescriptor deprecated

func (ObjectCompressionAlgorithm) EnumDescriptor() ([]byte, []int)

Deprecated: Use ObjectCompressionAlgorithm.Descriptor instead.

func (ObjectCompressionAlgorithm) Number

func (ObjectCompressionAlgorithm) String

func (ObjectCompressionAlgorithm) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use RawObject.ProtoReflect.Descriptor instead.

func (*RawObject) GetItem

func (x *RawObject) GetItem() []byte

func (*RawObject) ProtoMessage

func (*RawObject) ProtoMessage()

func (*RawObject) ProtoReflect

func (x *RawObject) ProtoReflect() protoreflect.Message

func (*RawObject) Reset

func (x *RawObject) Reset()

func (*RawObject) String

func (x *RawObject) String() string

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 {
	Hashtags []string `protobuf:"bytes,1,rep,name=hashtags,proto3" json:"hashtags,omitempty"` // without `#`
	// 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) LookupItemByIDs

func (UnimplementedShrimpingServer) LookupItemBySales

type UnimplementedShritagramServer

type UnimplementedShritagramServer struct {
}

UnimplementedShritagramServer must be embedded to have forward compatible implementations.

func (UnimplementedShritagramServer) Callback

func (UnimplementedShritagramServer) Posts

func (UnimplementedShritagramServer) Profile

func (UnimplementedShritagramServer) TopSearch

type UnimplementedVersioningServer

type UnimplementedVersioningServer struct {
}

UnimplementedVersioningServer must be embedded to have forward compatible implementations.

func (UnimplementedVersioningServer) Version

type UnimplementedWebhookCRUDServer

type UnimplementedWebhookCRUDServer struct {
}

UnimplementedWebhookCRUDServer must be embedded to have forward compatible implementations.

func (UnimplementedWebhookCRUDServer) DeleteWebhook

func (UnimplementedWebhookCRUDServer) ListWebhook

func (UnimplementedWebhookCRUDServer) SubscribeWebhook

func (UnimplementedWebhookCRUDServer) TestWebhook

func (UnimplementedWebhookCRUDServer) VerifySignature

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.

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

Jump to

Keyboard shortcuts

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