types

package
v1.6.5 Latest Latest
Warning

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

 Go to latest Published: Mar 8, 2024 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 (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 (*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 

type MsgServer interface {
	OpenBeam(context.Context, *MsgOpenBeam) (*MsgOpenBeamResponse, error)
	UpdateBeam(context.Context, *MsgUpdateBeam) (*MsgUpdateBeamResponse, error)
	ClaimBeam(context.Context, *MsgClaimBeam) (*MsgClaimBeamResponse, error)
}

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 

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 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) ClaimBeam(ctx context.Context, req *MsgClaimBeam) (*MsgClaimBeamResponse, error)

func (*UnimplementedMsgServer) OpenBeam added in v1.5.0 

func (*UnimplementedMsgServer) OpenBeam(ctx context.Context, req *MsgOpenBeam) (*MsgOpenBeamResponse, error)

func (*UnimplementedMsgServer) UpdateBeam added in v1.5.0 

func (*UnimplementedMsgServer) UpdateBeam(ctx context.Context, req *MsgUpdateBeam) (*MsgUpdateBeamResponse, error)

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.