types

package
v1.4.3 Latest Latest
Warning

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

 Go to latest Published: Jun 9, 2023 License: Apache-2.0 Imports: 29 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 = 2

	// 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                = sdkerrors.Register(ModuleName, 1100, "Beam does not exists")
	ErrBeamNotAuthorized           = sdkerrors.Register(ModuleName, 1101, "This beam does not belong to you")
	ErrBeamInvalidSecret           = sdkerrors.Register(ModuleName, 1102, "Invalid secret provided")
	ErrBeamAlreadyExists           = sdkerrors.Register(ModuleName, 1103, "This beam ID already exists")
	ErrBeamAutoCloseInThePast      = sdkerrors.Register(ModuleName, 1104, "Cannot set autoclose height in the past")
	ErrBeamIdContainsForbiddenChar = sdkerrors.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 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 (m *BeamMerchantReview) GetContent() *BeamMerchantReview_BeamMerchantReviewContent

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 (m *BeamMerchantReview) GetRatings() *BeamMerchantReview_BeamMerchantReviewRating

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

func (*BeamMerchantReview_BeamMerchantReviewContent) GetCustomerService 

func (m *BeamMerchantReview_BeamMerchantReviewContent) GetCustomerService() string

func (*BeamMerchantReview_BeamMerchantReviewContent) GetOverall 

func (m *BeamMerchantReview_BeamMerchantReviewContent) GetOverall() string

func (*BeamMerchantReview_BeamMerchantReviewContent) Marshal 

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

func (*BeamMerchantReview_BeamMerchantReviewContent) MarshalTo 

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

func (*BeamMerchantReview_BeamMerchantReviewContent) MarshalToSizedBuffer 

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

func (*BeamMerchantReview_BeamMerchantReviewContent) ProtoMessage 

func (*BeamMerchantReview_BeamMerchantReviewContent) ProtoMessage()

func (*BeamMerchantReview_BeamMerchantReviewContent) Reset 

func (m *BeamMerchantReview_BeamMerchantReviewContent) Reset()

func (*BeamMerchantReview_BeamMerchantReviewContent) Size 

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

func (*BeamMerchantReview_BeamMerchantReviewContent) String 

func (m *BeamMerchantReview_BeamMerchantReviewContent) String() string

func (*BeamMerchantReview_BeamMerchantReviewContent) Unmarshal 

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

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 (m *BeamMerchantReview_BeamMerchantReviewContent) XXX_Merge(src proto.Message)

func (*BeamMerchantReview_BeamMerchantReviewContent) XXX_Size 

func (m *BeamMerchantReview_BeamMerchantReviewContent) XXX_Size() int

func (*BeamMerchantReview_BeamMerchantReviewContent) XXX_Unmarshal 

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

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

func (*BeamMerchantReview_BeamMerchantReviewRating) GetCustomerService 

func (m *BeamMerchantReview_BeamMerchantReviewRating) GetCustomerService() float32

func (*BeamMerchantReview_BeamMerchantReviewRating) GetNps 

func (m *BeamMerchantReview_BeamMerchantReviewRating) GetNps() float32

func (*BeamMerchantReview_BeamMerchantReviewRating) GetOverall 

func (m *BeamMerchantReview_BeamMerchantReviewRating) GetOverall() float32

func (*BeamMerchantReview_BeamMerchantReviewRating) Marshal 

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

func (*BeamMerchantReview_BeamMerchantReviewRating) MarshalTo 

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

func (*BeamMerchantReview_BeamMerchantReviewRating) MarshalToSizedBuffer 

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

func (*BeamMerchantReview_BeamMerchantReviewRating) ProtoMessage 

func (*BeamMerchantReview_BeamMerchantReviewRating) ProtoMessage()

func (*BeamMerchantReview_BeamMerchantReviewRating) Reset 

func (m *BeamMerchantReview_BeamMerchantReviewRating) Reset()

func (*BeamMerchantReview_BeamMerchantReviewRating) Size 

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

func (*BeamMerchantReview_BeamMerchantReviewRating) String 

func (m *BeamMerchantReview_BeamMerchantReviewRating) String() string

func (*BeamMerchantReview_BeamMerchantReviewRating) Unmarshal 

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

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 (m *BeamMerchantReview_BeamMerchantReviewRating) XXX_Merge(src proto.Message)

func (*BeamMerchantReview_BeamMerchantReviewRating) XXX_Size 

func (m *BeamMerchantReview_BeamMerchantReviewRating) XXX_Size() int

func (*BeamMerchantReview_BeamMerchantReviewRating) XXX_Unmarshal 

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

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 (m *BeamProductReview) GetContent() *BeamProductReview_BeamProductReviewContent

func (*BeamProductReview) GetMedias 

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

func (*BeamProductReview) GetOrderId 

func (m *BeamProductReview) GetOrderId() string

func (*BeamProductReview) GetProducts 

func (m *BeamProductReview) GetProducts() []*BeamProductReview_BeamProduct

func (*BeamProductReview) GetRatingUrl 

func (m *BeamProductReview) GetRatingUrl() string

func (*BeamProductReview) GetRatings 

func (m *BeamProductReview) GetRatings() *BeamProductReview_BeamProductReviewRating

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 (m *BeamProductReview_BeamProduct) GetIds() *BeamProductReview_BeamProduct_BeamProductIds

func (*BeamProductReview_BeamProduct) GetName 

func (m *BeamProductReview_BeamProduct) GetName() string

func (*BeamProductReview_BeamProduct) GetUrl 

func (m *BeamProductReview_BeamProduct) GetUrl() string

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

func (*BeamProductReview_BeamProductReviewContent) GetCons 

func (m *BeamProductReview_BeamProductReviewContent) GetCons() string

func (*BeamProductReview_BeamProductReviewContent) GetOverall 

func (m *BeamProductReview_BeamProductReviewContent) GetOverall() string

func (*BeamProductReview_BeamProductReviewContent) GetPros 

func (m *BeamProductReview_BeamProductReviewContent) GetPros() string

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) ProtoMessage()

func (*BeamProductReview_BeamProductReviewContent) Reset 

func (m *BeamProductReview_BeamProductReviewContent) Reset()

func (*BeamProductReview_BeamProductReviewContent) Size 

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

func (*BeamProductReview_BeamProductReviewContent) String 

func (m *BeamProductReview_BeamProductReviewContent) String() string

func (*BeamProductReview_BeamProductReviewContent) Unmarshal 

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

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 (m *BeamProductReview_BeamProductReviewContent) XXX_Merge(src proto.Message)

func (*BeamProductReview_BeamProductReviewContent) XXX_Size 

func (m *BeamProductReview_BeamProductReviewContent) XXX_Size() int

func (*BeamProductReview_BeamProductReviewContent) XXX_Unmarshal 

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

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 (m *BeamProductReview_BeamProductReviewRating) GetOverall() float32

func (*BeamProductReview_BeamProductReviewRating) GetQuality 

func (m *BeamProductReview_BeamProductReviewRating) GetQuality() float32

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) ProtoMessage()

func (*BeamProductReview_BeamProductReviewRating) Reset 

func (m *BeamProductReview_BeamProductReviewRating) Reset()

func (*BeamProductReview_BeamProductReviewRating) Size 

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

func (*BeamProductReview_BeamProductReviewRating) String 

func (m *BeamProductReview_BeamProductReviewRating) String() string

func (*BeamProductReview_BeamProductReviewRating) Unmarshal 

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

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 (m *BeamProductReview_BeamProductReviewRating) XXX_Merge(src proto.Message)

func (*BeamProductReview_BeamProductReviewRating) XXX_Size 

func (m *BeamProductReview_BeamProductReviewRating) XXX_Size() int

func (*BeamProductReview_BeamProductReviewRating) XXX_Unmarshal 

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

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

func (*BeamProductReview_BeamProduct_BeamProductIds) GetAsins 

func (m *BeamProductReview_BeamProduct_BeamProductIds) GetAsins() []string

func (*BeamProductReview_BeamProduct_BeamProductIds) GetGtins 

func (m *BeamProductReview_BeamProduct_BeamProductIds) GetGtins() []string

func (*BeamProductReview_BeamProduct_BeamProductIds) GetMpns 

func (m *BeamProductReview_BeamProduct_BeamProductIds) GetMpns() []string

func (*BeamProductReview_BeamProduct_BeamProductIds) GetSkus 

func (m *BeamProductReview_BeamProduct_BeamProductIds) GetSkus() []string

func (*BeamProductReview_BeamProduct_BeamProductIds) Marshal 

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

func (*BeamProductReview_BeamProduct_BeamProductIds) MarshalTo 

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

func (*BeamProductReview_BeamProduct_BeamProductIds) MarshalToSizedBuffer 

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

func (*BeamProductReview_BeamProduct_BeamProductIds) ProtoMessage 

func (*BeamProductReview_BeamProduct_BeamProductIds) ProtoMessage()

func (*BeamProductReview_BeamProduct_BeamProductIds) Reset 

func (m *BeamProductReview_BeamProduct_BeamProductIds) Reset()

func (*BeamProductReview_BeamProduct_BeamProductIds) Size 

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

func (*BeamProductReview_BeamProduct_BeamProductIds) String 

func (m *BeamProductReview_BeamProduct_BeamProductIds) String() string

func (*BeamProductReview_BeamProduct_BeamProductIds) Unmarshal 

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

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 (m *BeamProductReview_BeamProduct_BeamProductIds) XXX_Merge(src proto.Message)

func (*BeamProductReview_BeamProduct_BeamProductIds) XXX_Size 

func (m *BeamProductReview_BeamProduct_BeamProductIds) XXX_Size() int

func (*BeamProductReview_BeamProduct_BeamProductIds) XXX_Unmarshal 

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

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 (m *BeamReward_BeamRewardDetails) String() 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 GetGenesisStateFromAppState added in v1.0.4 

func GetGenesisStateFromAppState(cdc codec.JSONCodec, appState map[string]json.RawMessage) *GenesisState

GetGenesisStateFromAppState returns x/beam GenesisState given raw application 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 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 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 QueryClient 

type QueryClient interface {
	Beam(ctx context.Context, in *QueryGetBeamRequest, opts ...grpc.CallOption) (*QueryGetBeamResponse, error)
	Beams(ctx context.Context, in *QueryFetchBeamsRequest, opts ...grpc.CallOption) (*QueryFetchBeamsResponse, error)
	BeamsOpenQueue(ctx context.Context, in *QueryFetchBeamsOpenQueueRequest, opts ...grpc.CallOption) (*QueryFetchBeamsOpenQueueResponse, error)
}

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 (m *QueryFetchBeamsOpenQueueRequest) GetPagination() *query.PageRequest

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 (m *QueryFetchBeamsOpenQueueRequest) Reset()

func (*QueryFetchBeamsOpenQueueRequest) Size added in v1.1.0 

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

func (*QueryFetchBeamsOpenQueueRequest) String added in v1.1.0 

func (m *QueryFetchBeamsOpenQueueRequest) String() string

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 (m *QueryFetchBeamsOpenQueueResponse) GetPagination() *query.PageResponse

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 (m *QueryFetchBeamsOpenQueueResponse) Reset()

func (*QueryFetchBeamsOpenQueueResponse) Size added in v1.1.0 

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

func (*QueryFetchBeamsOpenQueueResponse) String added in v1.1.0 

func (m *QueryFetchBeamsOpenQueueResponse) String() string

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 (m *QueryFetchBeamsOpenQueueResponse) XXX_Merge(src proto.Message)

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 

type QueryServer interface {
	Beam(context.Context, *QueryGetBeamRequest) (*QueryGetBeamResponse, error)
	Beams(context.Context, *QueryFetchBeamsRequest) (*QueryFetchBeamsResponse, error)
	BeamsOpenQueue(context.Context, *QueryFetchBeamsOpenQueueRequest) (*QueryFetchBeamsOpenQueueResponse, error)
}

QueryServer is the server API for Query service.

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Beam 

func (*UnimplementedQueryServer) Beam(ctx context.Context, req *QueryGetBeamRequest) (*QueryGetBeamResponse, error)

func (*UnimplementedQueryServer) Beams 

func (*UnimplementedQueryServer) Beams(ctx context.Context, req *QueryFetchBeamsRequest) (*QueryFetchBeamsResponse, error)

func (*UnimplementedQueryServer) BeamsOpenQueue added in v1.1.0 

func (*UnimplementedQueryServer) BeamsOpenQueue(ctx context.Context, req *QueryFetchBeamsOpenQueueRequest) (*QueryFetchBeamsOpenQueueResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.