types

package
v0.17.0 Latest Latest
Warning

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

 Go to latest Published: Jan 10, 2023 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	ModuleName = "incentivization"
	StoreKey   = ModuleName
)

Variables

View Source 
var (
	ErrMinLockupDurationTooLow        = sdkerrors.Register(ModuleName, 1, "minimum lockup duration too low")
	ErrStartTimeInPast                = sdkerrors.Register(ModuleName, 2, "incentivization program start time is in the past")
	ErrEpochsTooLow                   = sdkerrors.Register(ModuleName, 3, "number of epochs too low")
	ErrIncentivizationProgramNotFound = sdkerrors.Register(ModuleName, 4, "incentivization program not found")
)
View Source 
var (
	ErrInvalidLengthIncentivization        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowIncentivization          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupIncentivization = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterInterfaces 

func RegisterInterfaces(r codectypes.InterfaceRegistry)

func RegisterMsgHandler 

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

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

func RegisterMsgHandlerClient 

func RegisterMsgHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MsgClient) error

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

func RegisterMsgHandlerFromEndpoint 

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

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

func RegisterMsgHandlerServer 

func RegisterMsgHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MsgServer) error

RegisterMsgHandlerServer registers the http handlers for service Msg to "mux". UnaryRPC :call MsgServer 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 (such as grpc.SendHeader, etc) to stop working. Consider using RegisterMsgHandlerFromEndpoint instead.

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler added in v0.2.7 

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 added in v0.2.7 

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 added in v0.2.7 

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 added in v0.2.7 

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 (such as grpc.SendHeader, etc) to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type GenesisState 

type GenesisState struct {
	IncentivizationPrograms []*IncentivizationProgram `` /* 130-byte string literal not displayed */
}

func DefaultGenesis 

func DefaultGenesis() *GenesisState

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetIncentivizationPrograms 

func (m *GenesisState) GetIncentivizationPrograms() []*IncentivizationProgram

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 (m *GenesisState) Validate() error

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 IncentivizationProgram 

type IncentivizationProgram struct {
	// id defines the unique uint64 id of the program
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// escrow_address defines the escrow module account address
	// for the incentivization program.
	EscrowAddress string `protobuf:"bytes,2,opt,name=escrow_address,json=escrowAddress,proto3" json:"escrow_address,omitempty"`
	// remaining_epochs defines the number of epochs left before the incentivization
	// program can be considered finalized.
	RemainingEpochs int64 `protobuf:"varint,3,opt,name=remaining_epochs,json=remainingEpochs,proto3" json:"remaining_epochs,omitempty"`
	// lp_denom defines the liquidity pool denom that is being incentivized.
	LpDenom string `protobuf:"bytes,4,opt,name=lp_denom,json=lpDenom,proto3" json:"lp_denom,omitempty"`
	// min_lockup_duration defines the minimum lp_denom lockup period
	// required to get the epochs' rewards.
	MinLockupDuration time.Duration `protobuf:"bytes,5,opt,name=min_lockup_duration,json=minLockupDuration,proto3,stdduration" json:"min_lockup_duration"`
	// start_time defines the incentivization program start time.
	StartTime time.Time `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time"`
}

IncentivizationProgram defines how an incentivization program looks like.

func (*IncentivizationProgram) Descriptor 

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

func (*IncentivizationProgram) GetEscrowAddress 

func (m *IncentivizationProgram) GetEscrowAddress() string

func (*IncentivizationProgram) GetId 

func (m *IncentivizationProgram) GetId() uint64

func (*IncentivizationProgram) GetLpDenom 

func (m *IncentivizationProgram) GetLpDenom() string

func (*IncentivizationProgram) GetMinLockupDuration 

func (m *IncentivizationProgram) GetMinLockupDuration() time.Duration

func (*IncentivizationProgram) GetRemainingEpochs 

func (m *IncentivizationProgram) GetRemainingEpochs() int64

func (*IncentivizationProgram) GetStartTime 

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

func (*IncentivizationProgram) Marshal 

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

func (*IncentivizationProgram) MarshalTo 

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

func (*IncentivizationProgram) MarshalToSizedBuffer 

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

func (*IncentivizationProgram) ProtoMessage 

func (*IncentivizationProgram) ProtoMessage()

func (*IncentivizationProgram) Reset 

func (m *IncentivizationProgram) Reset()

func (*IncentivizationProgram) Size 

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

func (*IncentivizationProgram) String 

func (m *IncentivizationProgram) String() string

func (*IncentivizationProgram) Unmarshal 

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

func (*IncentivizationProgram) XXX_DiscardUnknown 

func (m *IncentivizationProgram) XXX_DiscardUnknown()

func (*IncentivizationProgram) XXX_Marshal 

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

func (*IncentivizationProgram) XXX_Merge 

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

func (*IncentivizationProgram) XXX_Size 

func (m *IncentivizationProgram) XXX_Size() int

func (*IncentivizationProgram) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// CreateIncentivizationProgram allows an entity to create an incentivization program for a liquidity pool.
	CreateIncentivizationProgram(ctx context.Context, in *MsgCreateIncentivizationProgram, opts ...grpc.CallOption) (*MsgCreateIncentivizationProgramResponse, error)
	// FundIncentivizationProgram allows an entity to fund an already existing incentivization program with more coins.
	FundIncentivizationProgram(ctx context.Context, in *MsgFundIncentivizationProgram, opts ...grpc.CallOption) (*MsgFundIncentivizationProgramResponse, 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 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgCreateIncentivizationProgram 

type MsgCreateIncentivizationProgram struct {
	// sender defines the sender of the msg that needs to be signed.
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// lp_denom defines the liquidity pool denom that we want to incentivize.
	LpDenom string `protobuf:"bytes,2,opt,name=lp_denom,json=lpDenom,proto3" json:"lp_denom,omitempty"`
	// min_lockup_duration defines the minimum lockup duration
	// required on the lp_denom to get the incentivization.
	MinLockupDuration *time.Duration `` /* 126-byte string literal not displayed */
	// start_time identifies when the incentivization starts.
	StartTime *time.Time `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time,omitempty"`
	// epochs defines the number of epochs the incentivization
	// program will last.
	Epochs int64 `protobuf:"varint,5,opt,name=epochs,proto3" json:"epochs,omitempty"`
	// initial_funds defines the initial funds to bootstrap the incentivization program's escrow.
	// This is optional.
	InitialFunds github_com_cosmos_cosmos_sdk_types.Coins `` /* 141-byte string literal not displayed */
}

MsgCreateIncentivizationProgram is the request needed for the CreateIncentivizationProgram RPC.

func (*MsgCreateIncentivizationProgram) Descriptor 

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

func (*MsgCreateIncentivizationProgram) GetEpochs 

func (m *MsgCreateIncentivizationProgram) GetEpochs() int64

func (*MsgCreateIncentivizationProgram) GetInitialFunds 

func (m *MsgCreateIncentivizationProgram) GetInitialFunds() github_com_cosmos_cosmos_sdk_types.Coins

func (*MsgCreateIncentivizationProgram) GetLpDenom 

func (m *MsgCreateIncentivizationProgram) GetLpDenom() string

func (*MsgCreateIncentivizationProgram) GetMinLockupDuration 

func (m *MsgCreateIncentivizationProgram) GetMinLockupDuration() *time.Duration

func (*MsgCreateIncentivizationProgram) GetSender 

func (m *MsgCreateIncentivizationProgram) GetSender() string

func (*MsgCreateIncentivizationProgram) GetSigners 

func (m *MsgCreateIncentivizationProgram) GetSigners() []sdk.AccAddress

func (*MsgCreateIncentivizationProgram) GetStartTime 

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

func (*MsgCreateIncentivizationProgram) Marshal 

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

func (*MsgCreateIncentivizationProgram) MarshalTo 

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

func (*MsgCreateIncentivizationProgram) MarshalToSizedBuffer 

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

func (*MsgCreateIncentivizationProgram) ProtoMessage 

func (*MsgCreateIncentivizationProgram) ProtoMessage()

func (*MsgCreateIncentivizationProgram) Reset 

func (m *MsgCreateIncentivizationProgram) Reset()

func (*MsgCreateIncentivizationProgram) Size 

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

func (*MsgCreateIncentivizationProgram) String 

func (m *MsgCreateIncentivizationProgram) String() string

func (*MsgCreateIncentivizationProgram) Unmarshal 

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

func (*MsgCreateIncentivizationProgram) ValidateBasic 

func (m *MsgCreateIncentivizationProgram) ValidateBasic() error

func (*MsgCreateIncentivizationProgram) XXX_DiscardUnknown 

func (m *MsgCreateIncentivizationProgram) XXX_DiscardUnknown()

func (*MsgCreateIncentivizationProgram) XXX_Marshal 

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

func (*MsgCreateIncentivizationProgram) XXX_Merge 

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

func (*MsgCreateIncentivizationProgram) XXX_Size 

func (m *MsgCreateIncentivizationProgram) XXX_Size() int

func (*MsgCreateIncentivizationProgram) XXX_Unmarshal 

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

type MsgCreateIncentivizationProgramResponse 

type MsgCreateIncentivizationProgramResponse struct {
	// program_id defines the incentivization program unique identifier.
	ProgramId uint64 `protobuf:"varint,1,opt,name=program_id,json=programId,proto3" json:"program_id,omitempty"`
}

MsgCreateIncentivizationProgramResponse is the response returned by the CreateIncentivizationProgram RPC.

func (*MsgCreateIncentivizationProgramResponse) Descriptor 

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

func (*MsgCreateIncentivizationProgramResponse) GetProgramId 

func (m *MsgCreateIncentivizationProgramResponse) GetProgramId() uint64

func (*MsgCreateIncentivizationProgramResponse) Marshal 

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

func (*MsgCreateIncentivizationProgramResponse) MarshalTo 

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

func (*MsgCreateIncentivizationProgramResponse) MarshalToSizedBuffer 

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

func (*MsgCreateIncentivizationProgramResponse) ProtoMessage 

func (*MsgCreateIncentivizationProgramResponse) ProtoMessage()

func (*MsgCreateIncentivizationProgramResponse) Reset 

func (m *MsgCreateIncentivizationProgramResponse) Reset()

func (*MsgCreateIncentivizationProgramResponse) Size 

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

func (*MsgCreateIncentivizationProgramResponse) String 

func (m *MsgCreateIncentivizationProgramResponse) String() string

func (*MsgCreateIncentivizationProgramResponse) Unmarshal 

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

func (*MsgCreateIncentivizationProgramResponse) XXX_DiscardUnknown 

func (m *MsgCreateIncentivizationProgramResponse) XXX_DiscardUnknown()

func (*MsgCreateIncentivizationProgramResponse) XXX_Marshal 

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

func (*MsgCreateIncentivizationProgramResponse) XXX_Merge 

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

func (*MsgCreateIncentivizationProgramResponse) XXX_Size 

func (m *MsgCreateIncentivizationProgramResponse) XXX_Size() int

func (*MsgCreateIncentivizationProgramResponse) XXX_Unmarshal 

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

type MsgFundIncentivizationProgram 

type MsgFundIncentivizationProgram struct {
	// sender is the sender of the requests
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// id marks the incentivization program id.
	Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// funds is the amount of money sender deposits in the program funding escrow.
	Funds github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,3,rep,name=funds,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"funds"`
}

MsgFundIncentivizationProgram is the request for the FundIncentivizationProgram RPC.

func (*MsgFundIncentivizationProgram) Descriptor 

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

func (*MsgFundIncentivizationProgram) GetFunds 

func (m *MsgFundIncentivizationProgram) GetFunds() github_com_cosmos_cosmos_sdk_types.Coins

func (*MsgFundIncentivizationProgram) GetId 

func (m *MsgFundIncentivizationProgram) GetId() uint64

func (*MsgFundIncentivizationProgram) GetSender 

func (m *MsgFundIncentivizationProgram) GetSender() string

func (*MsgFundIncentivizationProgram) GetSigners 

func (m *MsgFundIncentivizationProgram) GetSigners() []sdk.AccAddress

func (*MsgFundIncentivizationProgram) Marshal 

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

func (*MsgFundIncentivizationProgram) MarshalTo 

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

func (*MsgFundIncentivizationProgram) MarshalToSizedBuffer 

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

func (*MsgFundIncentivizationProgram) ProtoMessage 

func (*MsgFundIncentivizationProgram) ProtoMessage()

func (*MsgFundIncentivizationProgram) Reset 

func (m *MsgFundIncentivizationProgram) Reset()

func (*MsgFundIncentivizationProgram) Size 

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

func (*MsgFundIncentivizationProgram) String 

func (m *MsgFundIncentivizationProgram) String() string

func (*MsgFundIncentivizationProgram) Unmarshal 

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

func (*MsgFundIncentivizationProgram) ValidateBasic 

func (m *MsgFundIncentivizationProgram) ValidateBasic() error

func (*MsgFundIncentivizationProgram) XXX_DiscardUnknown 

func (m *MsgFundIncentivizationProgram) XXX_DiscardUnknown()

func (*MsgFundIncentivizationProgram) XXX_Marshal 

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

func (*MsgFundIncentivizationProgram) XXX_Merge 

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

func (*MsgFundIncentivizationProgram) XXX_Size 

func (m *MsgFundIncentivizationProgram) XXX_Size() int

func (*MsgFundIncentivizationProgram) XXX_Unmarshal 

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

type MsgFundIncentivizationProgramResponse 

type MsgFundIncentivizationProgramResponse struct {
}

func (*MsgFundIncentivizationProgramResponse) Descriptor 

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

func (*MsgFundIncentivizationProgramResponse) Marshal 

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

func (*MsgFundIncentivizationProgramResponse) MarshalTo 

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

func (*MsgFundIncentivizationProgramResponse) MarshalToSizedBuffer 

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

func (*MsgFundIncentivizationProgramResponse) ProtoMessage 

func (*MsgFundIncentivizationProgramResponse) ProtoMessage()

func (*MsgFundIncentivizationProgramResponse) Reset 

func (m *MsgFundIncentivizationProgramResponse) Reset()

func (*MsgFundIncentivizationProgramResponse) Size 

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

func (*MsgFundIncentivizationProgramResponse) String 

func (m *MsgFundIncentivizationProgramResponse) String() string

func (*MsgFundIncentivizationProgramResponse) Unmarshal 

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

func (*MsgFundIncentivizationProgramResponse) XXX_DiscardUnknown 

func (m *MsgFundIncentivizationProgramResponse) XXX_DiscardUnknown()

func (*MsgFundIncentivizationProgramResponse) XXX_Marshal 

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

func (*MsgFundIncentivizationProgramResponse) XXX_Merge 

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

func (*MsgFundIncentivizationProgramResponse) XXX_Size 

func (m *MsgFundIncentivizationProgramResponse) XXX_Size() int

func (*MsgFundIncentivizationProgramResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// CreateIncentivizationProgram allows an entity to create an incentivization program for a liquidity pool.
	CreateIncentivizationProgram(context.Context, *MsgCreateIncentivizationProgram) (*MsgCreateIncentivizationProgramResponse, error)
	// FundIncentivizationProgram allows an entity to fund an already existing incentivization program with more coins.
	FundIncentivizationProgram(context.Context, *MsgFundIncentivizationProgram) (*MsgFundIncentivizationProgramResponse, error)
}

MsgServer is the server API for Msg service.

type QueryClient 

type QueryClient interface {
	IncentivizationProgram(ctx context.Context, in *QueryIncentivizationProgramRequest, opts ...grpc.CallOption) (*QueryIncentivizationProgramResponse, error)
	IncentivizationPrograms(ctx context.Context, in *QueryIncentivizationProgramsRequest, opts ...grpc.CallOption) (*QueryIncentivizationProgramsResponse, 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 QueryIncentivizationProgramRequest added in v0.2.7 

type QueryIncentivizationProgramRequest struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*QueryIncentivizationProgramRequest) Descriptor added in v0.2.7 

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

func (*QueryIncentivizationProgramRequest) GetId added in v0.2.7 

func (m *QueryIncentivizationProgramRequest) GetId() uint64

func (*QueryIncentivizationProgramRequest) Marshal added in v0.2.7 

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

func (*QueryIncentivizationProgramRequest) MarshalTo added in v0.2.7 

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

func (*QueryIncentivizationProgramRequest) MarshalToSizedBuffer added in v0.2.7 

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

func (*QueryIncentivizationProgramRequest) ProtoMessage added in v0.2.7 

func (*QueryIncentivizationProgramRequest) ProtoMessage()

func (*QueryIncentivizationProgramRequest) Reset added in v0.2.7 

func (m *QueryIncentivizationProgramRequest) Reset()

func (*QueryIncentivizationProgramRequest) Size added in v0.2.7 

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

func (*QueryIncentivizationProgramRequest) String added in v0.2.7 

func (m *QueryIncentivizationProgramRequest) String() string

func (*QueryIncentivizationProgramRequest) Unmarshal added in v0.2.7 

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

func (*QueryIncentivizationProgramRequest) XXX_DiscardUnknown added in v0.2.7 

func (m *QueryIncentivizationProgramRequest) XXX_DiscardUnknown()

func (*QueryIncentivizationProgramRequest) XXX_Marshal added in v0.2.7 

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

func (*QueryIncentivizationProgramRequest) XXX_Merge added in v0.2.7 

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

func (*QueryIncentivizationProgramRequest) XXX_Size added in v0.2.7 

func (m *QueryIncentivizationProgramRequest) XXX_Size() int

func (*QueryIncentivizationProgramRequest) XXX_Unmarshal added in v0.2.7 

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

type QueryIncentivizationProgramResponse added in v0.2.7 

type QueryIncentivizationProgramResponse struct {
	IncentivizationProgram *IncentivizationProgram `` /* 127-byte string literal not displayed */
}

func (*QueryIncentivizationProgramResponse) Descriptor added in v0.2.7 

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

func (*QueryIncentivizationProgramResponse) GetIncentivizationProgram added in v0.2.7 

func (m *QueryIncentivizationProgramResponse) GetIncentivizationProgram() *IncentivizationProgram

func (*QueryIncentivizationProgramResponse) Marshal added in v0.2.7 

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

func (*QueryIncentivizationProgramResponse) MarshalTo added in v0.2.7 

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

func (*QueryIncentivizationProgramResponse) MarshalToSizedBuffer added in v0.2.7 

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

func (*QueryIncentivizationProgramResponse) ProtoMessage added in v0.2.7 

func (*QueryIncentivizationProgramResponse) ProtoMessage()

func (*QueryIncentivizationProgramResponse) Reset added in v0.2.7 

func (m *QueryIncentivizationProgramResponse) Reset()

func (*QueryIncentivizationProgramResponse) Size added in v0.2.7 

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

func (*QueryIncentivizationProgramResponse) String added in v0.2.7 

func (m *QueryIncentivizationProgramResponse) String() string

func (*QueryIncentivizationProgramResponse) Unmarshal added in v0.2.7 

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

func (*QueryIncentivizationProgramResponse) XXX_DiscardUnknown added in v0.2.7 

func (m *QueryIncentivizationProgramResponse) XXX_DiscardUnknown()

func (*QueryIncentivizationProgramResponse) XXX_Marshal added in v0.2.7 

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

func (*QueryIncentivizationProgramResponse) XXX_Merge added in v0.2.7 

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

func (*QueryIncentivizationProgramResponse) XXX_Size added in v0.2.7 

func (m *QueryIncentivizationProgramResponse) XXX_Size() int

func (*QueryIncentivizationProgramResponse) XXX_Unmarshal added in v0.2.7 

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

type QueryIncentivizationProgramsRequest added in v0.2.7 

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

func (*QueryIncentivizationProgramsRequest) Descriptor added in v0.2.7 

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

func (*QueryIncentivizationProgramsRequest) GetPagination added in v0.2.7 

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

func (*QueryIncentivizationProgramsRequest) Marshal added in v0.2.7 

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

func (*QueryIncentivizationProgramsRequest) MarshalTo added in v0.2.7 

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

func (*QueryIncentivizationProgramsRequest) MarshalToSizedBuffer added in v0.2.7 

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

func (*QueryIncentivizationProgramsRequest) ProtoMessage added in v0.2.7 

func (*QueryIncentivizationProgramsRequest) ProtoMessage()

func (*QueryIncentivizationProgramsRequest) Reset added in v0.2.7 

func (m *QueryIncentivizationProgramsRequest) Reset()

func (*QueryIncentivizationProgramsRequest) Size added in v0.2.7 

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

func (*QueryIncentivizationProgramsRequest) String added in v0.2.7 

func (m *QueryIncentivizationProgramsRequest) String() string

func (*QueryIncentivizationProgramsRequest) Unmarshal added in v0.2.7 

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

func (*QueryIncentivizationProgramsRequest) XXX_DiscardUnknown added in v0.2.7 

func (m *QueryIncentivizationProgramsRequest) XXX_DiscardUnknown()

func (*QueryIncentivizationProgramsRequest) XXX_Marshal added in v0.2.7 

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

func (*QueryIncentivizationProgramsRequest) XXX_Merge added in v0.2.7 

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

func (*QueryIncentivizationProgramsRequest) XXX_Size added in v0.2.7 

func (m *QueryIncentivizationProgramsRequest) XXX_Size() int

func (*QueryIncentivizationProgramsRequest) XXX_Unmarshal added in v0.2.7 

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

type QueryIncentivizationProgramsResponse added in v0.2.7 

type QueryIncentivizationProgramsResponse struct {
	IncentivizationPrograms []*IncentivizationProgram `` /* 130-byte string literal not displayed */
	Pagination              *query.PageResponse       `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*QueryIncentivizationProgramsResponse) Descriptor added in v0.2.7 

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

func (*QueryIncentivizationProgramsResponse) GetIncentivizationPrograms added in v0.2.7 

func (m *QueryIncentivizationProgramsResponse) GetIncentivizationPrograms() []*IncentivizationProgram

func (*QueryIncentivizationProgramsResponse) GetPagination added in v0.2.7 

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

func (*QueryIncentivizationProgramsResponse) Marshal added in v0.2.7 

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

func (*QueryIncentivizationProgramsResponse) MarshalTo added in v0.2.7 

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

func (*QueryIncentivizationProgramsResponse) MarshalToSizedBuffer added in v0.2.7 

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

func (*QueryIncentivizationProgramsResponse) ProtoMessage added in v0.2.7 

func (*QueryIncentivizationProgramsResponse) ProtoMessage()

func (*QueryIncentivizationProgramsResponse) Reset added in v0.2.7 

func (m *QueryIncentivizationProgramsResponse) Reset()

func (*QueryIncentivizationProgramsResponse) Size added in v0.2.7 

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

func (*QueryIncentivizationProgramsResponse) String added in v0.2.7 

func (m *QueryIncentivizationProgramsResponse) String() string

func (*QueryIncentivizationProgramsResponse) Unmarshal added in v0.2.7 

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

func (*QueryIncentivizationProgramsResponse) XXX_DiscardUnknown added in v0.2.7 

func (m *QueryIncentivizationProgramsResponse) XXX_DiscardUnknown()

func (*QueryIncentivizationProgramsResponse) XXX_Marshal added in v0.2.7 

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

func (*QueryIncentivizationProgramsResponse) XXX_Merge added in v0.2.7 

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

func (*QueryIncentivizationProgramsResponse) XXX_Size added in v0.2.7 

func (m *QueryIncentivizationProgramsResponse) XXX_Size() int

func (*QueryIncentivizationProgramsResponse) XXX_Unmarshal added in v0.2.7 

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

type QueryServer 

type QueryServer interface {
	IncentivizationProgram(context.Context, *QueryIncentivizationProgramRequest) (*QueryIncentivizationProgramResponse, error)
	IncentivizationPrograms(context.Context, *QueryIncentivizationProgramsRequest) (*QueryIncentivizationProgramsResponse, error)
}

QueryServer is the server API for Query service.

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) CreateIncentivizationProgram 

func (*UnimplementedMsgServer) CreateIncentivizationProgram(ctx context.Context, req *MsgCreateIncentivizationProgram) (*MsgCreateIncentivizationProgramResponse, error)

func (*UnimplementedMsgServer) FundIncentivizationProgram 

func (*UnimplementedMsgServer) FundIncentivizationProgram(ctx context.Context, req *MsgFundIncentivizationProgram) (*MsgFundIncentivizationProgramResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) IncentivizationProgram added in v0.2.7 

func (*UnimplementedQueryServer) IncentivizationProgram(ctx context.Context, req *QueryIncentivizationProgramRequest) (*QueryIncentivizationProgramResponse, error)

func (*UnimplementedQueryServer) IncentivizationPrograms added in v0.2.7 

func (*UnimplementedQueryServer) IncentivizationPrograms(ctx context.Context, req *QueryIncentivizationProgramsRequest) (*QueryIncentivizationProgramsResponse, 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.