types

package
v1.6.2-1 Latest Latest
Warning

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

Go to latest
Published: Nov 2, 2023 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source
const (
	EventTypeOpenBeam   = "open_beam"
	EventTypeUpdateBeam = "update_beam"
	EventTypeClaimBeam  = "claim_beam"

	AttributeKeyOpener  = "opener"
	AttributeKeyUpdater = "updater"
	AttributeKeyClaimer = "claimer"
)
View Source
const (
	// ModuleName defines the module name
	ModuleName = "beam"

	// ModuleVersion defines the current module version
	ModuleVersion = 3

	// StoreKey defines the primary module store key
	StoreKey = ModuleName

	// RouterKey is the message route for slashing
	RouterKey = ModuleName

	// QuerierRoute defines the module's query routing key
	QuerierRoute = ModuleName

	// MemStoreKey defines the in-memory store key
	MemStoreKey = "mem_capability"

	// MemStoreQueueSeparator Used to separate content in the by-height-open-beams queue
	MemStoreQueueSeparator = ","
)
View Source
const (
	TypeMsgOpenBeam   = "OpenBeam"
	TypeMsgUpdateBeam = "UpdateBeam"
	TypeMsgClaimBeam  = "ClaimBeam"
)
View Source
const (
	QueryFetchBeams = "fetch"
	QueryGetBeam    = "get"
)
View Source
const (
	BEAM_SCHEMA_REVIEW = "lum-network/review"
	BEAM_SCHEMA_REWARD = "lum-network/reward"
)

Variables

View Source
var (
	ErrInvalidLengthBeam        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBeam          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBeam = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrBeamNotFound                = errorsmod.Register(ModuleName, 1100, "Beam does not exists")
	ErrBeamNotAuthorized           = errorsmod.Register(ModuleName, 1101, "This beam does not belong to you")
	ErrBeamInvalidSecret           = errorsmod.Register(ModuleName, 1102, "Invalid secret provided")
	ErrBeamAlreadyExists           = errorsmod.Register(ModuleName, 1103, "This beam ID already exists")
	ErrBeamAutoCloseInThePast      = errorsmod.Register(ModuleName, 1104, "Cannot set autoclose height in the past")
	ErrBeamIdContainsForbiddenChar = errorsmod.Register(ModuleName, 1105, "This beam ID cannot contains comma")
)
View Source
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	BeamsPrefix            = []byte{0x01}
	OpenBeamsQueuePrefix   = []byte{0x02}
	ClosedBeamsQueuePrefix = []byte{0x03}

	OpenBeamsByBlockQueuePrefix = []byte{0x04}
)
View Source
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source
var BeamState_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "OPEN",
	2: "CANCELED",
	3: "CLOSED",
}
View Source
var BeamState_value = map[string]int32{
	"UNSPECIFIED": 0,
	"OPEN":        1,
	"CANCELED":    2,
	"CLOSED":      3,
}
View Source
var (
	DefaultBeamDenom = "ulum"
)
View Source
var (
	ModuleCdc = codec.NewAminoCodec(amino)
)

Functions

func BytesKeyToString added in v1.1.0

func BytesKeyToString(key []byte) string

func GetBeamKey

func GetBeamKey(beamID string) []byte

func GetClosedBeamQueueKey

func GetClosedBeamQueueKey(beamID string) []byte

func GetOpenBeamQueueKey

func GetOpenBeamQueueKey(beamID string) []byte

func GetOpenBeamsByBlockQueueKey added in v1.1.0

func GetOpenBeamsByBlockQueueKey(height int) []byte

func IntKeyToString added in v1.1.0

func IntKeyToString(key int) string

func RegisterCodec

func RegisterCodec(cdc *codec.LegacyAmino)

RegisterCodec Register the codec for the message passing

func RegisterInterfaces

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

RegisterInterfaces Register the implementations for the given codecs

func RegisterMsgServer added in v1.5.0

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler

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

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

func RegisterQueryHandlerClient

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

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

func RegisterQueryHandlerFromEndpoint

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

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

func RegisterQueryHandlerServer

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer 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 RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func SplitBeamKey

func SplitBeamKey(key []byte) []byte

func StringKeyToBytes added in v1.1.0

func StringKeyToBytes(key string) []byte

Types

type Beam

type Beam struct {
	CreatorAddress      string     `protobuf:"bytes,1,opt,name=creator_address,json=creatorAddress,proto3" json:"creator_address,omitempty"`
	Id                  string     `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Amount              types.Coin `protobuf:"bytes,3,opt,name=amount,proto3" json:"amount"`
	Status              BeamState  `protobuf:"varint,4,opt,name=status,proto3,enum=lum.network.beam.BeamState" json:"status,omitempty"`
	Secret              string     `protobuf:"bytes,5,opt,name=secret,proto3" json:"secret,omitempty"`
	ClaimAddress        string     `protobuf:"bytes,6,opt,name=claim_address,json=claimAddress,proto3" json:"claim_address,omitempty"`
	FundsWithdrawn      bool       `protobuf:"varint,7,opt,name=funds_withdrawn,json=fundsWithdrawn,proto3" json:"funds_withdrawn,omitempty"`
	Claimed             bool       `protobuf:"varint,8,opt,name=claimed,proto3" json:"claimed,omitempty"`
	CancelReason        string     `protobuf:"bytes,9,opt,name=cancel_reason,json=cancelReason,proto3" json:"cancel_reason,omitempty"`
	HideContent         bool       `protobuf:"varint,10,opt,name=hide_content,json=hideContent,proto3" json:"hide_content,omitempty"`
	Schema              string     `protobuf:"bytes,11,opt,name=schema,proto3" json:"schema,omitempty"`
	Data                *BeamData  `protobuf:"bytes,12,opt,name=data,proto3" json:"data,omitempty"`
	ClaimExpiresAtBlock int32      `protobuf:"varint,13,opt,name=claim_expires_at_block,json=claimExpiresAtBlock,proto3" json:"claim_expires_at_block,omitempty"`
	ClosesAtBlock       int32      `protobuf:"varint,14,opt,name=closes_at_block,json=closesAtBlock,proto3" json:"closes_at_block,omitempty"`
	CreatedAt           time.Time  `protobuf:"bytes,15,opt,name=created_at,json=createdAt,proto3,stdtime" json:"created_at"`
	ClosedAt            time.Time  `protobuf:"bytes,16,opt,name=closed_at,json=closedAt,proto3,stdtime" json:"closed_at"`
}

func (*Beam) Descriptor

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

func (*Beam) GetAmount

func (m *Beam) GetAmount() types.Coin

func (*Beam) GetCancelReason

func (m *Beam) GetCancelReason() string

func (*Beam) GetClaimAddress

func (m *Beam) GetClaimAddress() string

func (*Beam) GetClaimExpiresAtBlock

func (m *Beam) GetClaimExpiresAtBlock() int32

func (*Beam) GetClaimed

func (m *Beam) GetClaimed() bool

func (*Beam) GetClosedAt

func (m *Beam) GetClosedAt() time.Time

func (*Beam) GetClosesAtBlock

func (m *Beam) GetClosesAtBlock() int32

func (*Beam) GetCreatedAt

func (m *Beam) GetCreatedAt() time.Time

func (*Beam) GetCreatorAddress

func (m *Beam) GetCreatorAddress() string

func (*Beam) GetData

func (m *Beam) GetData() *BeamData

func (*Beam) GetFundsWithdrawn

func (m *Beam) GetFundsWithdrawn() bool

func (*Beam) GetHideContent

func (m *Beam) GetHideContent() bool

func (*Beam) GetId

func (m *Beam) GetId() string

func (*Beam) GetSchema

func (m *Beam) GetSchema() string

func (*Beam) GetSecret

func (m *Beam) GetSecret() string

func (*Beam) GetStatus

func (m *Beam) GetStatus() BeamState

func (*Beam) Marshal

func (m *Beam) Marshal() (dAtA []byte, err error)

func (*Beam) MarshalTo

func (m *Beam) MarshalTo(dAtA []byte) (int, error)

func (*Beam) MarshalToSizedBuffer

func (m *Beam) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Beam) ProtoMessage

func (*Beam) ProtoMessage()

func (*Beam) Reset

func (m *Beam) Reset()

func (*Beam) Size

func (m *Beam) Size() (n int)

func (*Beam) String

func (m *Beam) String() string

func (*Beam) Unmarshal

func (m *Beam) Unmarshal(dAtA []byte) error

func (*Beam) XXX_DiscardUnknown

func (m *Beam) XXX_DiscardUnknown()

func (*Beam) XXX_Marshal

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

func (*Beam) XXX_Merge

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

func (*Beam) XXX_Size

func (m *Beam) XXX_Size() int

func (*Beam) XXX_Unmarshal

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

type BeamData

type BeamData struct {
	Reward          *BeamReward          `protobuf:"bytes,1,opt,name=reward,proto3" json:"reward,omitempty"`
	Verifier        *BeamVerifier        `protobuf:"bytes,2,opt,name=verifier,proto3" json:"verifier,omitempty"`
	Reviewer        *BeamReviewer        `protobuf:"bytes,3,opt,name=reviewer,proto3" json:"reviewer,omitempty"`
	MerchantReview  *BeamMerchantReview  `protobuf:"bytes,4,opt,name=merchant_review,json=merchantReview,proto3" json:"merchant_review,omitempty"`
	ProductsReviews []*BeamProductReview `protobuf:"bytes,5,rep,name=products_reviews,json=productsReviews,proto3" json:"products_reviews,omitempty"`
}

func (*BeamData) Descriptor

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

func (*BeamData) GetMerchantReview

func (m *BeamData) GetMerchantReview() *BeamMerchantReview

func (*BeamData) GetProductsReviews

func (m *BeamData) GetProductsReviews() []*BeamProductReview

func (*BeamData) GetReviewer

func (m *BeamData) GetReviewer() *BeamReviewer

func (*BeamData) GetReward

func (m *BeamData) GetReward() *BeamReward

func (*BeamData) GetVerifier

func (m *BeamData) GetVerifier() *BeamVerifier

func (*BeamData) Marshal

func (m *BeamData) Marshal() (dAtA []byte, err error)

func (*BeamData) MarshalTo

func (m *BeamData) MarshalTo(dAtA []byte) (int, error)

func (*BeamData) MarshalToSizedBuffer

func (m *BeamData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BeamData) ProtoMessage

func (*BeamData) ProtoMessage()

func (*BeamData) Reset

func (m *BeamData) Reset()

func (*BeamData) Size

func (m *BeamData) Size() (n int)

func (*BeamData) String

func (m *BeamData) String() string

func (*BeamData) Unmarshal

func (m *BeamData) Unmarshal(dAtA []byte) error

func (*BeamData) XXX_DiscardUnknown

func (m *BeamData) XXX_DiscardUnknown()

func (*BeamData) XXX_Marshal

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

func (*BeamData) XXX_Merge

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

func (*BeamData) XXX_Size

func (m *BeamData) XXX_Size() int

func (*BeamData) XXX_Unmarshal

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

type BeamMedia

type BeamMedia struct {
	Mimetype     string `protobuf:"bytes,1,opt,name=mimetype,proto3" json:"mimetype,omitempty"`
	Url          string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	ThumbnailUrl string `protobuf:"bytes,3,opt,name=thumbnail_url,json=thumbnailUrl,proto3" json:"thumbnail_url,omitempty"`
}

func (*BeamMedia) Descriptor

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

func (*BeamMedia) GetMimetype

func (m *BeamMedia) GetMimetype() string

func (*BeamMedia) GetThumbnailUrl

func (m *BeamMedia) GetThumbnailUrl() string

func (*BeamMedia) GetUrl

func (m *BeamMedia) GetUrl() string

func (*BeamMedia) Marshal

func (m *BeamMedia) Marshal() (dAtA []byte, err error)

func (*BeamMedia) MarshalTo

func (m *BeamMedia) MarshalTo(dAtA []byte) (int, error)

func (*BeamMedia) MarshalToSizedBuffer

func (m *BeamMedia) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BeamMedia) ProtoMessage

func (*BeamMedia) ProtoMessage()

func (*BeamMedia) Reset

func (m *BeamMedia) Reset()

func (*BeamMedia) Size

func (m *BeamMedia) Size() (n int)

func (*BeamMedia) String

func (m *BeamMedia) String() string

func (*BeamMedia) Unmarshal

func (m *BeamMedia) Unmarshal(dAtA []byte) error

func (*BeamMedia) XXX_DiscardUnknown

func (m *BeamMedia) XXX_DiscardUnknown()

func (*BeamMedia) XXX_Marshal

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

func (*BeamMedia) XXX_Merge

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

func (*BeamMedia) XXX_Size

func (m *BeamMedia) XXX_Size() int

func (*BeamMedia) XXX_Unmarshal

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

type BeamMerchantReview

type BeamMerchantReview struct {
	OrderId          string                                        `protobuf:"bytes,1,opt,name=order_id,json=orderId,proto3" json:"order_id,omitempty"`
	ReviewId         string                                        `protobuf:"bytes,2,opt,name=review_id,json=reviewId,proto3" json:"review_id,omitempty"`
	MerchantUrl      string                                        `protobuf:"bytes,3,opt,name=merchant_url,json=merchantUrl,proto3" json:"merchant_url,omitempty"`
	RatingUrl        string                                        `protobuf:"bytes,4,opt,name=rating_url,json=ratingUrl,proto3" json:"rating_url,omitempty"`
	ReviewUrl        string                                        `protobuf:"bytes,5,opt,name=review_url,json=reviewUrl,proto3" json:"review_url,omitempty"`
	CollectionMethod string                                        `protobuf:"bytes,6,opt,name=collection_method,json=collectionMethod,proto3" json:"collection_method,omitempty"`
	Timestamp        string                                        `protobuf:"bytes,7,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Ratings          *BeamMerchantReview_BeamMerchantReviewRating  `protobuf:"bytes,8,opt,name=ratings,proto3" json:"ratings,omitempty"`
	Title            string                                        `protobuf:"bytes,9,opt,name=title,proto3" json:"title,omitempty"`
	Content          *BeamMerchantReview_BeamMerchantReviewContent `protobuf:"bytes,10,opt,name=content,proto3" json:"content,omitempty"`
}

func (*BeamMerchantReview) Descriptor

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

func (*BeamMerchantReview) GetCollectionMethod

func (m *BeamMerchantReview) GetCollectionMethod() string

func (*BeamMerchantReview) GetContent

func (*BeamMerchantReview) GetMerchantUrl

func (m *BeamMerchantReview) GetMerchantUrl() string

func (*BeamMerchantReview) GetOrderId

func (m *BeamMerchantReview) GetOrderId() string

func (*BeamMerchantReview) GetRatingUrl

func (m *BeamMerchantReview) GetRatingUrl() string

func (*BeamMerchantReview) GetRatings

func (*BeamMerchantReview) GetReviewId

func (m *BeamMerchantReview) GetReviewId() string

func (*BeamMerchantReview) GetReviewUrl

func (m *BeamMerchantReview) GetReviewUrl() string

func (*BeamMerchantReview) GetTimestamp

func (m *BeamMerchantReview) GetTimestamp() string

func (*BeamMerchantReview) GetTitle

func (m *BeamMerchantReview) GetTitle() string

func (*BeamMerchantReview) Marshal

func (m *BeamMerchantReview) Marshal() (dAtA []byte, err error)

func (*BeamMerchantReview) MarshalTo

func (m *BeamMerchantReview) MarshalTo(dAtA []byte) (int, error)

func (*BeamMerchantReview) MarshalToSizedBuffer

func (m *BeamMerchantReview) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BeamMerchantReview) ProtoMessage

func (*BeamMerchantReview) ProtoMessage()

func (*BeamMerchantReview) Reset

func (m *BeamMerchantReview) Reset()

func (*BeamMerchantReview) Size

func (m *BeamMerchantReview) Size() (n int)

func (*BeamMerchantReview) String

func (m *BeamMerchantReview) String() string

func (*BeamMerchantReview) Unmarshal

func (m *BeamMerchantReview) Unmarshal(dAtA []byte) error

func (*BeamMerchantReview) XXX_DiscardUnknown

func (m *BeamMerchantReview) XXX_DiscardUnknown()

func (*BeamMerchantReview) XXX_Marshal

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

func (*BeamMerchantReview) XXX_Merge

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

func (*BeamMerchantReview) XXX_Size

func (m *BeamMerchantReview) XXX_Size() int

func (*BeamMerchantReview) XXX_Unmarshal

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

type BeamMerchantReview_BeamMerchantReviewContent

type BeamMerchantReview_BeamMerchantReviewContent struct {
	Overall         string `protobuf:"bytes,1,opt,name=overall,proto3" json:"overall,omitempty"`
	CustomerService string `protobuf:"bytes,2,opt,name=customer_service,json=customerService,proto3" json:"customer_service,omitempty"`
}

func (*BeamMerchantReview_BeamMerchantReviewContent) Descriptor

func (*BeamMerchantReview_BeamMerchantReviewContent) GetCustomerService

func (m *BeamMerchantReview_BeamMerchantReviewContent) GetCustomerService() string

func (*BeamMerchantReview_BeamMerchantReviewContent) GetOverall

func (*BeamMerchantReview_BeamMerchantReviewContent) Marshal

func (m *BeamMerchantReview_BeamMerchantReviewContent) Marshal() (dAtA []byte, err error)

func (*BeamMerchantReview_BeamMerchantReviewContent) MarshalTo

func (*BeamMerchantReview_BeamMerchantReviewContent) MarshalToSizedBuffer

func (m *BeamMerchantReview_BeamMerchantReviewContent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BeamMerchantReview_BeamMerchantReviewContent) ProtoMessage

func (*BeamMerchantReview_BeamMerchantReviewContent) Reset

func (*BeamMerchantReview_BeamMerchantReviewContent) Size

func (*BeamMerchantReview_BeamMerchantReviewContent) String

func (*BeamMerchantReview_BeamMerchantReviewContent) Unmarshal

func (*BeamMerchantReview_BeamMerchantReviewContent) XXX_DiscardUnknown

func (m *BeamMerchantReview_BeamMerchantReviewContent) XXX_DiscardUnknown()

func (*BeamMerchantReview_BeamMerchantReviewContent) XXX_Marshal

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

func (*BeamMerchantReview_BeamMerchantReviewContent) XXX_Merge

func (*BeamMerchantReview_BeamMerchantReviewContent) XXX_Size

func (*BeamMerchantReview_BeamMerchantReviewContent) XXX_Unmarshal

type BeamMerchantReview_BeamMerchantReviewRating

type BeamMerchantReview_BeamMerchantReviewRating struct {
	Overall         float32 `protobuf:"fixed32,1,opt,name=overall,proto3" json:"overall,omitempty"`
	CustomerService float32 `protobuf:"fixed32,2,opt,name=customer_service,json=customerService,proto3" json:"customer_service,omitempty"`
	Nps             float32 `protobuf:"fixed32,3,opt,name=nps,proto3" json:"nps,omitempty"`
}

func (*BeamMerchantReview_BeamMerchantReviewRating) Descriptor

func (*BeamMerchantReview_BeamMerchantReviewRating) GetCustomerService

func (m *BeamMerchantReview_BeamMerchantReviewRating) GetCustomerService() float32

func (*BeamMerchantReview_BeamMerchantReviewRating) GetNps

func (*BeamMerchantReview_BeamMerchantReviewRating) GetOverall

func (*BeamMerchantReview_BeamMerchantReviewRating) Marshal

func (m *BeamMerchantReview_BeamMerchantReviewRating) Marshal() (dAtA []byte, err error)

func (*BeamMerchantReview_BeamMerchantReviewRating) MarshalTo

func (*BeamMerchantReview_BeamMerchantReviewRating) MarshalToSizedBuffer

func (m *BeamMerchantReview_BeamMerchantReviewRating) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BeamMerchantReview_BeamMerchantReviewRating) ProtoMessage

func (*BeamMerchantReview_BeamMerchantReviewRating) Reset

func (*BeamMerchantReview_BeamMerchantReviewRating) Size

func (*BeamMerchantReview_BeamMerchantReviewRating) String

func (*BeamMerchantReview_BeamMerchantReviewRating) Unmarshal

func (*BeamMerchantReview_BeamMerchantReviewRating) XXX_DiscardUnknown

func (m *BeamMerchantReview_BeamMerchantReviewRating) XXX_DiscardUnknown()

func (*BeamMerchantReview_BeamMerchantReviewRating) XXX_Marshal

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

func (*BeamMerchantReview_BeamMerchantReviewRating) XXX_Merge

func (*BeamMerchantReview_BeamMerchantReviewRating) XXX_Size

func (*BeamMerchantReview_BeamMerchantReviewRating) XXX_Unmarshal

type BeamProductReview

type BeamProductReview struct {
	OrderId          string                                      `protobuf:"bytes,1,opt,name=order_id,json=orderId,proto3" json:"order_id,omitempty"`
	ReviewId         string                                      `protobuf:"bytes,2,opt,name=review_id,json=reviewId,proto3" json:"review_id,omitempty"`
	RatingUrl        string                                      `protobuf:"bytes,3,opt,name=rating_url,json=ratingUrl,proto3" json:"rating_url,omitempty"`
	ReviewUrl        string                                      `protobuf:"bytes,4,opt,name=review_url,json=reviewUrl,proto3" json:"review_url,omitempty"`
	CollectionMethod string                                      `protobuf:"bytes,5,opt,name=collection_method,json=collectionMethod,proto3" json:"collection_method,omitempty"`
	Timestamp        string                                      `protobuf:"bytes,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Ratings          *BeamProductReview_BeamProductReviewRating  `protobuf:"bytes,7,opt,name=ratings,proto3" json:"ratings,omitempty"`
	Title            string                                      `protobuf:"bytes,8,opt,name=title,proto3" json:"title,omitempty"`
	Content          *BeamProductReview_BeamProductReviewContent `protobuf:"bytes,9,opt,name=content,proto3" json:"content,omitempty"`
	Medias           []*BeamMedia                                `protobuf:"bytes,10,rep,name=medias,proto3" json:"medias,omitempty"`
	Products         []*BeamProductReview_BeamProduct            `protobuf:"bytes,11,rep,name=products,proto3" json:"products,omitempty"`
}

func (*BeamProductReview) Descriptor

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

func (*BeamProductReview) GetCollectionMethod

func (m *BeamProductReview) GetCollectionMethod() string

func (*BeamProductReview) GetContent

func (*BeamProductReview) GetMedias

func (m *BeamProductReview) GetMedias() []*BeamMedia

func (*BeamProductReview) GetOrderId

func (m *BeamProductReview) GetOrderId() string

func (*BeamProductReview) GetProducts

func (*BeamProductReview) GetRatingUrl

func (m *BeamProductReview) GetRatingUrl() string

func (*BeamProductReview) GetRatings

func (*BeamProductReview) GetReviewId

func (m *BeamProductReview) GetReviewId() string

func (*BeamProductReview) GetReviewUrl

func (m *BeamProductReview) GetReviewUrl() string

func (*BeamProductReview) GetTimestamp

func (m *BeamProductReview) GetTimestamp() string

func (*BeamProductReview) GetTitle

func (m *BeamProductReview) GetTitle() string

func (*BeamProductReview) Marshal

func (m *BeamProductReview) Marshal() (dAtA []byte, err error)

func (*BeamProductReview) MarshalTo

func (m *BeamProductReview) MarshalTo(dAtA []byte) (int, error)

func (*BeamProductReview) MarshalToSizedBuffer

func (m *BeamProductReview) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BeamProductReview) ProtoMessage

func (*BeamProductReview) ProtoMessage()

func (*BeamProductReview) Reset

func (m *BeamProductReview) Reset()

func (*BeamProductReview) Size

func (m *BeamProductReview) Size() (n int)

func (*BeamProductReview) String

func (m *BeamProductReview) String() string

func (*BeamProductReview) Unmarshal

func (m *BeamProductReview) Unmarshal(dAtA []byte) error

func (*BeamProductReview) XXX_DiscardUnknown

func (m *BeamProductReview) XXX_DiscardUnknown()

func (*BeamProductReview) XXX_Marshal

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

func (*BeamProductReview) XXX_Merge

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

func (*BeamProductReview) XXX_Size

func (m *BeamProductReview) XXX_Size() int

func (*BeamProductReview) XXX_Unmarshal

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

type BeamProductReview_BeamProduct

type BeamProductReview_BeamProduct struct {
	Name string                                        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Url  string                                        `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Urls []string                                      `protobuf:"bytes,3,rep,name=urls,proto3" json:"urls,omitempty"`
	Ids  *BeamProductReview_BeamProduct_BeamProductIds `protobuf:"bytes,4,opt,name=ids,proto3" json:"ids,omitempty"`
}

func (*BeamProductReview_BeamProduct) Descriptor

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

func (*BeamProductReview_BeamProduct) GetIds

func (*BeamProductReview_BeamProduct) GetName

func (*BeamProductReview_BeamProduct) GetUrl

func (*BeamProductReview_BeamProduct) GetUrls

func (m *BeamProductReview_BeamProduct) GetUrls() []string

func (*BeamProductReview_BeamProduct) Marshal

func (m *BeamProductReview_BeamProduct) Marshal() (dAtA []byte, err error)

func (*BeamProductReview_BeamProduct) MarshalTo

func (m *BeamProductReview_BeamProduct) MarshalTo(dAtA []byte) (int, error)

func (*BeamProductReview_BeamProduct) MarshalToSizedBuffer

func (m *BeamProductReview_BeamProduct) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BeamProductReview_BeamProduct) ProtoMessage

func (*BeamProductReview_BeamProduct) ProtoMessage()

func (*BeamProductReview_BeamProduct) Reset

func (m *BeamProductReview_BeamProduct) Reset()

func (*BeamProductReview_BeamProduct) Size

func (m *BeamProductReview_BeamProduct) Size() (n int)

func (*BeamProductReview_BeamProduct) String

func (*BeamProductReview_BeamProduct) Unmarshal

func (m *BeamProductReview_BeamProduct) Unmarshal(dAtA []byte) error

func (*BeamProductReview_BeamProduct) XXX_DiscardUnknown

func (m *BeamProductReview_BeamProduct) XXX_DiscardUnknown()

func (*BeamProductReview_BeamProduct) XXX_Marshal

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

func (*BeamProductReview_BeamProduct) XXX_Merge

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

func (*BeamProductReview_BeamProduct) XXX_Size

func (m *BeamProductReview_BeamProduct) XXX_Size() int

func (*BeamProductReview_BeamProduct) XXX_Unmarshal

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

type BeamProductReview_BeamProductReviewContent

type BeamProductReview_BeamProductReviewContent struct {
	Overall string `protobuf:"bytes,1,opt,name=overall,proto3" json:"overall,omitempty"`
	Pros    string `protobuf:"bytes,2,opt,name=pros,proto3" json:"pros,omitempty"`
	Cons    string `protobuf:"bytes,3,opt,name=cons,proto3" json:"cons,omitempty"`
}

func (*BeamProductReview_BeamProductReviewContent) Descriptor

func (*BeamProductReview_BeamProductReviewContent) GetCons

func (*BeamProductReview_BeamProductReviewContent) GetOverall

func (*BeamProductReview_BeamProductReviewContent) GetPros

func (*BeamProductReview_BeamProductReviewContent) Marshal

func (m *BeamProductReview_BeamProductReviewContent) Marshal() (dAtA []byte, err error)

func (*BeamProductReview_BeamProductReviewContent) MarshalTo

func (m *BeamProductReview_BeamProductReviewContent) MarshalTo(dAtA []byte) (int, error)

func (*BeamProductReview_BeamProductReviewContent) MarshalToSizedBuffer

func (m *BeamProductReview_BeamProductReviewContent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BeamProductReview_BeamProductReviewContent) ProtoMessage

func (*BeamProductReview_BeamProductReviewContent) Reset

func (*BeamProductReview_BeamProductReviewContent) Size

func (*BeamProductReview_BeamProductReviewContent) String

func (*BeamProductReview_BeamProductReviewContent) Unmarshal

func (*BeamProductReview_BeamProductReviewContent) XXX_DiscardUnknown

func (m *BeamProductReview_BeamProductReviewContent) XXX_DiscardUnknown()

func (*BeamProductReview_BeamProductReviewContent) XXX_Marshal

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

func (*BeamProductReview_BeamProductReviewContent) XXX_Merge

func (*BeamProductReview_BeamProductReviewContent) XXX_Size

func (*BeamProductReview_BeamProductReviewContent) XXX_Unmarshal

type BeamProductReview_BeamProductReviewRating

type BeamProductReview_BeamProductReviewRating struct {
	Overall float32 `protobuf:"fixed32,1,opt,name=overall,proto3" json:"overall,omitempty"`
	Quality float32 `protobuf:"fixed32,2,opt,name=quality,proto3" json:"quality,omitempty"`
}

func (*BeamProductReview_BeamProductReviewRating) Descriptor

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

func (*BeamProductReview_BeamProductReviewRating) GetOverall

func (*BeamProductReview_BeamProductReviewRating) GetQuality

func (*BeamProductReview_BeamProductReviewRating) Marshal

func (m *BeamProductReview_BeamProductReviewRating) Marshal() (dAtA []byte, err error)

func (*BeamProductReview_BeamProductReviewRating) MarshalTo

func (m *BeamProductReview_BeamProductReviewRating) MarshalTo(dAtA []byte) (int, error)

func (*BeamProductReview_BeamProductReviewRating) MarshalToSizedBuffer

func (m *BeamProductReview_BeamProductReviewRating) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BeamProductReview_BeamProductReviewRating) ProtoMessage

func (*BeamProductReview_BeamProductReviewRating) Reset

func (*BeamProductReview_BeamProductReviewRating) Size

func (*BeamProductReview_BeamProductReviewRating) String

func (*BeamProductReview_BeamProductReviewRating) Unmarshal

func (*BeamProductReview_BeamProductReviewRating) XXX_DiscardUnknown

func (m *BeamProductReview_BeamProductReviewRating) XXX_DiscardUnknown()

func (*BeamProductReview_BeamProductReviewRating) XXX_Marshal

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

func (*BeamProductReview_BeamProductReviewRating) XXX_Merge

func (*BeamProductReview_BeamProductReviewRating) XXX_Size

func (*BeamProductReview_BeamProductReviewRating) XXX_Unmarshal

type BeamProductReview_BeamProduct_BeamProductIds

type BeamProductReview_BeamProduct_BeamProductIds struct {
	Gtins []string `protobuf:"bytes,1,rep,name=gtins,proto3" json:"gtins,omitempty"`
	Mpns  []string `protobuf:"bytes,2,rep,name=mpns,proto3" json:"mpns,omitempty"`
	Skus  []string `protobuf:"bytes,3,rep,name=skus,proto3" json:"skus,omitempty"`
	Asins []string `protobuf:"bytes,4,rep,name=asins,proto3" json:"asins,omitempty"`
}

func (*BeamProductReview_BeamProduct_BeamProductIds) Descriptor

func (*BeamProductReview_BeamProduct_BeamProductIds) GetAsins

func (*BeamProductReview_BeamProduct_BeamProductIds) GetGtins

func (*BeamProductReview_BeamProduct_BeamProductIds) GetMpns

func (*BeamProductReview_BeamProduct_BeamProductIds) GetSkus

func (*BeamProductReview_BeamProduct_BeamProductIds) Marshal

func (m *BeamProductReview_BeamProduct_BeamProductIds) Marshal() (dAtA []byte, err error)

func (*BeamProductReview_BeamProduct_BeamProductIds) MarshalTo

func (*BeamProductReview_BeamProduct_BeamProductIds) MarshalToSizedBuffer

func (m *BeamProductReview_BeamProduct_BeamProductIds) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BeamProductReview_BeamProduct_BeamProductIds) ProtoMessage

func (*BeamProductReview_BeamProduct_BeamProductIds) Reset

func (*BeamProductReview_BeamProduct_BeamProductIds) Size

func (*BeamProductReview_BeamProduct_BeamProductIds) String

func (*BeamProductReview_BeamProduct_BeamProductIds) Unmarshal

func (*BeamProductReview_BeamProduct_BeamProductIds) XXX_DiscardUnknown

func (m *BeamProductReview_BeamProduct_BeamProductIds) XXX_DiscardUnknown()

func (*BeamProductReview_BeamProduct_BeamProductIds) XXX_Marshal

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

func (*BeamProductReview_BeamProduct_BeamProductIds) XXX_Merge

func (*BeamProductReview_BeamProduct_BeamProductIds) XXX_Size

func (*BeamProductReview_BeamProduct_BeamProductIds) XXX_Unmarshal

type BeamReviewer

type BeamReviewer struct {
	ReviewerId  string `protobuf:"bytes,1,opt,name=reviewer_id,json=reviewerId,proto3" json:"reviewer_id,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	IsAnonymous bool   `protobuf:"varint,3,opt,name=is_anonymous,json=isAnonymous,proto3" json:"is_anonymous,omitempty"`
}

func (*BeamReviewer) Descriptor

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

func (*BeamReviewer) GetIsAnonymous

func (m *BeamReviewer) GetIsAnonymous() bool

func (*BeamReviewer) GetName

func (m *BeamReviewer) GetName() string

func (*BeamReviewer) GetReviewerId

func (m *BeamReviewer) GetReviewerId() string

func (*BeamReviewer) Marshal

func (m *BeamReviewer) Marshal() (dAtA []byte, err error)

func (*BeamReviewer) MarshalTo

func (m *BeamReviewer) MarshalTo(dAtA []byte) (int, error)

func (*BeamReviewer) MarshalToSizedBuffer

func (m *BeamReviewer) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BeamReviewer) ProtoMessage

func (*BeamReviewer) ProtoMessage()

func (*BeamReviewer) Reset

func (m *BeamReviewer) Reset()

func (*BeamReviewer) Size

func (m *BeamReviewer) Size() (n int)

func (*BeamReviewer) String

func (m *BeamReviewer) String() string

func (*BeamReviewer) Unmarshal

func (m *BeamReviewer) Unmarshal(dAtA []byte) error

func (*BeamReviewer) XXX_DiscardUnknown

func (m *BeamReviewer) XXX_DiscardUnknown()

func (*BeamReviewer) XXX_Marshal

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

func (*BeamReviewer) XXX_Merge

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

func (*BeamReviewer) XXX_Size

func (m *BeamReviewer) XXX_Size() int

func (*BeamReviewer) XXX_Unmarshal

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

type BeamReward

type BeamReward struct {
	Trigger   string                          `protobuf:"bytes,1,opt,name=trigger,proto3" json:"trigger,omitempty"`
	Amount    float32                         `protobuf:"fixed32,2,opt,name=amount,proto3" json:"amount,omitempty"`
	MaxAmount float32                         `protobuf:"fixed32,3,opt,name=max_amount,json=maxAmount,proto3" json:"max_amount,omitempty"`
	Currency  string                          `protobuf:"bytes,4,opt,name=currency,proto3" json:"currency,omitempty"`
	Status    string                          `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	Details   []*BeamReward_BeamRewardDetails `protobuf:"bytes,6,rep,name=details,proto3" json:"details,omitempty"`
}

func (*BeamReward) Descriptor

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

func (*BeamReward) GetAmount

func (m *BeamReward) GetAmount() float32

func (*BeamReward) GetCurrency

func (m *BeamReward) GetCurrency() string

func (*BeamReward) GetDetails

func (m *BeamReward) GetDetails() []*BeamReward_BeamRewardDetails

func (*BeamReward) GetMaxAmount

func (m *BeamReward) GetMaxAmount() float32

func (*BeamReward) GetStatus

func (m *BeamReward) GetStatus() string

func (*BeamReward) GetTrigger

func (m *BeamReward) GetTrigger() string

func (*BeamReward) Marshal

func (m *BeamReward) Marshal() (dAtA []byte, err error)

func (*BeamReward) MarshalTo

func (m *BeamReward) MarshalTo(dAtA []byte) (int, error)

func (*BeamReward) MarshalToSizedBuffer

func (m *BeamReward) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BeamReward) ProtoMessage

func (*BeamReward) ProtoMessage()

func (*BeamReward) Reset

func (m *BeamReward) Reset()

func (*BeamReward) Size

func (m *BeamReward) Size() (n int)

func (*BeamReward) String

func (m *BeamReward) String() string

func (*BeamReward) Unmarshal

func (m *BeamReward) Unmarshal(dAtA []byte) error

func (*BeamReward) XXX_DiscardUnknown

func (m *BeamReward) XXX_DiscardUnknown()

func (*BeamReward) XXX_Marshal

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

func (*BeamReward) XXX_Merge

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

func (*BeamReward) XXX_Size

func (m *BeamReward) XXX_Size() int

func (*BeamReward) XXX_Unmarshal

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

type BeamReward_BeamRewardDetails

type BeamReward_BeamRewardDetails struct {
	Type      string  `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Amount    float32 `protobuf:"fixed32,2,opt,name=amount,proto3" json:"amount,omitempty"`
	MaxAmount float32 `protobuf:"fixed32,3,opt,name=max_amount,json=maxAmount,proto3" json:"max_amount,omitempty"`
	Status    string  `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
}

func (*BeamReward_BeamRewardDetails) Descriptor

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

func (*BeamReward_BeamRewardDetails) GetAmount

func (m *BeamReward_BeamRewardDetails) GetAmount() float32

func (*BeamReward_BeamRewardDetails) GetMaxAmount

func (m *BeamReward_BeamRewardDetails) GetMaxAmount() float32

func (*BeamReward_BeamRewardDetails) GetStatus

func (m *BeamReward_BeamRewardDetails) GetStatus() string

func (*BeamReward_BeamRewardDetails) GetType

func (m *BeamReward_BeamRewardDetails) GetType() string

func (*BeamReward_BeamRewardDetails) Marshal

func (m *BeamReward_BeamRewardDetails) Marshal() (dAtA []byte, err error)

func (*BeamReward_BeamRewardDetails) MarshalTo

func (m *BeamReward_BeamRewardDetails) MarshalTo(dAtA []byte) (int, error)

func (*BeamReward_BeamRewardDetails) MarshalToSizedBuffer

func (m *BeamReward_BeamRewardDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BeamReward_BeamRewardDetails) ProtoMessage

func (*BeamReward_BeamRewardDetails) ProtoMessage()

func (*BeamReward_BeamRewardDetails) Reset

func (m *BeamReward_BeamRewardDetails) Reset()

func (*BeamReward_BeamRewardDetails) Size

func (m *BeamReward_BeamRewardDetails) Size() (n int)

func (*BeamReward_BeamRewardDetails) String

func (*BeamReward_BeamRewardDetails) Unmarshal

func (m *BeamReward_BeamRewardDetails) Unmarshal(dAtA []byte) error

func (*BeamReward_BeamRewardDetails) XXX_DiscardUnknown

func (m *BeamReward_BeamRewardDetails) XXX_DiscardUnknown()

func (*BeamReward_BeamRewardDetails) XXX_Marshal

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

func (*BeamReward_BeamRewardDetails) XXX_Merge

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

func (*BeamReward_BeamRewardDetails) XXX_Size

func (m *BeamReward_BeamRewardDetails) XXX_Size() int

func (*BeamReward_BeamRewardDetails) XXX_Unmarshal

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

type BeamState

type BeamState int32
const (
	BeamState_StateUnspecified BeamState = 0
	BeamState_StateOpen        BeamState = 1
	BeamState_StateCanceled    BeamState = 2
	BeamState_StateClosed      BeamState = 3
)

func (BeamState) EnumDescriptor

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

func (BeamState) String

func (x BeamState) String() string

type BeamVerifier

type BeamVerifier struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Url       string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Signature string `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
}

func (*BeamVerifier) Descriptor

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

func (*BeamVerifier) GetName

func (m *BeamVerifier) GetName() string

func (*BeamVerifier) GetSignature

func (m *BeamVerifier) GetSignature() string

func (*BeamVerifier) GetUrl

func (m *BeamVerifier) GetUrl() string

func (*BeamVerifier) Marshal

func (m *BeamVerifier) Marshal() (dAtA []byte, err error)

func (*BeamVerifier) MarshalTo

func (m *BeamVerifier) MarshalTo(dAtA []byte) (int, error)

func (*BeamVerifier) MarshalToSizedBuffer

func (m *BeamVerifier) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BeamVerifier) ProtoMessage

func (*BeamVerifier) ProtoMessage()

func (*BeamVerifier) Reset

func (m *BeamVerifier) Reset()

func (*BeamVerifier) Size

func (m *BeamVerifier) Size() (n int)

func (*BeamVerifier) String

func (m *BeamVerifier) String() string

func (*BeamVerifier) Unmarshal

func (m *BeamVerifier) Unmarshal(dAtA []byte) error

func (*BeamVerifier) XXX_DiscardUnknown

func (m *BeamVerifier) XXX_DiscardUnknown()

func (*BeamVerifier) XXX_Marshal

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

func (*BeamVerifier) XXX_Merge

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

func (*BeamVerifier) XXX_Size

func (m *BeamVerifier) XXX_Size() int

func (*BeamVerifier) XXX_Unmarshal

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

type GenesisState

type GenesisState struct {
	ModuleAccountBalance types.Coin `` /* 143-byte string literal not displayed */
	Beams                []*Beam    `protobuf:"bytes,2,rep,name=beams,proto3" json:"beams,omitempty"`
}

GenesisState defines the capability module's genesis state.

func DefaultGenesis

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default Capability genesis state

func (*GenesisState) Descriptor

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

func (*GenesisState) GetBeams added in v1.0.3

func (m *GenesisState) GetBeams() []*Beam

func (*GenesisState) GetModuleAccountBalance added in v1.0.3

func (m *GenesisState) GetModuleAccountBalance() types.Coin

func (*GenesisState) Marshal

func (m *GenesisState) Marshal() (dAtA []byte, err error)

func (*GenesisState) MarshalTo

func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)

func (*GenesisState) MarshalToSizedBuffer

func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenesisState) ProtoMessage

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset

func (m *GenesisState) Reset()

func (*GenesisState) Size

func (m *GenesisState) Size() (n int)

func (*GenesisState) String

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal

func (m *GenesisState) Unmarshal(dAtA []byte) error

func (GenesisState) Validate

func (gs GenesisState) Validate() error

Validate performs basic genesis state validation returning an error upon any failure.

func (*GenesisState) XXX_DiscardUnknown

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal

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

func (*GenesisState) XXX_Merge

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

func (*GenesisState) XXX_Size

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal

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

type MsgClaimBeam

type MsgClaimBeam struct {
	Id             string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ClaimerAddress string `protobuf:"bytes,2,opt,name=claimer_address,json=claimerAddress,proto3" json:"claimer_address,omitempty"`
	Secret         string `protobuf:"bytes,3,opt,name=secret,proto3" json:"secret,omitempty"`
}

func NewMsgClaimBeam

func NewMsgClaimBeam(claimer string, id string, secret string) *MsgClaimBeam

NewMsgClaimBeam Build a MsgClaimBeam instance

func (*MsgClaimBeam) Descriptor

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

func (*MsgClaimBeam) GetClaimerAddress

func (m *MsgClaimBeam) GetClaimerAddress() string

func (*MsgClaimBeam) GetId

func (m *MsgClaimBeam) GetId() string

func (*MsgClaimBeam) GetSecret

func (m *MsgClaimBeam) GetSecret() string

func (*MsgClaimBeam) GetSignBytes

func (msg *MsgClaimBeam) GetSignBytes() []byte

GetSignBytes Return the generated bytes from the signature

func (*MsgClaimBeam) GetSigners

func (msg *MsgClaimBeam) GetSigners() []sdk.AccAddress

GetSigners Return the list of signers for the given message

func (*MsgClaimBeam) Marshal

func (m *MsgClaimBeam) Marshal() (dAtA []byte, err error)

func (*MsgClaimBeam) MarshalTo

func (m *MsgClaimBeam) MarshalTo(dAtA []byte) (int, error)

func (*MsgClaimBeam) MarshalToSizedBuffer

func (m *MsgClaimBeam) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgClaimBeam) ProtoMessage

func (*MsgClaimBeam) ProtoMessage()

func (*MsgClaimBeam) Reset

func (m *MsgClaimBeam) Reset()

func (MsgClaimBeam) Route

func (msg MsgClaimBeam) Route() string

Route dunno

func (*MsgClaimBeam) Size

func (m *MsgClaimBeam) Size() (n int)

func (*MsgClaimBeam) String

func (m *MsgClaimBeam) String() string

func (MsgClaimBeam) Type

func (msg MsgClaimBeam) Type() string

Type Return the message type

func (*MsgClaimBeam) Unmarshal

func (m *MsgClaimBeam) Unmarshal(dAtA []byte) error

func (*MsgClaimBeam) ValidateBasic

func (msg *MsgClaimBeam) ValidateBasic() error

ValidateBasic Validate the msg payload

func (*MsgClaimBeam) XXX_DiscardUnknown

func (m *MsgClaimBeam) XXX_DiscardUnknown()

func (*MsgClaimBeam) XXX_Marshal

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

func (*MsgClaimBeam) XXX_Merge

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

func (*MsgClaimBeam) XXX_Size

func (m *MsgClaimBeam) XXX_Size() int

func (*MsgClaimBeam) XXX_Unmarshal

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

type MsgClaimBeamResponse added in v1.5.0

type MsgClaimBeamResponse struct {
}

func (*MsgClaimBeamResponse) Descriptor added in v1.5.0

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

func (*MsgClaimBeamResponse) Marshal added in v1.5.0

func (m *MsgClaimBeamResponse) Marshal() (dAtA []byte, err error)

func (*MsgClaimBeamResponse) MarshalTo added in v1.5.0

func (m *MsgClaimBeamResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgClaimBeamResponse) MarshalToSizedBuffer added in v1.5.0

func (m *MsgClaimBeamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgClaimBeamResponse) ProtoMessage added in v1.5.0

func (*MsgClaimBeamResponse) ProtoMessage()

func (*MsgClaimBeamResponse) Reset added in v1.5.0

func (m *MsgClaimBeamResponse) Reset()

func (*MsgClaimBeamResponse) Size added in v1.5.0

func (m *MsgClaimBeamResponse) Size() (n int)

func (*MsgClaimBeamResponse) String added in v1.5.0

func (m *MsgClaimBeamResponse) String() string

func (*MsgClaimBeamResponse) Unmarshal added in v1.5.0

func (m *MsgClaimBeamResponse) Unmarshal(dAtA []byte) error

func (*MsgClaimBeamResponse) XXX_DiscardUnknown added in v1.5.0

func (m *MsgClaimBeamResponse) XXX_DiscardUnknown()

func (*MsgClaimBeamResponse) XXX_Marshal added in v1.5.0

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

func (*MsgClaimBeamResponse) XXX_Merge added in v1.5.0

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

func (*MsgClaimBeamResponse) XXX_Size added in v1.5.0

func (m *MsgClaimBeamResponse) XXX_Size() int

func (*MsgClaimBeamResponse) XXX_Unmarshal added in v1.5.0

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

type MsgClient added in v1.5.0

type MsgClient interface {
	OpenBeam(ctx context.Context, in *MsgOpenBeam, opts ...grpc.CallOption) (*MsgOpenBeamResponse, error)
	UpdateBeam(ctx context.Context, in *MsgUpdateBeam, opts ...grpc.CallOption) (*MsgUpdateBeamResponse, error)
	ClaimBeam(ctx context.Context, in *MsgClaimBeam, opts ...grpc.CallOption) (*MsgClaimBeamResponse, error)
}

MsgClient is the client API for Msg service.

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

func NewMsgClient added in v1.5.0

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgOpenBeam

type MsgOpenBeam struct {
	Id                  string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CreatorAddress      string      `protobuf:"bytes,2,opt,name=creator_address,json=creatorAddress,proto3" json:"creator_address,omitempty"`
	Secret              string      `protobuf:"bytes,3,opt,name=secret,proto3" json:"secret,omitempty"`
	Amount              *types.Coin `protobuf:"bytes,4,opt,name=amount,proto3" json:"amount,omitempty"`
	Schema              string      `protobuf:"bytes,5,opt,name=schema,proto3" json:"schema,omitempty"`
	Data                *BeamData   `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"`
	ClaimAddress        string      `protobuf:"bytes,7,opt,name=claim_address,json=claimAddress,proto3" json:"claim_address,omitempty"`
	ClaimExpiresAtBlock int32       `protobuf:"varint,8,opt,name=claim_expires_at_block,json=claimExpiresAtBlock,proto3" json:"claim_expires_at_block,omitempty"`
	ClosesAtBlock       int32       `protobuf:"varint,9,opt,name=closes_at_block,json=closesAtBlock,proto3" json:"closes_at_block,omitempty"`
}

func NewMsgOpenBeam

func NewMsgOpenBeam(id string, creator string, owner string, amount *sdk.Coin, secret string, schema string, data *BeamData, closesAtBlock int32, claimExpiresAtBlock int32) *MsgOpenBeam

NewMsgOpenBeam Build a open beam message based on parameters

func (*MsgOpenBeam) Descriptor

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

func (*MsgOpenBeam) GetAmount

func (m *MsgOpenBeam) GetAmount() *types.Coin

func (*MsgOpenBeam) GetClaimAddress

func (m *MsgOpenBeam) GetClaimAddress() string

func (*MsgOpenBeam) GetClaimExpiresAtBlock

func (m *MsgOpenBeam) GetClaimExpiresAtBlock() int32

func (*MsgOpenBeam) GetClosesAtBlock

func (m *MsgOpenBeam) GetClosesAtBlock() int32

func (*MsgOpenBeam) GetCreatorAddress

func (m *MsgOpenBeam) GetCreatorAddress() string

func (*MsgOpenBeam) GetData

func (m *MsgOpenBeam) GetData() *BeamData

func (*MsgOpenBeam) GetId

func (m *MsgOpenBeam) GetId() string

func (*MsgOpenBeam) GetSchema

func (m *MsgOpenBeam) GetSchema() string

func (*MsgOpenBeam) GetSecret

func (m *MsgOpenBeam) GetSecret() string

func (*MsgOpenBeam) GetSignBytes

func (msg *MsgOpenBeam) GetSignBytes() []byte

GetSignBytes Return the generated bytes from the signature

func (*MsgOpenBeam) GetSigners

func (msg *MsgOpenBeam) GetSigners() []sdk.AccAddress

GetSigners Return the list of signers for the given message

func (*MsgOpenBeam) Marshal

func (m *MsgOpenBeam) Marshal() (dAtA []byte, err error)

func (*MsgOpenBeam) MarshalTo

func (m *MsgOpenBeam) MarshalTo(dAtA []byte) (int, error)

func (*MsgOpenBeam) MarshalToSizedBuffer

func (m *MsgOpenBeam) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgOpenBeam) ProtoMessage

func (*MsgOpenBeam) ProtoMessage()

func (*MsgOpenBeam) Reset

func (m *MsgOpenBeam) Reset()

func (MsgOpenBeam) Route

func (msg MsgOpenBeam) Route() string

Route dunno

func (*MsgOpenBeam) Size

func (m *MsgOpenBeam) Size() (n int)

func (*MsgOpenBeam) String

func (m *MsgOpenBeam) String() string

func (MsgOpenBeam) Type

func (msg MsgOpenBeam) Type() string

Type Return the message type

func (*MsgOpenBeam) Unmarshal

func (m *MsgOpenBeam) Unmarshal(dAtA []byte) error

func (*MsgOpenBeam) ValidateBasic

func (msg *MsgOpenBeam) ValidateBasic() error

ValidateBasic Validate the message payload before dispatching to the local kv store

func (*MsgOpenBeam) XXX_DiscardUnknown

func (m *MsgOpenBeam) XXX_DiscardUnknown()

func (*MsgOpenBeam) XXX_Marshal

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

func (*MsgOpenBeam) XXX_Merge

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

func (*MsgOpenBeam) XXX_Size

func (m *MsgOpenBeam) XXX_Size() int

func (*MsgOpenBeam) XXX_Unmarshal

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

type MsgOpenBeamResponse added in v1.5.0

type MsgOpenBeamResponse struct {
}

func (*MsgOpenBeamResponse) Descriptor added in v1.5.0

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

func (*MsgOpenBeamResponse) Marshal added in v1.5.0

func (m *MsgOpenBeamResponse) Marshal() (dAtA []byte, err error)

func (*MsgOpenBeamResponse) MarshalTo added in v1.5.0

func (m *MsgOpenBeamResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgOpenBeamResponse) MarshalToSizedBuffer added in v1.5.0

func (m *MsgOpenBeamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgOpenBeamResponse) ProtoMessage added in v1.5.0

func (*MsgOpenBeamResponse) ProtoMessage()

func (*MsgOpenBeamResponse) Reset added in v1.5.0

func (m *MsgOpenBeamResponse) Reset()

func (*MsgOpenBeamResponse) Size added in v1.5.0

func (m *MsgOpenBeamResponse) Size() (n int)

func (*MsgOpenBeamResponse) String added in v1.5.0

func (m *MsgOpenBeamResponse) String() string

func (*MsgOpenBeamResponse) Unmarshal added in v1.5.0

func (m *MsgOpenBeamResponse) Unmarshal(dAtA []byte) error

func (*MsgOpenBeamResponse) XXX_DiscardUnknown added in v1.5.0

func (m *MsgOpenBeamResponse) XXX_DiscardUnknown()

func (*MsgOpenBeamResponse) XXX_Marshal added in v1.5.0

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

func (*MsgOpenBeamResponse) XXX_Merge added in v1.5.0

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

func (*MsgOpenBeamResponse) XXX_Size added in v1.5.0

func (m *MsgOpenBeamResponse) XXX_Size() int

func (*MsgOpenBeamResponse) XXX_Unmarshal added in v1.5.0

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

type MsgServer added in v1.5.0

MsgServer is the server API for Msg service.

type MsgUpdateBeam

type MsgUpdateBeam struct {
	Id                  string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	UpdaterAddress      string      `protobuf:"bytes,2,opt,name=updater_address,json=updaterAddress,proto3" json:"updater_address,omitempty"`
	Amount              *types.Coin `protobuf:"bytes,3,opt,name=amount,proto3" json:"amount,omitempty"`
	Status              BeamState   `protobuf:"varint,4,opt,name=status,proto3,enum=lum.network.beam.BeamState" json:"status,omitempty"`
	CancelReason        string      `protobuf:"bytes,5,opt,name=cancel_reason,json=cancelReason,proto3" json:"cancel_reason,omitempty"`
	HideContent         bool        `protobuf:"varint,6,opt,name=hide_content,json=hideContent,proto3" json:"hide_content,omitempty"`
	Data                *BeamData   `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"`
	ClaimAddress        string      `protobuf:"bytes,8,opt,name=claim_address,json=claimAddress,proto3" json:"claim_address,omitempty"`
	ClaimExpiresAtBlock int32       `protobuf:"varint,9,opt,name=claim_expires_at_block,json=claimExpiresAtBlock,proto3" json:"claim_expires_at_block,omitempty"`
	ClosesAtBlock       int32       `protobuf:"varint,10,opt,name=closes_at_block,json=closesAtBlock,proto3" json:"closes_at_block,omitempty"`
}

func NewMsgUpdateBeam

func NewMsgUpdateBeam(updater string, id string, amount *sdk.Coin, status BeamState, data *BeamData, cancelReason string, hideContent bool, closesAtBlock int32, claimExpiresAtBlock int32) *MsgUpdateBeam

NewMsgUpdateBeam Build a increase beam message based on parameters

func (*MsgUpdateBeam) Descriptor

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

func (*MsgUpdateBeam) GetAmount

func (m *MsgUpdateBeam) GetAmount() *types.Coin

func (*MsgUpdateBeam) GetCancelReason

func (m *MsgUpdateBeam) GetCancelReason() string

func (*MsgUpdateBeam) GetClaimAddress

func (m *MsgUpdateBeam) GetClaimAddress() string

func (*MsgUpdateBeam) GetClaimExpiresAtBlock

func (m *MsgUpdateBeam) GetClaimExpiresAtBlock() int32

func (*MsgUpdateBeam) GetClosesAtBlock

func (m *MsgUpdateBeam) GetClosesAtBlock() int32

func (*MsgUpdateBeam) GetData

func (m *MsgUpdateBeam) GetData() *BeamData

func (*MsgUpdateBeam) GetHideContent

func (m *MsgUpdateBeam) GetHideContent() bool

func (*MsgUpdateBeam) GetId

func (m *MsgUpdateBeam) GetId() string

func (*MsgUpdateBeam) GetSignBytes

func (msg *MsgUpdateBeam) GetSignBytes() []byte

GetSignBytes Return the generated bytes from the signature

func (*MsgUpdateBeam) GetSigners

func (msg *MsgUpdateBeam) GetSigners() []sdk.AccAddress

GetSigners Return the list of signers for the given message

func (*MsgUpdateBeam) GetStatus

func (m *MsgUpdateBeam) GetStatus() BeamState

func (*MsgUpdateBeam) GetUpdaterAddress

func (m *MsgUpdateBeam) GetUpdaterAddress() string

func (*MsgUpdateBeam) Marshal

func (m *MsgUpdateBeam) Marshal() (dAtA []byte, err error)

func (*MsgUpdateBeam) MarshalTo

func (m *MsgUpdateBeam) MarshalTo(dAtA []byte) (int, error)

func (*MsgUpdateBeam) MarshalToSizedBuffer

func (m *MsgUpdateBeam) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgUpdateBeam) ProtoMessage

func (*MsgUpdateBeam) ProtoMessage()

func (*MsgUpdateBeam) Reset

func (m *MsgUpdateBeam) Reset()

func (MsgUpdateBeam) Route

func (msg MsgUpdateBeam) Route() string

Route dunno

func (*MsgUpdateBeam) Size

func (m *MsgUpdateBeam) Size() (n int)

func (*MsgUpdateBeam) String

func (m *MsgUpdateBeam) String() string

func (MsgUpdateBeam) Type

func (msg MsgUpdateBeam) Type() string

Type Return the message type

func (*MsgUpdateBeam) Unmarshal

func (m *MsgUpdateBeam) Unmarshal(dAtA []byte) error

func (*MsgUpdateBeam) ValidateBasic

func (msg *MsgUpdateBeam) ValidateBasic() error

ValidateBasic Validate the message payload before dispatching to the local kv store

func (*MsgUpdateBeam) XXX_DiscardUnknown

func (m *MsgUpdateBeam) XXX_DiscardUnknown()

func (*MsgUpdateBeam) XXX_Marshal

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

func (*MsgUpdateBeam) XXX_Merge

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

func (*MsgUpdateBeam) XXX_Size

func (m *MsgUpdateBeam) XXX_Size() int

func (*MsgUpdateBeam) XXX_Unmarshal

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

type MsgUpdateBeamResponse added in v1.5.0

type MsgUpdateBeamResponse struct {
}

func (*MsgUpdateBeamResponse) Descriptor added in v1.5.0

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

func (*MsgUpdateBeamResponse) Marshal added in v1.5.0

func (m *MsgUpdateBeamResponse) Marshal() (dAtA []byte, err error)

func (*MsgUpdateBeamResponse) MarshalTo added in v1.5.0

func (m *MsgUpdateBeamResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgUpdateBeamResponse) MarshalToSizedBuffer added in v1.5.0

func (m *MsgUpdateBeamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgUpdateBeamResponse) ProtoMessage added in v1.5.0

func (*MsgUpdateBeamResponse) ProtoMessage()

func (*MsgUpdateBeamResponse) Reset added in v1.5.0

func (m *MsgUpdateBeamResponse) Reset()

func (*MsgUpdateBeamResponse) Size added in v1.5.0

func (m *MsgUpdateBeamResponse) Size() (n int)

func (*MsgUpdateBeamResponse) String added in v1.5.0

func (m *MsgUpdateBeamResponse) String() string

func (*MsgUpdateBeamResponse) Unmarshal added in v1.5.0

func (m *MsgUpdateBeamResponse) Unmarshal(dAtA []byte) error

func (*MsgUpdateBeamResponse) XXX_DiscardUnknown added in v1.5.0

func (m *MsgUpdateBeamResponse) XXX_DiscardUnknown()

func (*MsgUpdateBeamResponse) XXX_Marshal added in v1.5.0

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

func (*MsgUpdateBeamResponse) XXX_Merge added in v1.5.0

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

func (*MsgUpdateBeamResponse) XXX_Size added in v1.5.0

func (m *MsgUpdateBeamResponse) XXX_Size() int

func (*MsgUpdateBeamResponse) XXX_Unmarshal added in v1.5.0

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

type QueryClient

QueryClient is the client API for Query service.

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

func NewQueryClient

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryFetchBeamsOpenQueueRequest added in v1.1.0

type QueryFetchBeamsOpenQueueRequest struct {
	Pagination *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*QueryFetchBeamsOpenQueueRequest) Descriptor added in v1.1.0

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

func (*QueryFetchBeamsOpenQueueRequest) GetPagination added in v1.1.0

func (*QueryFetchBeamsOpenQueueRequest) Marshal added in v1.1.0

func (m *QueryFetchBeamsOpenQueueRequest) Marshal() (dAtA []byte, err error)

func (*QueryFetchBeamsOpenQueueRequest) MarshalTo added in v1.1.0

func (m *QueryFetchBeamsOpenQueueRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryFetchBeamsOpenQueueRequest) MarshalToSizedBuffer added in v1.1.0

func (m *QueryFetchBeamsOpenQueueRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryFetchBeamsOpenQueueRequest) ProtoMessage added in v1.1.0

func (*QueryFetchBeamsOpenQueueRequest) ProtoMessage()

func (*QueryFetchBeamsOpenQueueRequest) Reset added in v1.1.0

func (*QueryFetchBeamsOpenQueueRequest) Size added in v1.1.0

func (m *QueryFetchBeamsOpenQueueRequest) Size() (n int)

func (*QueryFetchBeamsOpenQueueRequest) String added in v1.1.0

func (*QueryFetchBeamsOpenQueueRequest) Unmarshal added in v1.1.0

func (m *QueryFetchBeamsOpenQueueRequest) Unmarshal(dAtA []byte) error

func (*QueryFetchBeamsOpenQueueRequest) XXX_DiscardUnknown added in v1.1.0

func (m *QueryFetchBeamsOpenQueueRequest) XXX_DiscardUnknown()

func (*QueryFetchBeamsOpenQueueRequest) XXX_Marshal added in v1.1.0

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

func (*QueryFetchBeamsOpenQueueRequest) XXX_Merge added in v1.1.0

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

func (*QueryFetchBeamsOpenQueueRequest) XXX_Size added in v1.1.0

func (m *QueryFetchBeamsOpenQueueRequest) XXX_Size() int

func (*QueryFetchBeamsOpenQueueRequest) XXX_Unmarshal added in v1.1.0

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

type QueryFetchBeamsOpenQueueResponse added in v1.1.0

type QueryFetchBeamsOpenQueueResponse struct {
	BeamIds    []string            `protobuf:"bytes,1,rep,name=beam_ids,json=beamIds,proto3" json:"beam_ids,omitempty"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*QueryFetchBeamsOpenQueueResponse) Descriptor added in v1.1.0

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

func (*QueryFetchBeamsOpenQueueResponse) GetBeamIds added in v1.1.0

func (m *QueryFetchBeamsOpenQueueResponse) GetBeamIds() []string

func (*QueryFetchBeamsOpenQueueResponse) GetPagination added in v1.1.0

func (*QueryFetchBeamsOpenQueueResponse) Marshal added in v1.1.0

func (m *QueryFetchBeamsOpenQueueResponse) Marshal() (dAtA []byte, err error)

func (*QueryFetchBeamsOpenQueueResponse) MarshalTo added in v1.1.0

func (m *QueryFetchBeamsOpenQueueResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryFetchBeamsOpenQueueResponse) MarshalToSizedBuffer added in v1.1.0

func (m *QueryFetchBeamsOpenQueueResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryFetchBeamsOpenQueueResponse) ProtoMessage added in v1.1.0

func (*QueryFetchBeamsOpenQueueResponse) ProtoMessage()

func (*QueryFetchBeamsOpenQueueResponse) Reset added in v1.1.0

func (*QueryFetchBeamsOpenQueueResponse) Size added in v1.1.0

func (m *QueryFetchBeamsOpenQueueResponse) Size() (n int)

func (*QueryFetchBeamsOpenQueueResponse) String added in v1.1.0

func (*QueryFetchBeamsOpenQueueResponse) Unmarshal added in v1.1.0

func (m *QueryFetchBeamsOpenQueueResponse) Unmarshal(dAtA []byte) error

func (*QueryFetchBeamsOpenQueueResponse) XXX_DiscardUnknown added in v1.1.0

func (m *QueryFetchBeamsOpenQueueResponse) XXX_DiscardUnknown()

func (*QueryFetchBeamsOpenQueueResponse) XXX_Marshal added in v1.1.0

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

func (*QueryFetchBeamsOpenQueueResponse) XXX_Merge added in v1.1.0

func (*QueryFetchBeamsOpenQueueResponse) XXX_Size added in v1.1.0

func (m *QueryFetchBeamsOpenQueueResponse) XXX_Size() int

func (*QueryFetchBeamsOpenQueueResponse) XXX_Unmarshal added in v1.1.0

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

type QueryFetchBeamsRequest

type QueryFetchBeamsRequest struct {
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
	State      BeamState          `protobuf:"varint,2,opt,name=state,proto3,enum=lum.network.beam.BeamState" json:"state,omitempty"`
}

func (*QueryFetchBeamsRequest) Descriptor

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

func (*QueryFetchBeamsRequest) GetPagination

func (m *QueryFetchBeamsRequest) GetPagination() *query.PageRequest

func (*QueryFetchBeamsRequest) GetState added in v1.1.0

func (m *QueryFetchBeamsRequest) GetState() BeamState

func (*QueryFetchBeamsRequest) Marshal

func (m *QueryFetchBeamsRequest) Marshal() (dAtA []byte, err error)

func (*QueryFetchBeamsRequest) MarshalTo

func (m *QueryFetchBeamsRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryFetchBeamsRequest) MarshalToSizedBuffer

func (m *QueryFetchBeamsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryFetchBeamsRequest) ProtoMessage

func (*QueryFetchBeamsRequest) ProtoMessage()

func (*QueryFetchBeamsRequest) Reset

func (m *QueryFetchBeamsRequest) Reset()

func (*QueryFetchBeamsRequest) Size

func (m *QueryFetchBeamsRequest) Size() (n int)

func (*QueryFetchBeamsRequest) String

func (m *QueryFetchBeamsRequest) String() string

func (*QueryFetchBeamsRequest) Unmarshal

func (m *QueryFetchBeamsRequest) Unmarshal(dAtA []byte) error

func (*QueryFetchBeamsRequest) XXX_DiscardUnknown

func (m *QueryFetchBeamsRequest) XXX_DiscardUnknown()

func (*QueryFetchBeamsRequest) XXX_Marshal

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

func (*QueryFetchBeamsRequest) XXX_Merge

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

func (*QueryFetchBeamsRequest) XXX_Size

func (m *QueryFetchBeamsRequest) XXX_Size() int

func (*QueryFetchBeamsRequest) XXX_Unmarshal

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

type QueryFetchBeamsResponse

type QueryFetchBeamsResponse struct {
	Beams      []*Beam             `protobuf:"bytes,1,rep,name=beams,proto3" json:"beams,omitempty"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*QueryFetchBeamsResponse) Descriptor

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

func (*QueryFetchBeamsResponse) GetBeams

func (m *QueryFetchBeamsResponse) GetBeams() []*Beam

func (*QueryFetchBeamsResponse) GetPagination

func (m *QueryFetchBeamsResponse) GetPagination() *query.PageResponse

func (*QueryFetchBeamsResponse) Marshal

func (m *QueryFetchBeamsResponse) Marshal() (dAtA []byte, err error)

func (*QueryFetchBeamsResponse) MarshalTo

func (m *QueryFetchBeamsResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryFetchBeamsResponse) MarshalToSizedBuffer

func (m *QueryFetchBeamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryFetchBeamsResponse) ProtoMessage

func (*QueryFetchBeamsResponse) ProtoMessage()

func (*QueryFetchBeamsResponse) Reset

func (m *QueryFetchBeamsResponse) Reset()

func (*QueryFetchBeamsResponse) Size

func (m *QueryFetchBeamsResponse) Size() (n int)

func (*QueryFetchBeamsResponse) String

func (m *QueryFetchBeamsResponse) String() string

func (*QueryFetchBeamsResponse) Unmarshal

func (m *QueryFetchBeamsResponse) Unmarshal(dAtA []byte) error

func (*QueryFetchBeamsResponse) XXX_DiscardUnknown

func (m *QueryFetchBeamsResponse) XXX_DiscardUnknown()

func (*QueryFetchBeamsResponse) XXX_Marshal

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

func (*QueryFetchBeamsResponse) XXX_Merge

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

func (*QueryFetchBeamsResponse) XXX_Size

func (m *QueryFetchBeamsResponse) XXX_Size() int

func (*QueryFetchBeamsResponse) XXX_Unmarshal

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

type QueryGetBeamRequest

type QueryGetBeamRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*QueryGetBeamRequest) Descriptor

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

func (*QueryGetBeamRequest) GetId

func (m *QueryGetBeamRequest) GetId() string

func (*QueryGetBeamRequest) Marshal

func (m *QueryGetBeamRequest) Marshal() (dAtA []byte, err error)

func (*QueryGetBeamRequest) MarshalTo

func (m *QueryGetBeamRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryGetBeamRequest) MarshalToSizedBuffer

func (m *QueryGetBeamRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryGetBeamRequest) ProtoMessage

func (*QueryGetBeamRequest) ProtoMessage()

func (*QueryGetBeamRequest) Reset

func (m *QueryGetBeamRequest) Reset()

func (*QueryGetBeamRequest) Size

func (m *QueryGetBeamRequest) Size() (n int)

func (*QueryGetBeamRequest) String

func (m *QueryGetBeamRequest) String() string

func (*QueryGetBeamRequest) Unmarshal

func (m *QueryGetBeamRequest) Unmarshal(dAtA []byte) error

func (*QueryGetBeamRequest) XXX_DiscardUnknown

func (m *QueryGetBeamRequest) XXX_DiscardUnknown()

func (*QueryGetBeamRequest) XXX_Marshal

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

func (*QueryGetBeamRequest) XXX_Merge

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

func (*QueryGetBeamRequest) XXX_Size

func (m *QueryGetBeamRequest) XXX_Size() int

func (*QueryGetBeamRequest) XXX_Unmarshal

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

type QueryGetBeamResponse

type QueryGetBeamResponse struct {
	Beam *Beam `protobuf:"bytes,1,opt,name=beam,proto3" json:"beam,omitempty"`
}

func (*QueryGetBeamResponse) Descriptor

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

func (*QueryGetBeamResponse) GetBeam

func (m *QueryGetBeamResponse) GetBeam() *Beam

func (*QueryGetBeamResponse) Marshal

func (m *QueryGetBeamResponse) Marshal() (dAtA []byte, err error)

func (*QueryGetBeamResponse) MarshalTo

func (m *QueryGetBeamResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryGetBeamResponse) MarshalToSizedBuffer

func (m *QueryGetBeamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryGetBeamResponse) ProtoMessage

func (*QueryGetBeamResponse) ProtoMessage()

func (*QueryGetBeamResponse) Reset

func (m *QueryGetBeamResponse) Reset()

func (*QueryGetBeamResponse) Size

func (m *QueryGetBeamResponse) Size() (n int)

func (*QueryGetBeamResponse) String

func (m *QueryGetBeamResponse) String() string

func (*QueryGetBeamResponse) Unmarshal

func (m *QueryGetBeamResponse) Unmarshal(dAtA []byte) error

func (*QueryGetBeamResponse) XXX_DiscardUnknown

func (m *QueryGetBeamResponse) XXX_DiscardUnknown()

func (*QueryGetBeamResponse) XXX_Marshal

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

func (*QueryGetBeamResponse) XXX_Merge

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

func (*QueryGetBeamResponse) XXX_Size

func (m *QueryGetBeamResponse) XXX_Size() int

func (*QueryGetBeamResponse) XXX_Unmarshal

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

type QueryServer

QueryServer is the server API for Query service.

type UnimplementedMsgServer added in v1.5.0

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) ClaimBeam added in v1.5.0

func (*UnimplementedMsgServer) OpenBeam added in v1.5.0

func (*UnimplementedMsgServer) UpdateBeam added in v1.5.0

type UnimplementedQueryServer

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Beam

func (*UnimplementedQueryServer) Beams

func (*UnimplementedQueryServer) BeamsOpenQueue added in v1.1.0

Jump to

Keyboard shortcuts

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