types

package
v3.1.0 Latest Latest
Warning

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

 Go to latest Published: Apr 14, 2024 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	TypeEvtCreateStream = "create_stream"
	TypeEvtDistribution = "distribution"

	AttributeStreamID = "stream_id"
	AttributeReceiver = "receiver"
	AttributeAmount   = "amount"
)

Incentive module event types.

View Source 
const (
	// ProposalTypeReplaceStreamDistribution defines the type for a ReplaceStreamDistributionmProposal
	ProposalTypeReplaceStreamDistribution = "ReplaceStreamDistribution"

	// ProposalTypeUpdateStreamDistribution defines the type for a UpdateStreamDistributionmProposal
	ProposalTypeUpdateStreamDistribution = "UpdateStreamDistribution"
)
View Source 
const (
	// ProposalTypeCreateStream defines the type for a CreateStreamProposal
	ProposalTypeCreateStream = "CreateStream"

	// ProposalTypeTerminateStream defines the type for a TerminateStreamProposal
	ProposalTypeTerminateStream = "TerminateStream"
)
View Source 
const DefaultIndex uint64 = 1

DefaultIndex is the default global index

Variables

View Source 
var (
	ErrInvalidLengthDistrInfo        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDistrInfo          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDistrInfo = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrNoGaugeIdExist                = sdkerrors.Register(ModuleName, 1, "no gauge id exist")
	ErrDistrRecordNotPositiveWeight  = sdkerrors.Register(ModuleName, 2, "weight in record should be non negative")
	ErrDistrRecordNotRegisteredGauge = sdkerrors.Register(ModuleName, 3, "gauge was not registered")
	ErrDistrRecordRegisteredGauge    = sdkerrors.Register(ModuleName, 4, "gauge was already registered")
	ErrDistrRecordNotSorted          = sdkerrors.Register(ModuleName, 5, "gauges are not sorted")
	ErrDistrInfoNotPositiveWeight    = sdkerrors.Register(ModuleName, 6, "total distribution weight should be positive")

	ErrEmptyProposalRecords         = sdkerrors.Register(ModuleName, 10, "records are empty")
	ErrEmptyProposalGaugeIds        = sdkerrors.Register(ModuleName, 11, "gauge ids are empty")
	ErrDistrInfoTotalWeightNotEqual = sdkerrors.Register(ModuleName, 12, "total weight is not equal to sum of weights in records")

	ErrInvalidStreamStatus = sdkerrors.Register(ModuleName, 20, "invalid stream status")
)

The following regiisters various lockdrop errors.

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 (
	ErrInvalidLengthGovDistribution        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGovDistribution          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGovDistribution = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthGovStream        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGovStream          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGovStream = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// ModuleName defines the module name.
	ModuleName = "streamer"

	// 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"

	// KeyPrefixTimestamp defines prefix key for timestamp iterator key.
	KeyPrefixTimestamp = []byte{0x01}

	// KeyLastStreamID defines key for setting last stream ID.
	KeyLastStreamID = []byte{0x02}

	// KeyPrefixPeriodStream defines prefix key for storing streams.
	KeyPrefixPeriodStream = []byte{0x03}

	// KeyPrefixStreams defines prefix key for storing reference key for all streams.
	KeyPrefixStreams = []byte{0x04}

	// KeyPrefixUpcomingStreams defines prefix key for storing reference key for upcoming streams.
	KeyPrefixUpcomingStreams = []byte{0x04, 0x00}

	// KeyPrefixActiveStreams defines prefix key for storing reference key for active streams.
	KeyPrefixActiveStreams = []byte{0x04, 0x01}

	// KeyPrefixFinishedStreams defines prefix key for storing reference key for finished streams.
	KeyPrefixFinishedStreams = []byte{0x04, 0x02}

	// KeyIndexSeparator defines key for merging bytes.
	KeyIndexSeparator = []byte{0x07}
)
View Source 
var (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group")
)
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 (
	ErrInvalidLengthStream        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStream          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupStream = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ModuleCdc = codec.NewAminoCodec(amino)
)

Functions

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable the param key table for launch module

func RegisterCodec 

func RegisterCodec(cdc *codec.LegacyAmino)

RegisterCodec registers the necessary x/streamer interfaces and concrete types on the provided LegacyAmino codec. These types are used for Amino JSON serialization.

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

RegisterInterfaces registers interfaces and implementations of the streamer module.

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)

Types

type AccountKeeper 

type AccountKeeper interface {
	GetModuleAccount(ctx sdk.Context, moduleName string) authtypes.ModuleAccountI
	GetModuleAddress(name string) sdk.AccAddress
}

type ActiveStreamsRequest 

type ActiveStreamsRequest struct {
	// Pagination defines pagination for the request
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*ActiveStreamsRequest) Descriptor 

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

func (*ActiveStreamsRequest) GetPagination 

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

func (*ActiveStreamsRequest) Marshal 

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

func (*ActiveStreamsRequest) MarshalTo 

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

func (*ActiveStreamsRequest) MarshalToSizedBuffer 

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

func (*ActiveStreamsRequest) ProtoMessage 

func (*ActiveStreamsRequest) ProtoMessage()

func (*ActiveStreamsRequest) Reset 

func (m *ActiveStreamsRequest) Reset()

func (*ActiveStreamsRequest) Size 

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

func (*ActiveStreamsRequest) String 

func (m *ActiveStreamsRequest) String() string

func (*ActiveStreamsRequest) Unmarshal 

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

func (*ActiveStreamsRequest) XXX_DiscardUnknown 

func (m *ActiveStreamsRequest) XXX_DiscardUnknown()

func (*ActiveStreamsRequest) XXX_Marshal 

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

func (*ActiveStreamsRequest) XXX_Merge 

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

func (*ActiveStreamsRequest) XXX_Size 

func (m *ActiveStreamsRequest) XXX_Size() int

func (*ActiveStreamsRequest) XXX_Unmarshal 

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

type ActiveStreamsResponse 

type ActiveStreamsResponse struct {
	// Active gagues only
	Data []Stream `protobuf:"bytes,1,rep,name=data,proto3" json:"data"`
	// Pagination defines pagination for the response
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*ActiveStreamsResponse) Descriptor 

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

func (*ActiveStreamsResponse) GetData 

func (m *ActiveStreamsResponse) GetData() []Stream

func (*ActiveStreamsResponse) GetPagination 

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

func (*ActiveStreamsResponse) Marshal 

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

func (*ActiveStreamsResponse) MarshalTo 

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

func (*ActiveStreamsResponse) MarshalToSizedBuffer 

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

func (*ActiveStreamsResponse) ProtoMessage 

func (*ActiveStreamsResponse) ProtoMessage()

func (*ActiveStreamsResponse) Reset 

func (m *ActiveStreamsResponse) Reset()

func (*ActiveStreamsResponse) Size 

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

func (*ActiveStreamsResponse) String 

func (m *ActiveStreamsResponse) String() string

func (*ActiveStreamsResponse) Unmarshal 

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

func (*ActiveStreamsResponse) XXX_DiscardUnknown 

func (m *ActiveStreamsResponse) XXX_DiscardUnknown()

func (*ActiveStreamsResponse) XXX_Marshal 

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

func (*ActiveStreamsResponse) XXX_Merge 

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

func (*ActiveStreamsResponse) XXX_Size 

func (m *ActiveStreamsResponse) XXX_Size() int

func (*ActiveStreamsResponse) XXX_Unmarshal 

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

type BankKeeper 

type BankKeeper interface {
	GetBalance(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin
	GetAllBalances(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
}

BankKeeper defines the expected interface needed to retrieve account balances.

type CreateStreamProposal 

type CreateStreamProposal struct {
	Title               string        `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Description         string        `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	DistributeToRecords []DistrRecord `protobuf:"bytes,3,rep,name=distribute_to_records,json=distributeToRecords,proto3" json:"distribute_to_records"`
	// coins are coin(s) to be distributed by the stream
	Coins github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,4,rep,name=coins,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"coins"`
	// start_time is the distribution start time
	StartTime            time.Time `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time" yaml:"timestamp"`
	DistrEpochIdentifier string    `` /* 153-byte string literal not displayed */
	// num_epochs_paid_over is the number of epochs distribution will be completed
	// over
	NumEpochsPaidOver uint64 `protobuf:"varint,7,opt,name=num_epochs_paid_over,json=numEpochsPaidOver,proto3" json:"num_epochs_paid_over,omitempty"`
}

func NewCreateStreamProposal 

func NewCreateStreamProposal(title, description string, coins sdk.Coins, distrToRecords []DistrRecord, startTime time.Time, epochIdentifier string, numEpochsPaidOver uint64) *CreateStreamProposal

NewCreateStreamProposal creates a new create stream proposal.

func (*CreateStreamProposal) Descriptor 

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

func (*CreateStreamProposal) Equal 

func (this *CreateStreamProposal) Equal(that interface{}) bool

func (*CreateStreamProposal) GetDescription 

func (csp *CreateStreamProposal) GetDescription() string

GetDescription returns the description of a community pool spend proposal.

func (*CreateStreamProposal) GetTitle 

func (csp *CreateStreamProposal) GetTitle() string

GetTitle returns the title of a community pool spend proposal.

func (*CreateStreamProposal) Marshal 

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

func (*CreateStreamProposal) MarshalTo 

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

func (*CreateStreamProposal) MarshalToSizedBuffer 

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

func (*CreateStreamProposal) ProposalRoute 

func (csp *CreateStreamProposal) ProposalRoute() string

GetDescription returns the routing key of a community pool spend proposal.

func (*CreateStreamProposal) ProposalType 

func (csp *CreateStreamProposal) ProposalType() string

ProposalType returns the type of a community pool spend proposal.

func (*CreateStreamProposal) ProtoMessage 

func (*CreateStreamProposal) ProtoMessage()

func (*CreateStreamProposal) Reset 

func (m *CreateStreamProposal) Reset()

func (*CreateStreamProposal) Size 

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

func (CreateStreamProposal) String 

func (csp CreateStreamProposal) String() string

String implements the Stringer interface.

func (*CreateStreamProposal) Unmarshal 

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

func (*CreateStreamProposal) ValidateBasic 

func (csp *CreateStreamProposal) ValidateBasic() error

ValidateBasic runs basic stateless validity checks

func (*CreateStreamProposal) XXX_DiscardUnknown 

func (m *CreateStreamProposal) XXX_DiscardUnknown()

func (*CreateStreamProposal) XXX_Marshal 

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

func (*CreateStreamProposal) XXX_Merge 

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

func (*CreateStreamProposal) XXX_Size 

func (m *CreateStreamProposal) XXX_Size() int

func (*CreateStreamProposal) XXX_Unmarshal 

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

type DistrInfo 

type DistrInfo struct {
	TotalWeight github_com_cosmos_cosmos_sdk_types.Int `` /* 154-byte string literal not displayed */
	Records     []DistrRecord                          `protobuf:"bytes,2,rep,name=records,proto3" json:"records"`
}

func NewDistrInfo 

func NewDistrInfo(records []DistrRecord) (*DistrInfo, error)

func (*DistrInfo) Descriptor 

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

func (*DistrInfo) GetRecords 

func (m *DistrInfo) GetRecords() []DistrRecord

func (*DistrInfo) Marshal 

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

func (*DistrInfo) MarshalTo 

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

func (*DistrInfo) MarshalToSizedBuffer 

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

func (*DistrInfo) ProtoMessage 

func (*DistrInfo) ProtoMessage()

func (*DistrInfo) Reset 

func (m *DistrInfo) Reset()

func (*DistrInfo) Size 

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

func (*DistrInfo) String 

func (m *DistrInfo) String() string

func (*DistrInfo) Unmarshal 

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

func (*DistrInfo) XXX_DiscardUnknown 

func (m *DistrInfo) XXX_DiscardUnknown()

func (*DistrInfo) XXX_Marshal 

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

func (*DistrInfo) XXX_Merge 

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

func (*DistrInfo) XXX_Size 

func (m *DistrInfo) XXX_Size() int

func (*DistrInfo) XXX_Unmarshal 

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

type DistrRecord 

type DistrRecord struct {
	GaugeId uint64                                 `protobuf:"varint,1,opt,name=gauge_id,json=gaugeId,proto3" json:"gauge_id,omitempty" yaml:"gauge_id"`
	Weight  github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,2,opt,name=weight,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"weight"`
}

func (*DistrRecord) Descriptor 

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

func (*DistrRecord) Equal 

func (this *DistrRecord) Equal(that interface{}) bool

func (*DistrRecord) GetGaugeId 

func (m *DistrRecord) GetGaugeId() uint64

func (*DistrRecord) Marshal 

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

func (*DistrRecord) MarshalTo 

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

func (*DistrRecord) MarshalToSizedBuffer 

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

func (*DistrRecord) ProtoMessage 

func (*DistrRecord) ProtoMessage()

func (*DistrRecord) Reset 

func (m *DistrRecord) Reset()

func (*DistrRecord) Size 

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

func (*DistrRecord) String 

func (m *DistrRecord) String() string

func (*DistrRecord) Unmarshal 

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

func (DistrRecord) ValidateBasic 

func (r DistrRecord) ValidateBasic() error

ValidateBasic is a basic validation test on recordd distribution gauges' weights.

func (*DistrRecord) XXX_DiscardUnknown 

func (m *DistrRecord) XXX_DiscardUnknown()

func (*DistrRecord) XXX_Marshal 

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

func (*DistrRecord) XXX_Merge 

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

func (*DistrRecord) XXX_Size 

func (m *DistrRecord) XXX_Size() int

func (*DistrRecord) XXX_Unmarshal 

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

type EpochKeeper 

type EpochKeeper interface {
	GetEpochInfo(ctx sdk.Context, identifier string) epochstypes.EpochInfo
}

EpochKeeper defines the expected interface needed to retrieve epoch info.

type GenesisState 

type GenesisState struct {
	// params are all the parameters of the module
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	// streams are all streams that should exist at genesis
	Streams []Stream `protobuf:"bytes,2,rep,name=streams,proto3" json:"streams"`
	// last_stream_id is what the stream number will increment from when creating
	// the next stream after genesis
	LastStreamId uint64 `protobuf:"varint,3,opt,name=last_stream_id,json=lastStreamId,proto3" json:"last_stream_id,omitempty"`
}

GenesisState defines the streamer module's various parameters when first initialized

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default genesis state

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetLastStreamId 

func (m *GenesisState) GetLastStreamId() uint64

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetStreams 

func (m *GenesisState) GetStreams() []Stream

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 IncentivesKeeper 

type IncentivesKeeper interface {
	CreateGauge(ctx sdk.Context, isPerpetual bool, owner sdk.AccAddress, coins sdk.Coins, distrTo lockuptypes.QueryCondition, startTime time.Time, numEpochsPaidOver uint64) (uint64, error)
	GetLockableDurations(ctx sdk.Context) []time.Duration

	GetGaugeByID(ctx sdk.Context, gaugeID uint64) (*incentivestypes.Gauge, error)
	AddToGaugeRewards(ctx sdk.Context, owner sdk.AccAddress, coins sdk.Coins, gaugeID uint64) error
}

IncentivesKeeper creates and gets gauges, and also allows additions to gauge rewards.

type ModuleToDistributeCoinsRequest 

type ModuleToDistributeCoinsRequest struct {
}

func (*ModuleToDistributeCoinsRequest) Descriptor 

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

func (*ModuleToDistributeCoinsRequest) Marshal 

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

func (*ModuleToDistributeCoinsRequest) MarshalTo 

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

func (*ModuleToDistributeCoinsRequest) MarshalToSizedBuffer 

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

func (*ModuleToDistributeCoinsRequest) ProtoMessage 

func (*ModuleToDistributeCoinsRequest) ProtoMessage()

func (*ModuleToDistributeCoinsRequest) Reset 

func (m *ModuleToDistributeCoinsRequest) Reset()

func (*ModuleToDistributeCoinsRequest) Size 

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

func (*ModuleToDistributeCoinsRequest) String 

func (m *ModuleToDistributeCoinsRequest) String() string

func (*ModuleToDistributeCoinsRequest) Unmarshal 

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

func (*ModuleToDistributeCoinsRequest) XXX_DiscardUnknown 

func (m *ModuleToDistributeCoinsRequest) XXX_DiscardUnknown()

func (*ModuleToDistributeCoinsRequest) XXX_Marshal 

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

func (*ModuleToDistributeCoinsRequest) XXX_Merge 

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

func (*ModuleToDistributeCoinsRequest) XXX_Size 

func (m *ModuleToDistributeCoinsRequest) XXX_Size() int

func (*ModuleToDistributeCoinsRequest) XXX_Unmarshal 

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

type ModuleToDistributeCoinsResponse 

type ModuleToDistributeCoinsResponse struct {
	// Coins that have yet to be distributed
	Coins github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,1,rep,name=coins,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"coins"`
}

func (*ModuleToDistributeCoinsResponse) Descriptor 

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

func (*ModuleToDistributeCoinsResponse) GetCoins 

func (m *ModuleToDistributeCoinsResponse) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins

func (*ModuleToDistributeCoinsResponse) Marshal 

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

func (*ModuleToDistributeCoinsResponse) MarshalTo 

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

func (*ModuleToDistributeCoinsResponse) MarshalToSizedBuffer 

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

func (*ModuleToDistributeCoinsResponse) ProtoMessage 

func (*ModuleToDistributeCoinsResponse) ProtoMessage()

func (*ModuleToDistributeCoinsResponse) Reset 

func (m *ModuleToDistributeCoinsResponse) Reset()

func (*ModuleToDistributeCoinsResponse) Size 

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

func (*ModuleToDistributeCoinsResponse) String 

func (m *ModuleToDistributeCoinsResponse) String() string

func (*ModuleToDistributeCoinsResponse) Unmarshal 

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

func (*ModuleToDistributeCoinsResponse) XXX_DiscardUnknown 

func (m *ModuleToDistributeCoinsResponse) XXX_DiscardUnknown()

func (*ModuleToDistributeCoinsResponse) XXX_Marshal 

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

func (*ModuleToDistributeCoinsResponse) XXX_Merge 

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

func (*ModuleToDistributeCoinsResponse) XXX_Size 

func (m *ModuleToDistributeCoinsResponse) XXX_Size() int

func (*ModuleToDistributeCoinsResponse) XXX_Unmarshal 

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

type Params 

type Params struct {
}

Params holds parameters for the streamer module

func DefaultParams 

func DefaultParams() Params

DefaultParams returns a default set of parameters

func NewParams 

func NewParams() Params

NewParams creates a new Params instance

func (*Params) Descriptor 

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

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ParamSetPairs 

func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs

ParamSetPairs get the params.ParamSet

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

Validate validates the set of params

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// ModuleToDistributeCoins returns coins that are going to be distributed
	ModuleToDistributeCoins(ctx context.Context, in *ModuleToDistributeCoinsRequest, opts ...grpc.CallOption) (*ModuleToDistributeCoinsResponse, error)
	// StreamByID returns streams by their respective ID
	StreamByID(ctx context.Context, in *StreamByIDRequest, opts ...grpc.CallOption) (*StreamByIDResponse, error)
	// Streams returns both upcoming and active streams
	Streams(ctx context.Context, in *StreamsRequest, opts ...grpc.CallOption) (*StreamsResponse, error)
	// ActiveStreams returns active streams
	ActiveStreams(ctx context.Context, in *ActiveStreamsRequest, opts ...grpc.CallOption) (*ActiveStreamsResponse, error)
	// Returns scheduled streams that have not yet occurred
	UpcomingStreams(ctx context.Context, in *UpcomingStreamsRequest, opts ...grpc.CallOption) (*UpcomingStreamsResponse, 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 QueryServer 

type QueryServer interface {
	// ModuleToDistributeCoins returns coins that are going to be distributed
	ModuleToDistributeCoins(context.Context, *ModuleToDistributeCoinsRequest) (*ModuleToDistributeCoinsResponse, error)
	// StreamByID returns streams by their respective ID
	StreamByID(context.Context, *StreamByIDRequest) (*StreamByIDResponse, error)
	// Streams returns both upcoming and active streams
	Streams(context.Context, *StreamsRequest) (*StreamsResponse, error)
	// ActiveStreams returns active streams
	ActiveStreams(context.Context, *ActiveStreamsRequest) (*ActiveStreamsResponse, error)
	// Returns scheduled streams that have not yet occurred
	UpcomingStreams(context.Context, *UpcomingStreamsRequest) (*UpcomingStreamsResponse, error)
}

QueryServer is the server API for Query service.

type ReplaceStreamDistributionProposal 

type ReplaceStreamDistributionProposal struct {
	Title       string        `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Description string        `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	StreamId    uint64        `protobuf:"varint,3,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Records     []DistrRecord `protobuf:"bytes,4,rep,name=records,proto3" json:"records"`
}

ReplaceStreamDistributionProposal is a gov Content type for updating a stream If a ReplaceStreamDistributionProposal passes, the proposal’s records override the existing DistrRecords set in the module. Each record has a specified gauge id and weight, and the incentives are distributed to each gauge according to weight/total_weight.

func NewReplaceStreamDistributionProposal 

func NewReplaceStreamDistributionProposal(title, description string, streamId uint64, distrToRecords []DistrRecord) *ReplaceStreamDistributionProposal

NewReplaceStreamDistributionProposal creates a new ReplaceStreamDistribution proposal.

func (*ReplaceStreamDistributionProposal) Descriptor 

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

func (*ReplaceStreamDistributionProposal) Equal 

func (this *ReplaceStreamDistributionProposal) Equal(that interface{}) bool

func (*ReplaceStreamDistributionProposal) GetDescription 

func (csp *ReplaceStreamDistributionProposal) GetDescription() string

GetDescription returns the description of a community pool spend proposal.

func (*ReplaceStreamDistributionProposal) GetTitle 

func (csp *ReplaceStreamDistributionProposal) GetTitle() string

GetTitle returns the title of a community pool spend proposal.

func (*ReplaceStreamDistributionProposal) Marshal 

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

func (*ReplaceStreamDistributionProposal) MarshalTo 

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

func (*ReplaceStreamDistributionProposal) MarshalToSizedBuffer 

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

func (*ReplaceStreamDistributionProposal) ProposalRoute 

func (csp *ReplaceStreamDistributionProposal) ProposalRoute() string

GetDescription returns the routing key of a community pool spend proposal.

func (*ReplaceStreamDistributionProposal) ProposalType 

func (csp *ReplaceStreamDistributionProposal) ProposalType() string

ProposalType returns the type of a community pool spend proposal.

func (*ReplaceStreamDistributionProposal) ProtoMessage 

func (*ReplaceStreamDistributionProposal) ProtoMessage()

func (*ReplaceStreamDistributionProposal) Reset 

func (m *ReplaceStreamDistributionProposal) Reset()

func (*ReplaceStreamDistributionProposal) Size 

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

func (ReplaceStreamDistributionProposal) String 

func (csp ReplaceStreamDistributionProposal) String() string

String implements the Stringer interface.

func (*ReplaceStreamDistributionProposal) Unmarshal 

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

func (*ReplaceStreamDistributionProposal) ValidateBasic 

func (csp *ReplaceStreamDistributionProposal) ValidateBasic() error

ValidateBasic runs basic stateless validity checks

func (*ReplaceStreamDistributionProposal) XXX_DiscardUnknown 

func (m *ReplaceStreamDistributionProposal) XXX_DiscardUnknown()

func (*ReplaceStreamDistributionProposal) XXX_Marshal 

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

func (*ReplaceStreamDistributionProposal) XXX_Merge 

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

func (*ReplaceStreamDistributionProposal) XXX_Size 

func (m *ReplaceStreamDistributionProposal) XXX_Size() int

func (*ReplaceStreamDistributionProposal) XXX_Unmarshal 

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

type Stream 

type Stream struct {
	// id is the unique ID of a Stream
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// distribute_to is the distr_info.
	DistributeTo *DistrInfo `protobuf:"bytes,2,opt,name=distribute_to,json=distributeTo,proto3" json:"distribute_to,omitempty"`
	// coins is the total amount of coins that have been in the stream
	// Can distribute multiple coin denoms
	Coins github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,3,rep,name=coins,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"coins"`
	// start_time is the distribution start time
	StartTime time.Time `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time" yaml:"start_time"`
	// distr_epoch_identifier is what epoch type di-stribution will be triggered by
	// (day, week, etc.)
	DistrEpochIdentifier string `` /* 153-byte string literal not displayed */
	// num_epochs_paid_over is the number of total epochs distribution will be
	// completed over
	NumEpochsPaidOver uint64 `protobuf:"varint,6,opt,name=num_epochs_paid_over,json=numEpochsPaidOver,proto3" json:"num_epochs_paid_over,omitempty"`
	// filled_epochs is the number of epochs distribution has been completed on
	// already
	FilledEpochs uint64 `protobuf:"varint,7,opt,name=filled_epochs,json=filledEpochs,proto3" json:"filled_epochs,omitempty"`
	// distributed_coins are coins that have been distributed already
	DistributedCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 153-byte string literal not displayed */
}

Stream is an object that stores and distributes yields to recipients who satisfy certain conditions. Currently streams support conditions around the duration for which a given denom is locked.

func NewStream 

func NewStream(id uint64, distrTo *DistrInfo, coins sdk.Coins, startTime time.Time, epochIdentifier string, numEpochsPaidOver uint64) Stream

NewStream creates a new stream struct given the required stream parameters.

func (*Stream) Descriptor 

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

func (*Stream) GetCoins 

func (m *Stream) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins

func (*Stream) GetDistrEpochIdentifier 

func (m *Stream) GetDistrEpochIdentifier() string

func (*Stream) GetDistributeTo 

func (m *Stream) GetDistributeTo() *DistrInfo

func (*Stream) GetDistributedCoins 

func (m *Stream) GetDistributedCoins() github_com_cosmos_cosmos_sdk_types.Coins

func (*Stream) GetFilledEpochs 

func (m *Stream) GetFilledEpochs() uint64

func (*Stream) GetId 

func (m *Stream) GetId() uint64

func (*Stream) GetNumEpochsPaidOver 

func (m *Stream) GetNumEpochsPaidOver() uint64

func (*Stream) GetStartTime 

func (m *Stream) GetStartTime() time.Time

func (Stream) IsActiveStream 

func (stream Stream) IsActiveStream(curTime time.Time) bool

IsActiveStream returns true if the stream is in an active state during the provided time.

func (Stream) IsFinishedStream 

func (stream Stream) IsFinishedStream(curTime time.Time) bool

IsFinishedStream returns true if the stream is in a finished state during the provided time.

func (Stream) IsUpcomingStream 

func (stream Stream) IsUpcomingStream(curTime time.Time) bool

IsUpcomingStream returns true if the stream's distribution start time is after the provided time.

func (*Stream) Marshal 

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

func (*Stream) MarshalTo 

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

func (*Stream) MarshalToSizedBuffer 

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

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) Reset 

func (m *Stream) Reset()

func (*Stream) Size 

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

func (*Stream) String 

func (m *Stream) String() string

func (*Stream) Unmarshal 

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

func (*Stream) XXX_DiscardUnknown 

func (m *Stream) XXX_DiscardUnknown()

func (*Stream) XXX_Marshal 

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

func (*Stream) XXX_Merge 

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

func (*Stream) XXX_Size 

func (m *Stream) XXX_Size() int

func (*Stream) XXX_Unmarshal 

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

type StreamByIDRequest 

type StreamByIDRequest struct {
	// Gague ID being queried
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*StreamByIDRequest) Descriptor 

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

func (*StreamByIDRequest) GetId 

func (m *StreamByIDRequest) GetId() uint64

func (*StreamByIDRequest) Marshal 

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

func (*StreamByIDRequest) MarshalTo 

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

func (*StreamByIDRequest) MarshalToSizedBuffer 

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

func (*StreamByIDRequest) ProtoMessage 

func (*StreamByIDRequest) ProtoMessage()

func (*StreamByIDRequest) Reset 

func (m *StreamByIDRequest) Reset()

func (*StreamByIDRequest) Size 

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

func (*StreamByIDRequest) String 

func (m *StreamByIDRequest) String() string

func (*StreamByIDRequest) Unmarshal 

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

func (*StreamByIDRequest) XXX_DiscardUnknown 

func (m *StreamByIDRequest) XXX_DiscardUnknown()

func (*StreamByIDRequest) XXX_Marshal 

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

func (*StreamByIDRequest) XXX_Merge 

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

func (*StreamByIDRequest) XXX_Size 

func (m *StreamByIDRequest) XXX_Size() int

func (*StreamByIDRequest) XXX_Unmarshal 

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

type StreamByIDResponse 

type StreamByIDResponse struct {
	// Stream that corresponds to provided gague ID
	Stream *Stream `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
}

func (*StreamByIDResponse) Descriptor 

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

func (*StreamByIDResponse) GetStream 

func (m *StreamByIDResponse) GetStream() *Stream

func (*StreamByIDResponse) Marshal 

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

func (*StreamByIDResponse) MarshalTo 

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

func (*StreamByIDResponse) MarshalToSizedBuffer 

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

func (*StreamByIDResponse) ProtoMessage 

func (*StreamByIDResponse) ProtoMessage()

func (*StreamByIDResponse) Reset 

func (m *StreamByIDResponse) Reset()

func (*StreamByIDResponse) Size 

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

func (*StreamByIDResponse) String 

func (m *StreamByIDResponse) String() string

func (*StreamByIDResponse) Unmarshal 

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

func (*StreamByIDResponse) XXX_DiscardUnknown 

func (m *StreamByIDResponse) XXX_DiscardUnknown()

func (*StreamByIDResponse) XXX_Marshal 

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

func (*StreamByIDResponse) XXX_Merge 

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

func (*StreamByIDResponse) XXX_Size 

func (m *StreamByIDResponse) XXX_Size() int

func (*StreamByIDResponse) XXX_Unmarshal 

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

type StreamsRequest 

type StreamsRequest struct {
	// Pagination defines pagination for the request
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*StreamsRequest) Descriptor 

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

func (*StreamsRequest) GetPagination 

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

func (*StreamsRequest) Marshal 

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

func (*StreamsRequest) MarshalTo 

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

func (*StreamsRequest) MarshalToSizedBuffer 

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

func (*StreamsRequest) ProtoMessage 

func (*StreamsRequest) ProtoMessage()

func (*StreamsRequest) Reset 

func (m *StreamsRequest) Reset()

func (*StreamsRequest) Size 

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

func (*StreamsRequest) String 

func (m *StreamsRequest) String() string

func (*StreamsRequest) Unmarshal 

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

func (*StreamsRequest) XXX_DiscardUnknown 

func (m *StreamsRequest) XXX_DiscardUnknown()

func (*StreamsRequest) XXX_Marshal 

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

func (*StreamsRequest) XXX_Merge 

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

func (*StreamsRequest) XXX_Size 

func (m *StreamsRequest) XXX_Size() int

func (*StreamsRequest) XXX_Unmarshal 

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

type StreamsResponse 

type StreamsResponse struct {
	// Upcoming and active streams
	Data []Stream `protobuf:"bytes,1,rep,name=data,proto3" json:"data"`
	// Pagination defines pagination for the response
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*StreamsResponse) Descriptor 

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

func (*StreamsResponse) GetData 

func (m *StreamsResponse) GetData() []Stream

func (*StreamsResponse) GetPagination 

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

func (*StreamsResponse) Marshal 

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

func (*StreamsResponse) MarshalTo 

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

func (*StreamsResponse) MarshalToSizedBuffer 

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

func (*StreamsResponse) ProtoMessage 

func (*StreamsResponse) ProtoMessage()

func (*StreamsResponse) Reset 

func (m *StreamsResponse) Reset()

func (*StreamsResponse) Size 

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

func (*StreamsResponse) String 

func (m *StreamsResponse) String() string

func (*StreamsResponse) Unmarshal 

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

func (*StreamsResponse) XXX_DiscardUnknown 

func (m *StreamsResponse) XXX_DiscardUnknown()

func (*StreamsResponse) XXX_Marshal 

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

func (*StreamsResponse) XXX_Merge 

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

func (*StreamsResponse) XXX_Size 

func (m *StreamsResponse) XXX_Size() int

func (*StreamsResponse) XXX_Unmarshal 

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

type TerminateStreamProposal 

type TerminateStreamProposal struct {
	Title       string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	StreamId    uint64 `protobuf:"varint,4,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
}

func NewTerminateStreamProposal 

func NewTerminateStreamProposal(title, description string, streamId uint64) *TerminateStreamProposal

NewTerminateStreamProposal creates a new stop stream proposal.

func (*TerminateStreamProposal) Descriptor 

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

func (*TerminateStreamProposal) Equal 

func (this *TerminateStreamProposal) Equal(that interface{}) bool

func (*TerminateStreamProposal) GetDescription 

func (csp *TerminateStreamProposal) GetDescription() string

GetDescription returns the description of a community pool spend proposal.

func (*TerminateStreamProposal) GetTitle 

func (csp *TerminateStreamProposal) GetTitle() string

GetTitle returns the title of a community pool spend proposal.

func (*TerminateStreamProposal) Marshal 

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

func (*TerminateStreamProposal) MarshalTo 

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

func (*TerminateStreamProposal) MarshalToSizedBuffer 

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

func (*TerminateStreamProposal) ProposalRoute 

func (csp *TerminateStreamProposal) ProposalRoute() string

GetDescription returns the routing key of a community pool spend proposal.

func (*TerminateStreamProposal) ProposalType 

func (csp *TerminateStreamProposal) ProposalType() string

ProposalType returns the type of a community pool spend proposal.

func (*TerminateStreamProposal) ProtoMessage 

func (*TerminateStreamProposal) ProtoMessage()

func (*TerminateStreamProposal) Reset 

func (m *TerminateStreamProposal) Reset()

func (*TerminateStreamProposal) Size 

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

func (TerminateStreamProposal) String 

func (csp TerminateStreamProposal) String() string

String implements the Stringer interface.

func (*TerminateStreamProposal) Unmarshal 

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

func (*TerminateStreamProposal) ValidateBasic 

func (csp *TerminateStreamProposal) ValidateBasic() error

ValidateBasic runs basic stateless validity checks

func (*TerminateStreamProposal) XXX_DiscardUnknown 

func (m *TerminateStreamProposal) XXX_DiscardUnknown()

func (*TerminateStreamProposal) XXX_Marshal 

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

func (*TerminateStreamProposal) XXX_Merge 

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

func (*TerminateStreamProposal) XXX_Size 

func (m *TerminateStreamProposal) XXX_Size() int

func (*TerminateStreamProposal) XXX_Unmarshal 

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

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) ActiveStreams 

func (*UnimplementedQueryServer) ActiveStreams(ctx context.Context, req *ActiveStreamsRequest) (*ActiveStreamsResponse, error)

func (*UnimplementedQueryServer) ModuleToDistributeCoins 

func (*UnimplementedQueryServer) ModuleToDistributeCoins(ctx context.Context, req *ModuleToDistributeCoinsRequest) (*ModuleToDistributeCoinsResponse, error)

func (*UnimplementedQueryServer) StreamByID 

func (*UnimplementedQueryServer) StreamByID(ctx context.Context, req *StreamByIDRequest) (*StreamByIDResponse, error)

func (*UnimplementedQueryServer) Streams 

func (*UnimplementedQueryServer) Streams(ctx context.Context, req *StreamsRequest) (*StreamsResponse, error)

func (*UnimplementedQueryServer) UpcomingStreams 

func (*UnimplementedQueryServer) UpcomingStreams(ctx context.Context, req *UpcomingStreamsRequest) (*UpcomingStreamsResponse, error)

type UpcomingStreamsRequest 

type UpcomingStreamsRequest struct {
	// Pagination defines pagination for the request
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*UpcomingStreamsRequest) Descriptor 

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

func (*UpcomingStreamsRequest) GetPagination 

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

func (*UpcomingStreamsRequest) Marshal 

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

func (*UpcomingStreamsRequest) MarshalTo 

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

func (*UpcomingStreamsRequest) MarshalToSizedBuffer 

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

func (*UpcomingStreamsRequest) ProtoMessage 

func (*UpcomingStreamsRequest) ProtoMessage()

func (*UpcomingStreamsRequest) Reset 

func (m *UpcomingStreamsRequest) Reset()

func (*UpcomingStreamsRequest) Size 

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

func (*UpcomingStreamsRequest) String 

func (m *UpcomingStreamsRequest) String() string

func (*UpcomingStreamsRequest) Unmarshal 

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

func (*UpcomingStreamsRequest) XXX_DiscardUnknown 

func (m *UpcomingStreamsRequest) XXX_DiscardUnknown()

func (*UpcomingStreamsRequest) XXX_Marshal 

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

func (*UpcomingStreamsRequest) XXX_Merge 

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

func (*UpcomingStreamsRequest) XXX_Size 

func (m *UpcomingStreamsRequest) XXX_Size() int

func (*UpcomingStreamsRequest) XXX_Unmarshal 

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

type UpcomingStreamsResponse 

type UpcomingStreamsResponse struct {
	// Streams whose distribution is upcoming
	Data []Stream `protobuf:"bytes,1,rep,name=data,proto3" json:"data"`
	// Pagination defines pagination for the response
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*UpcomingStreamsResponse) Descriptor 

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

func (*UpcomingStreamsResponse) GetData 

func (m *UpcomingStreamsResponse) GetData() []Stream

func (*UpcomingStreamsResponse) GetPagination 

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

func (*UpcomingStreamsResponse) Marshal 

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

func (*UpcomingStreamsResponse) MarshalTo 

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

func (*UpcomingStreamsResponse) MarshalToSizedBuffer 

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

func (*UpcomingStreamsResponse) ProtoMessage 

func (*UpcomingStreamsResponse) ProtoMessage()

func (*UpcomingStreamsResponse) Reset 

func (m *UpcomingStreamsResponse) Reset()

func (*UpcomingStreamsResponse) Size 

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

func (*UpcomingStreamsResponse) String 

func (m *UpcomingStreamsResponse) String() string

func (*UpcomingStreamsResponse) Unmarshal 

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

func (*UpcomingStreamsResponse) XXX_DiscardUnknown 

func (m *UpcomingStreamsResponse) XXX_DiscardUnknown()

func (*UpcomingStreamsResponse) XXX_Marshal 

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

func (*UpcomingStreamsResponse) XXX_Merge 

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

func (*UpcomingStreamsResponse) XXX_Size 

func (m *UpcomingStreamsResponse) XXX_Size() int

func (*UpcomingStreamsResponse) XXX_Unmarshal 

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

type UpdateStreamDistributionProposal 

type UpdateStreamDistributionProposal struct {
	Title       string        `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Description string        `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	StreamId    uint64        `protobuf:"varint,3,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Records     []DistrRecord `protobuf:"bytes,4,rep,name=records,proto3" json:"records"`
}

For example: if the existing DistrRecords were: [(Gauge 0, 5), (Gauge 1, 6), (Gauge 2, 6)] An UpdatePoolIncentivesProposal includes [(Gauge 1, 0), (Gauge 2, 4), (Gauge 3, 10)] This would delete Gauge 1, Edit Gauge 2, and Add Gauge 3 The result DistrRecords in state would be: [(Gauge 0, 5), (Gauge 2, 4), (Gauge 3, 10)]

func NewUpdateStreamDistributionProposal 

func NewUpdateStreamDistributionProposal(title, description string, streamId uint64, distrToRecords []DistrRecord) *UpdateStreamDistributionProposal

NewUpdateStreamDistributionProposal creates a new UpdateStreamDistribution proposal.

func (*UpdateStreamDistributionProposal) Descriptor 

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

func (*UpdateStreamDistributionProposal) Equal 

func (this *UpdateStreamDistributionProposal) Equal(that interface{}) bool

func (*UpdateStreamDistributionProposal) GetDescription 

func (csp *UpdateStreamDistributionProposal) GetDescription() string

GetDescription returns the description of a community pool spend proposal.

func (*UpdateStreamDistributionProposal) GetTitle 

func (csp *UpdateStreamDistributionProposal) GetTitle() string

GetTitle returns the title of a community pool spend proposal.

func (*UpdateStreamDistributionProposal) Marshal 

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

func (*UpdateStreamDistributionProposal) MarshalTo 

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

func (*UpdateStreamDistributionProposal) MarshalToSizedBuffer 

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

func (*UpdateStreamDistributionProposal) ProposalRoute 

func (csp *UpdateStreamDistributionProposal) ProposalRoute() string

GetDescription returns the routing key of a community pool spend proposal.

func (*UpdateStreamDistributionProposal) ProposalType 

func (csp *UpdateStreamDistributionProposal) ProposalType() string

ProposalType returns the type of a community pool spend proposal.

func (*UpdateStreamDistributionProposal) ProtoMessage 

func (*UpdateStreamDistributionProposal) ProtoMessage()

func (*UpdateStreamDistributionProposal) Reset 

func (m *UpdateStreamDistributionProposal) Reset()

func (*UpdateStreamDistributionProposal) Size 

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

func (UpdateStreamDistributionProposal) String 

func (csp UpdateStreamDistributionProposal) String() string

String implements the Stringer interface.

func (*UpdateStreamDistributionProposal) Unmarshal 

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

func (*UpdateStreamDistributionProposal) ValidateBasic 

func (csp *UpdateStreamDistributionProposal) ValidateBasic() error

ValidateBasic runs basic stateless validity checks

func (*UpdateStreamDistributionProposal) XXX_DiscardUnknown 

func (m *UpdateStreamDistributionProposal) XXX_DiscardUnknown()

func (*UpdateStreamDistributionProposal) XXX_Marshal 

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

func (*UpdateStreamDistributionProposal) XXX_Merge 

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

func (*UpdateStreamDistributionProposal) XXX_Size 

func (m *UpdateStreamDistributionProposal) XXX_Size() int

func (*UpdateStreamDistributionProposal) XXX_Unmarshal 

func (m *UpdateStreamDistributionProposal) XXX_Unmarshal(b []byte) 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.