types

package
v1.3.2 Latest Latest
Warning

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

 Go to latest Published: Nov 5, 2024 License: Apache-2.0 Imports: 42 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventTypeRegisterOperator             = "register_operator"
	EventTypeUpdateOperator               = "update_operator"
	EventTypeStartOperatorInactivation    = "start_operator_inactivation"
	EventTypeCompleteOperatorInactivation = "complete_operator_inactivation"
	EventTypeTransferOperatorOwnership    = "transfer_operator_ownership"
	EventTypeSetOperatorParams            = "set_operator_params"
	EventTypeDeleteOperator               = "delete_operator"

	AttributeKeyOperatorID = "operator_id"
	AttributeKeyNewAdmin   = "new_admin"
)
View Source 
const (
	ModuleName = "operators"
	StoreKey   = ModuleName

	DoNotModify = "[do-not-modify]"
)

Variables

View Source 
var (
	ErrOperatorNotFound        = errors.Wrap(sdkerrors.ErrNotFound, "operator not found")
	ErrInvalidGenesis          = errors.Register(ModuleName, 1, "invalid genesis state")
	ErrInsufficientShares      = errors.Register(ModuleName, 2, "insufficient delegation shares")
	ErrInvalidDeactivationTime = errors.Register(ModuleName, 3, "invalid deactivation time")
	ErrOperatorNotActive       = errors.Register(ModuleName, 4, "operator not active")
	ErrInvalidOperatorParams   = errors.Register(ModuleName, 5, "invalid operator params")
	ErrOperatorNotInactive     = errors.Register(ModuleName, 6, "operator not inactive")
)
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 (
	ParamsKey = []byte{0x01}

	NextOperatorIDKey               = []byte{0xa1}
	OperatorPrefix                  = []byte{0xa2}
	InactivatingOperatorQueuePrefix = []byte{0xa3}
	OperatorAddressSetPrefix        = collections.NewPrefix(0xa4)
	OperatorParamsMapPrefix         = collections.NewPrefix(0xa5)
)
View Source 
var (
	ErrInvalidLengthMessages        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessages          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessages = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthModels        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowModels          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupModels = fmt.Errorf("proto: unexpected end of group")
)
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 AminoCdc = codec.NewLegacyAmino()

AminoCdc references the global x/avs module codec. Note, the codec should ONLY be used in certain instances of tests and for JSON encoding as Amino is still used for that purpose.

The actual codec used for serialization should be provided to x/avs and defined at the application level.

View Source 
var OperatorStatus_name = map[int32]string{
	0: "OPERATOR_STATUS_UNSPECIFIED",
	1: "OPERATOR_STATUS_ACTIVE",
	2: "OPERATOR_STATUS_INACTIVATING",
	3: "OPERATOR_STATUS_INACTIVE",
}
View Source 
var OperatorStatus_value = map[string]int32{
	"OPERATOR_STATUS_UNSPECIFIED":  0,
	"OPERATOR_STATUS_ACTIVE":       1,
	"OPERATOR_STATUS_INACTIVATING": 2,
	"OPERATOR_STATUS_INACTIVE":     3,
}

Functions

func GetOperatorAddress 

func GetOperatorAddress(operatorID uint32) sdk.AccAddress

GetOperatorAddress generates an operator address from its id

func GetOperatorIDBytes 

func GetOperatorIDBytes(operatorID uint32) (operatorIDBz []byte)

GetOperatorIDBytes returns the byte representation of the operator ID

func GetOperatorIDFromBytes 

func GetOperatorIDFromBytes(bz []byte) (operatorID uint32)

GetOperatorIDFromBytes returns the operator ID from a byte array

func InactivatingOperatorByTime 

func InactivatingOperatorByTime(endTime time.Time) []byte

InactivatingOperatorByTime returns the key for all inactivating operators that expire at the given time

func InactivatingOperatorQueueKey 

func InactivatingOperatorQueueKey(operatorID uint32, endTime time.Time) []byte

InactivatingOperatorQueueKey returns the key for an inactivating operator in the queue

func OperatorStoreKey 

func OperatorStoreKey(operatorID uint32) []byte

OperatorStoreKey returns a operator ID into a key used to store a operator in the KVStore

func ParseOperatorID 

func ParseOperatorID(value string) (uint32, error)

ParseOperatorID tries parsing the given value as an operator id

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

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

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

func RegisterQueryHandlerClient 

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

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

func RegisterQueryHandlerFromEndpoint 

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

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

func RegisterQueryHandlerServer 

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

RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func SplitInactivatingOperatorQueueKey 

func SplitInactivatingOperatorQueueKey(key []byte) (operatorID uint32, endTime time.Time)

SplitInactivatingOperatorQueueKey split the inactivating operator queue key into operatorID and endTime

Types

type AccountKeeper 

type AccountKeeper interface {
	NewAccountWithAddress(ctx context.Context, addr sdk.AccAddress) sdk.AccountI
	HasAccount(ctx context.Context, addr sdk.AccAddress) bool
	SetAccount(ctx context.Context, acc sdk.AccountI)
}

type CommunityPoolKeeper 

type CommunityPoolKeeper interface {
	FundCommunityPool(ctx context.Context, amount sdk.Coins, sender sdk.AccAddress) error
}

type GenesisState 

type GenesisState struct {
	// Params defines the parameters of the module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	// NextOperatorID defines the ID that will be assigned to the
	// next operator that gets created.
	NextOperatorID uint32 `protobuf:"varint,2,opt,name=next_operator_id,json=nextOperatorId,proto3" json:"next_operator_id,omitempty"`
	// Operators defines the list of operators.
	Operators []Operator `protobuf:"bytes,3,rep,name=operators,proto3" json:"operators" yaml:"operators"`
	// UnbondingOperators defines the list of operators that are currently being
	// unbonded.
	UnbondingOperators []UnbondingOperator `` /* 132-byte string literal not displayed */
	// OperatorsParams defines the list of operators params.
	OperatorsParams []OperatorParamsRecord `protobuf:"bytes,5,rep,name=operators_params,json=operatorsParams,proto3" json:"operators_params" yaml:"operators_params"`
}

GenesisState defines the operators module's genesis state.

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default genesis state.

func NewGenesisState 

func NewGenesisState(
	nextOperatorID uint32,
	operators []Operator,
	operatorParams []OperatorParamsRecord,
	unbondingOperators []UnbondingOperator,
	params Params,
) *GenesisState

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetNextOperatorID 

func (m *GenesisState) GetNextOperatorID() uint32

func (*GenesisState) GetOperators 

func (m *GenesisState) GetOperators() []Operator

func (*GenesisState) GetOperatorsParams added in v1.3.0 

func (m *GenesisState) GetOperatorsParams() []OperatorParamsRecord

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetUnbondingOperators 

func (m *GenesisState) GetUnbondingOperators() []UnbondingOperator

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

Validate checks that the genesis state is valid.

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 MsgClient 

type MsgClient interface {
	// RegisterOperator defines the operation for registering a new operator.
	RegisterOperator(ctx context.Context, in *MsgRegisterOperator, opts ...grpc.CallOption) (*MsgRegisterOperatorResponse, error)
	// UpdateOperator defines the operation for updating an operator's details.
	// The operator owner can update the moniker, website, and picture URL.
	UpdateOperator(ctx context.Context, in *MsgUpdateOperator, opts ...grpc.CallOption) (*MsgUpdateOperatorResponse, error)
	// DeactivateOperator defines the operation for deactivating an
	// operator. Operators will require some time in order to be deactivated.
	// This time is defined by the governance parameters.
	DeactivateOperator(ctx context.Context, in *MsgDeactivateOperator, opts ...grpc.CallOption) (*MsgDeactivateOperatorResponse, error)
	// DeleteOperator defines the operation for deleting a deactivated operator.
	DeleteOperator(ctx context.Context, in *MsgDeleteOperator, opts ...grpc.CallOption) (*MsgDeleteOperatorResponse, error)
	// TransferOperatorOwnership defines the operation for transferring the
	// ownership of an operator to another account.
	TransferOperatorOwnership(ctx context.Context, in *MsgTransferOperatorOwnership, opts ...grpc.CallOption) (*MsgTransferOperatorOwnershipResponse, error)
	// SetOperatorParams defines the operation for setting a operator's
	// parameters.
	SetOperatorParams(ctx context.Context, in *MsgSetOperatorParams, opts ...grpc.CallOption) (*MsgSetOperatorParamsResponse, error)
	// UpdateParams defines a governance operation for updating the module
	// parameters.
	// The authority defaults to the x/gov module account.
	UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, 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 MsgDeactivateOperator 

type MsgDeactivateOperator struct {
	// Sender is the address of the user deactivating the operator
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// OperatorID represents the ID of the operator to be deregistered
	OperatorID uint32 `protobuf:"varint,2,opt,name=operator_id,json=operatorId,proto3" json:"operator_id,omitempty"`
}

MsgDeactivateOperator defines the message structure for the DeactivateOperator gRPC service method. It allows the operator owner to signal that the operator will become inactive. This should be used to signal users that the operator is going to stop performing services and they should switch to another operator.

func NewMsgDeactivateOperator 

func NewMsgDeactivateOperator(operatorID uint32, sender string) *MsgDeactivateOperator

NewMsgDeactivateOperator creates a new MsgDeactivateOperator instance

func (*MsgDeactivateOperator) Descriptor 

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

func (*MsgDeactivateOperator) GetOperatorID 

func (m *MsgDeactivateOperator) GetOperatorID() uint32

func (*MsgDeactivateOperator) GetSender 

func (m *MsgDeactivateOperator) GetSender() string

func (*MsgDeactivateOperator) GetSignBytes 

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

GetSignBytes implements sdk.Msg

func (*MsgDeactivateOperator) GetSigners 

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

GetSigners implements sdk.Msg

func (*MsgDeactivateOperator) Marshal 

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

func (*MsgDeactivateOperator) MarshalTo 

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

func (*MsgDeactivateOperator) MarshalToSizedBuffer 

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

func (*MsgDeactivateOperator) ProtoMessage 

func (*MsgDeactivateOperator) ProtoMessage()

func (*MsgDeactivateOperator) Reset 

func (m *MsgDeactivateOperator) Reset()

func (*MsgDeactivateOperator) Size 

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

func (*MsgDeactivateOperator) String 

func (m *MsgDeactivateOperator) String() string

func (*MsgDeactivateOperator) Unmarshal 

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

func (*MsgDeactivateOperator) ValidateBasic 

func (msg *MsgDeactivateOperator) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgDeactivateOperator) XXX_DiscardUnknown 

func (m *MsgDeactivateOperator) XXX_DiscardUnknown()

func (*MsgDeactivateOperator) XXX_Marshal 

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

func (*MsgDeactivateOperator) XXX_Merge 

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

func (*MsgDeactivateOperator) XXX_Size 

func (m *MsgDeactivateOperator) XXX_Size() int

func (*MsgDeactivateOperator) XXX_Unmarshal 

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

type MsgDeactivateOperatorResponse 

type MsgDeactivateOperatorResponse struct {
}

MsgDeactivateOperatorResponse is the return value of MsgDeactivateOperator.

func (*MsgDeactivateOperatorResponse) Descriptor 

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

func (*MsgDeactivateOperatorResponse) Marshal 

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

func (*MsgDeactivateOperatorResponse) MarshalTo 

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

func (*MsgDeactivateOperatorResponse) MarshalToSizedBuffer 

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

func (*MsgDeactivateOperatorResponse) ProtoMessage 

func (*MsgDeactivateOperatorResponse) ProtoMessage()

func (*MsgDeactivateOperatorResponse) Reset 

func (m *MsgDeactivateOperatorResponse) Reset()

func (*MsgDeactivateOperatorResponse) Size 

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

func (*MsgDeactivateOperatorResponse) String 

func (m *MsgDeactivateOperatorResponse) String() string

func (*MsgDeactivateOperatorResponse) Unmarshal 

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

func (*MsgDeactivateOperatorResponse) XXX_DiscardUnknown 

func (m *MsgDeactivateOperatorResponse) XXX_DiscardUnknown()

func (*MsgDeactivateOperatorResponse) XXX_Marshal 

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

func (*MsgDeactivateOperatorResponse) XXX_Merge 

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

func (*MsgDeactivateOperatorResponse) XXX_Size 

func (m *MsgDeactivateOperatorResponse) XXX_Size() int

func (*MsgDeactivateOperatorResponse) XXX_Unmarshal 

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

type MsgDeleteOperator added in v1.3.0 

type MsgDeleteOperator struct {
	// Sender is the address of the user deleting the operator
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// OperatorID represents the ID of the operator to be deleted
	OperatorID uint32 `protobuf:"varint,2,opt,name=operator_id,json=operatorId,proto3" json:"operator_id,omitempty"`
}

MsgDeleteOperator defines the message structure for the DeleteOperator gRPC service method. It allows the operator owner to delete a deactivated operator.

func NewMsgDeleteOperator added in v1.3.0 

func NewMsgDeleteOperator(operatorID uint32, sender string) *MsgDeleteOperator

NewMsgDeleteOperator creates a new MsgDeleteOperator instance

func (*MsgDeleteOperator) Descriptor added in v1.3.0 

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

func (*MsgDeleteOperator) GetOperatorID added in v1.3.0 

func (m *MsgDeleteOperator) GetOperatorID() uint32

func (*MsgDeleteOperator) GetSender added in v1.3.0 

func (m *MsgDeleteOperator) GetSender() string

func (*MsgDeleteOperator) Marshal added in v1.3.0 

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

func (*MsgDeleteOperator) MarshalTo added in v1.3.0 

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

func (*MsgDeleteOperator) MarshalToSizedBuffer added in v1.3.0 

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

func (*MsgDeleteOperator) ProtoMessage added in v1.3.0 

func (*MsgDeleteOperator) ProtoMessage()

func (*MsgDeleteOperator) Reset added in v1.3.0 

func (m *MsgDeleteOperator) Reset()

func (*MsgDeleteOperator) Size added in v1.3.0 

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

func (*MsgDeleteOperator) String added in v1.3.0 

func (m *MsgDeleteOperator) String() string

func (*MsgDeleteOperator) Unmarshal added in v1.3.0 

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

func (*MsgDeleteOperator) ValidateBasic added in v1.3.0 

func (msg *MsgDeleteOperator) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgDeleteOperator) XXX_DiscardUnknown added in v1.3.0 

func (m *MsgDeleteOperator) XXX_DiscardUnknown()

func (*MsgDeleteOperator) XXX_Marshal added in v1.3.0 

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

func (*MsgDeleteOperator) XXX_Merge added in v1.3.0 

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

func (*MsgDeleteOperator) XXX_Size added in v1.3.0 

func (m *MsgDeleteOperator) XXX_Size() int

func (*MsgDeleteOperator) XXX_Unmarshal added in v1.3.0 

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

type MsgDeleteOperatorResponse added in v1.3.0 

type MsgDeleteOperatorResponse struct {
}

MsgDeleteOperatorResponse is the return value of MsgDeleteOperator.

func (*MsgDeleteOperatorResponse) Descriptor added in v1.3.0 

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

func (*MsgDeleteOperatorResponse) Marshal added in v1.3.0 

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

func (*MsgDeleteOperatorResponse) MarshalTo added in v1.3.0 

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

func (*MsgDeleteOperatorResponse) MarshalToSizedBuffer added in v1.3.0 

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

func (*MsgDeleteOperatorResponse) ProtoMessage added in v1.3.0 

func (*MsgDeleteOperatorResponse) ProtoMessage()

func (*MsgDeleteOperatorResponse) Reset added in v1.3.0 

func (m *MsgDeleteOperatorResponse) Reset()

func (*MsgDeleteOperatorResponse) Size added in v1.3.0 

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

func (*MsgDeleteOperatorResponse) String added in v1.3.0 

func (m *MsgDeleteOperatorResponse) String() string

func (*MsgDeleteOperatorResponse) Unmarshal added in v1.3.0 

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

func (*MsgDeleteOperatorResponse) XXX_DiscardUnknown added in v1.3.0 

func (m *MsgDeleteOperatorResponse) XXX_DiscardUnknown()

func (*MsgDeleteOperatorResponse) XXX_Marshal added in v1.3.0 

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

func (*MsgDeleteOperatorResponse) XXX_Merge added in v1.3.0 

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

func (*MsgDeleteOperatorResponse) XXX_Size added in v1.3.0 

func (m *MsgDeleteOperatorResponse) XXX_Size() int

func (*MsgDeleteOperatorResponse) XXX_Unmarshal added in v1.3.0 

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

type MsgRegisterOperator 

type MsgRegisterOperator struct {
	// Sender is the address of the user registering the operator
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// Moniker is the moniker of the operator
	Moniker string `protobuf:"bytes,2,opt,name=moniker,proto3" json:"moniker,omitempty" yaml:"moniker"`
	// Website is the website of the operator (optional)
	Website string `protobuf:"bytes,3,opt,name=website,proto3" json:"website,omitempty" yaml:"website"`
	// PictureURL is the URL of operator picture (optional)
	PictureURL string `protobuf:"bytes,4,opt,name=picture_url,json=pictureUrl,proto3" json:"picture_url,omitempty" yaml:"picture_url"`
}

MsgRegisterOperator defines the message structure for the RegisterOperator gRPC service method. It allows an account to register a new operator that can opt-in to validate various services. It requires a sender address as well as the details of the operator to be registered.

func NewMsgRegisterOperator 

func NewMsgRegisterOperator(moniker string, website string, pictureURL string, sender string) *MsgRegisterOperator

NewMsgRegisterOperator creates a new MsgRegisterOperator instance

func (*MsgRegisterOperator) Descriptor 

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

func (*MsgRegisterOperator) GetMoniker 

func (m *MsgRegisterOperator) GetMoniker() string

func (*MsgRegisterOperator) GetPictureURL 

func (m *MsgRegisterOperator) GetPictureURL() string

func (*MsgRegisterOperator) GetSender 

func (m *MsgRegisterOperator) GetSender() string

func (*MsgRegisterOperator) GetSignBytes 

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

GetSignBytes implements sdk.Msg

func (*MsgRegisterOperator) GetSigners 

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

GetSigners implements sdk.Msg

func (*MsgRegisterOperator) GetWebsite 

func (m *MsgRegisterOperator) GetWebsite() string

func (*MsgRegisterOperator) Marshal 

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

func (*MsgRegisterOperator) MarshalTo 

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

func (*MsgRegisterOperator) MarshalToSizedBuffer 

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

func (*MsgRegisterOperator) ProtoMessage 

func (*MsgRegisterOperator) ProtoMessage()

func (*MsgRegisterOperator) Reset 

func (m *MsgRegisterOperator) Reset()

func (*MsgRegisterOperator) Size 

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

func (*MsgRegisterOperator) String 

func (m *MsgRegisterOperator) String() string

func (*MsgRegisterOperator) Unmarshal 

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

func (*MsgRegisterOperator) ValidateBasic 

func (msg *MsgRegisterOperator) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgRegisterOperator) XXX_DiscardUnknown 

func (m *MsgRegisterOperator) XXX_DiscardUnknown()

func (*MsgRegisterOperator) XXX_Marshal 

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

func (*MsgRegisterOperator) XXX_Merge 

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

func (*MsgRegisterOperator) XXX_Size 

func (m *MsgRegisterOperator) XXX_Size() int

func (*MsgRegisterOperator) XXX_Unmarshal 

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

type MsgRegisterOperatorResponse 

type MsgRegisterOperatorResponse struct {
	// NewOperatorID is the ID of the newly registered operator
	NewOperatorID uint32 `protobuf:"varint,1,opt,name=new_operator_id,json=newOperatorId,proto3" json:"new_operator_id,omitempty"`
}

MsgRegisterOperatorResponse is the return value of MsgRegisterOperator. It returns the newly created operator ID.

func (*MsgRegisterOperatorResponse) Descriptor 

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

func (*MsgRegisterOperatorResponse) GetNewOperatorID 

func (m *MsgRegisterOperatorResponse) GetNewOperatorID() uint32

func (*MsgRegisterOperatorResponse) Marshal 

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

func (*MsgRegisterOperatorResponse) MarshalTo 

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

func (*MsgRegisterOperatorResponse) MarshalToSizedBuffer 

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

func (*MsgRegisterOperatorResponse) ProtoMessage 

func (*MsgRegisterOperatorResponse) ProtoMessage()

func (*MsgRegisterOperatorResponse) Reset 

func (m *MsgRegisterOperatorResponse) Reset()

func (*MsgRegisterOperatorResponse) Size 

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

func (*MsgRegisterOperatorResponse) String 

func (m *MsgRegisterOperatorResponse) String() string

func (*MsgRegisterOperatorResponse) Unmarshal 

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

func (*MsgRegisterOperatorResponse) XXX_DiscardUnknown 

func (m *MsgRegisterOperatorResponse) XXX_DiscardUnknown()

func (*MsgRegisterOperatorResponse) XXX_Marshal 

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

func (*MsgRegisterOperatorResponse) XXX_Merge 

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

func (*MsgRegisterOperatorResponse) XXX_Size 

func (m *MsgRegisterOperatorResponse) XXX_Size() int

func (*MsgRegisterOperatorResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// RegisterOperator defines the operation for registering a new operator.
	RegisterOperator(context.Context, *MsgRegisterOperator) (*MsgRegisterOperatorResponse, error)
	// UpdateOperator defines the operation for updating an operator's details.
	// The operator owner can update the moniker, website, and picture URL.
	UpdateOperator(context.Context, *MsgUpdateOperator) (*MsgUpdateOperatorResponse, error)
	// DeactivateOperator defines the operation for deactivating an
	// operator. Operators will require some time in order to be deactivated.
	// This time is defined by the governance parameters.
	DeactivateOperator(context.Context, *MsgDeactivateOperator) (*MsgDeactivateOperatorResponse, error)
	// DeleteOperator defines the operation for deleting a deactivated operator.
	DeleteOperator(context.Context, *MsgDeleteOperator) (*MsgDeleteOperatorResponse, error)
	// TransferOperatorOwnership defines the operation for transferring the
	// ownership of an operator to another account.
	TransferOperatorOwnership(context.Context, *MsgTransferOperatorOwnership) (*MsgTransferOperatorOwnershipResponse, error)
	// SetOperatorParams defines the operation for setting a operator's
	// parameters.
	SetOperatorParams(context.Context, *MsgSetOperatorParams) (*MsgSetOperatorParamsResponse, error)
	// UpdateParams defines a governance operation for updating the module
	// parameters.
	// The authority defaults to the x/gov module account.
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSetOperatorParams added in v1.3.0 

type MsgSetOperatorParams struct {
	Sender     string         `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	OperatorID uint32         `protobuf:"varint,2,opt,name=operator_id,json=operatorId,proto3" json:"operator_id,omitempty"`
	Params     OperatorParams `protobuf:"bytes,3,opt,name=params,proto3" json:"params"`
}

MsgSetOperatorParams defines the message structure for the SetOperatorParams gRPC service method. It allows the operator admin to update the operator's parameters.

func NewMsgSetOperatorParams added in v1.3.0 

func NewMsgSetOperatorParams(sender string, operatorID uint32, operatorParams OperatorParams) *MsgSetOperatorParams

func (*MsgSetOperatorParams) Descriptor added in v1.3.0 

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

func (*MsgSetOperatorParams) GetOperatorID added in v1.3.0 

func (m *MsgSetOperatorParams) GetOperatorID() uint32

func (*MsgSetOperatorParams) GetParams added in v1.3.0 

func (m *MsgSetOperatorParams) GetParams() OperatorParams

func (*MsgSetOperatorParams) GetSender added in v1.3.0 

func (m *MsgSetOperatorParams) GetSender() string

func (*MsgSetOperatorParams) Marshal added in v1.3.0 

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

func (*MsgSetOperatorParams) MarshalTo added in v1.3.0 

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

func (*MsgSetOperatorParams) MarshalToSizedBuffer added in v1.3.0 

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

func (*MsgSetOperatorParams) ProtoMessage added in v1.3.0 

func (*MsgSetOperatorParams) ProtoMessage()

func (*MsgSetOperatorParams) Reset added in v1.3.0 

func (m *MsgSetOperatorParams) Reset()

func (*MsgSetOperatorParams) Size added in v1.3.0 

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

func (*MsgSetOperatorParams) String added in v1.3.0 

func (m *MsgSetOperatorParams) String() string

func (*MsgSetOperatorParams) Unmarshal added in v1.3.0 

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

func (*MsgSetOperatorParams) ValidateBasic added in v1.3.0 

func (msg *MsgSetOperatorParams) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgSetOperatorParams) XXX_DiscardUnknown added in v1.3.0 

func (m *MsgSetOperatorParams) XXX_DiscardUnknown()

func (*MsgSetOperatorParams) XXX_Marshal added in v1.3.0 

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

func (*MsgSetOperatorParams) XXX_Merge added in v1.3.0 

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

func (*MsgSetOperatorParams) XXX_Size added in v1.3.0 

func (m *MsgSetOperatorParams) XXX_Size() int

func (*MsgSetOperatorParams) XXX_Unmarshal added in v1.3.0 

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

type MsgSetOperatorParamsResponse added in v1.3.0 

type MsgSetOperatorParamsResponse struct {
}

MsgSetOperatorParamsResponse is the return value of MsgSetOperatorParams.

func (*MsgSetOperatorParamsResponse) Descriptor added in v1.3.0 

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

func (*MsgSetOperatorParamsResponse) Marshal added in v1.3.0 

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

func (*MsgSetOperatorParamsResponse) MarshalTo added in v1.3.0 

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

func (*MsgSetOperatorParamsResponse) MarshalToSizedBuffer added in v1.3.0 

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

func (*MsgSetOperatorParamsResponse) ProtoMessage added in v1.3.0 

func (*MsgSetOperatorParamsResponse) ProtoMessage()

func (*MsgSetOperatorParamsResponse) Reset added in v1.3.0 

func (m *MsgSetOperatorParamsResponse) Reset()

func (*MsgSetOperatorParamsResponse) Size added in v1.3.0 

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

func (*MsgSetOperatorParamsResponse) String added in v1.3.0 

func (m *MsgSetOperatorParamsResponse) String() string

func (*MsgSetOperatorParamsResponse) Unmarshal added in v1.3.0 

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

func (*MsgSetOperatorParamsResponse) XXX_DiscardUnknown added in v1.3.0 

func (m *MsgSetOperatorParamsResponse) XXX_DiscardUnknown()

func (*MsgSetOperatorParamsResponse) XXX_Marshal added in v1.3.0 

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

func (*MsgSetOperatorParamsResponse) XXX_Merge added in v1.3.0 

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

func (*MsgSetOperatorParamsResponse) XXX_Size added in v1.3.0 

func (m *MsgSetOperatorParamsResponse) XXX_Size() int

func (*MsgSetOperatorParamsResponse) XXX_Unmarshal added in v1.3.0 

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

type MsgTransferOperatorOwnership 

type MsgTransferOperatorOwnership struct {
	// Sender is the address of the user transferring the ownership
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// OperatorID represents the ID of the operator to transfer ownership
	OperatorID uint32 `protobuf:"varint,2,opt,name=operator_id,json=operatorId,proto3" json:"operator_id,omitempty"`
	// NewAdmin is the address of the new admin of the operator
	NewAdmin string `protobuf:"bytes,3,opt,name=new_admin,json=newAdmin,proto3" json:"new_admin,omitempty"`
}

MsgTransferOperatorOwnership defines the message structure for the TransferOperatorOwnership gRPC service method. It allows an operator admin to transfer the ownership of the operator to another account.

func NewMsgTransferOperatorOwnership 

func NewMsgTransferOperatorOwnership(operatorID uint32, newAdmin, sender string) *MsgTransferOperatorOwnership

NewMsgTransferOperatorOwnership creates a new MsgTransferOperatorOwnership instance

func (*MsgTransferOperatorOwnership) Descriptor 

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

func (*MsgTransferOperatorOwnership) GetNewAdmin 

func (m *MsgTransferOperatorOwnership) GetNewAdmin() string

func (*MsgTransferOperatorOwnership) GetOperatorID 

func (m *MsgTransferOperatorOwnership) GetOperatorID() uint32

func (*MsgTransferOperatorOwnership) GetSender 

func (m *MsgTransferOperatorOwnership) GetSender() string

func (*MsgTransferOperatorOwnership) GetSignBytes 

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

GetSignBytes implements sdk.Msg

func (*MsgTransferOperatorOwnership) GetSigners 

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

GetSigners implements sdk.Msg

func (*MsgTransferOperatorOwnership) Marshal 

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

func (*MsgTransferOperatorOwnership) MarshalTo 

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

func (*MsgTransferOperatorOwnership) MarshalToSizedBuffer 

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

func (*MsgTransferOperatorOwnership) ProtoMessage 

func (*MsgTransferOperatorOwnership) ProtoMessage()

func (*MsgTransferOperatorOwnership) Reset 

func (m *MsgTransferOperatorOwnership) Reset()

func (*MsgTransferOperatorOwnership) Size 

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

func (*MsgTransferOperatorOwnership) String 

func (m *MsgTransferOperatorOwnership) String() string

func (*MsgTransferOperatorOwnership) Unmarshal 

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

func (*MsgTransferOperatorOwnership) ValidateBasic 

func (msg *MsgTransferOperatorOwnership) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgTransferOperatorOwnership) XXX_DiscardUnknown 

func (m *MsgTransferOperatorOwnership) XXX_DiscardUnknown()

func (*MsgTransferOperatorOwnership) XXX_Marshal 

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

func (*MsgTransferOperatorOwnership) XXX_Merge 

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

func (*MsgTransferOperatorOwnership) XXX_Size 

func (m *MsgTransferOperatorOwnership) XXX_Size() int

func (*MsgTransferOperatorOwnership) XXX_Unmarshal 

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

type MsgTransferOperatorOwnershipResponse 

type MsgTransferOperatorOwnershipResponse struct {
}

MsgTransferOperatorOwnershipResponse is the return value of MsgTransferOperatorOwnership.

func (*MsgTransferOperatorOwnershipResponse) Descriptor 

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

func (*MsgTransferOperatorOwnershipResponse) Marshal 

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

func (*MsgTransferOperatorOwnershipResponse) MarshalTo 

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

func (*MsgTransferOperatorOwnershipResponse) MarshalToSizedBuffer 

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

func (*MsgTransferOperatorOwnershipResponse) ProtoMessage 

func (*MsgTransferOperatorOwnershipResponse) ProtoMessage()

func (*MsgTransferOperatorOwnershipResponse) Reset 

func (m *MsgTransferOperatorOwnershipResponse) Reset()

func (*MsgTransferOperatorOwnershipResponse) Size 

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

func (*MsgTransferOperatorOwnershipResponse) String 

func (m *MsgTransferOperatorOwnershipResponse) String() string

func (*MsgTransferOperatorOwnershipResponse) Unmarshal 

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

func (*MsgTransferOperatorOwnershipResponse) XXX_DiscardUnknown 

func (m *MsgTransferOperatorOwnershipResponse) XXX_DiscardUnknown()

func (*MsgTransferOperatorOwnershipResponse) XXX_Marshal 

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

func (*MsgTransferOperatorOwnershipResponse) XXX_Merge 

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

func (*MsgTransferOperatorOwnershipResponse) XXX_Size 

func (m *MsgTransferOperatorOwnershipResponse) XXX_Size() int

func (*MsgTransferOperatorOwnershipResponse) XXX_Unmarshal 

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

type MsgUpdateOperator 

type MsgUpdateOperator struct {
	// Sender is the address of the user updating the operator
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// OperatorID represents the ID of the operator to be updated
	OperatorID uint32 `protobuf:"varint,2,opt,name=operator_id,json=operatorId,proto3" json:"operator_id,omitempty"`
	// Moniker is the new moniker of the operator.
	// If it shouldn't be changed, use [do-not-modify] instead.
	Moniker string `protobuf:"bytes,3,opt,name=moniker,proto3" json:"moniker,omitempty" yaml:"name"`
	// Website is the new website of the operator.
	// If it shouldn't be changed, use [do-not-modify] instead.
	Website string `protobuf:"bytes,4,opt,name=website,proto3" json:"website,omitempty" yaml:"website"`
	// PictureURL is the new URL of the operator picture.
	// If it shouldn't be changed, use [do-not-modify] instead.
	PictureURL string `protobuf:"bytes,5,opt,name=picture_url,json=pictureUrl,proto3" json:"picture_url,omitempty" yaml:"picture_url"`
}

MsgUpdateOperator defines the message structure for the UpdateOperator gRPC service method. It allows the operator owner to update the details of an existing operator.

func NewMsgUpdateOperator 

func NewMsgUpdateOperator(operatorID uint32, moniker string, website string, pictureURL string, sender string) *MsgUpdateOperator

NewMsgUpdateOperator creates a new MsgUpdateOperator instance

func (*MsgUpdateOperator) Descriptor 

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

func (*MsgUpdateOperator) GetMoniker 

func (m *MsgUpdateOperator) GetMoniker() string

func (*MsgUpdateOperator) GetOperatorID 

func (m *MsgUpdateOperator) GetOperatorID() uint32

func (*MsgUpdateOperator) GetPictureURL 

func (m *MsgUpdateOperator) GetPictureURL() string

func (*MsgUpdateOperator) GetSender 

func (m *MsgUpdateOperator) GetSender() string

func (*MsgUpdateOperator) GetSignBytes 

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

GetSignBytes implements sdk.Msg

func (*MsgUpdateOperator) GetSigners 

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

GetSigners implements sdk.Msg

func (*MsgUpdateOperator) GetWebsite 

func (m *MsgUpdateOperator) GetWebsite() string

func (*MsgUpdateOperator) Marshal 

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

func (*MsgUpdateOperator) MarshalTo 

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

func (*MsgUpdateOperator) MarshalToSizedBuffer 

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

func (*MsgUpdateOperator) ProtoMessage 

func (*MsgUpdateOperator) ProtoMessage()

func (*MsgUpdateOperator) Reset 

func (m *MsgUpdateOperator) Reset()

func (*MsgUpdateOperator) Size 

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

func (*MsgUpdateOperator) String 

func (m *MsgUpdateOperator) String() string

func (*MsgUpdateOperator) Unmarshal 

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

func (*MsgUpdateOperator) ValidateBasic 

func (msg *MsgUpdateOperator) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgUpdateOperator) XXX_DiscardUnknown 

func (m *MsgUpdateOperator) XXX_DiscardUnknown()

func (*MsgUpdateOperator) XXX_Marshal 

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

func (*MsgUpdateOperator) XXX_Merge 

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

func (*MsgUpdateOperator) XXX_Size 

func (m *MsgUpdateOperator) XXX_Size() int

func (*MsgUpdateOperator) XXX_Unmarshal 

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

type MsgUpdateOperatorResponse 

type MsgUpdateOperatorResponse struct {
}

MsgUpdateOperatorResponse is the return value of MsgUpdateOperator.

func (*MsgUpdateOperatorResponse) Descriptor 

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

func (*MsgUpdateOperatorResponse) Marshal 

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

func (*MsgUpdateOperatorResponse) MarshalTo 

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

func (*MsgUpdateOperatorResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateOperatorResponse) ProtoMessage 

func (*MsgUpdateOperatorResponse) ProtoMessage()

func (*MsgUpdateOperatorResponse) Reset 

func (m *MsgUpdateOperatorResponse) Reset()

func (*MsgUpdateOperatorResponse) Size 

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

func (*MsgUpdateOperatorResponse) String 

func (m *MsgUpdateOperatorResponse) String() string

func (*MsgUpdateOperatorResponse) Unmarshal 

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

func (*MsgUpdateOperatorResponse) XXX_DiscardUnknown 

func (m *MsgUpdateOperatorResponse) XXX_DiscardUnknown()

func (*MsgUpdateOperatorResponse) XXX_Marshal 

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

func (*MsgUpdateOperatorResponse) XXX_Merge 

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

func (*MsgUpdateOperatorResponse) XXX_Size 

func (m *MsgUpdateOperatorResponse) XXX_Size() int

func (*MsgUpdateOperatorResponse) XXX_Unmarshal 

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

type MsgUpdateParams 

type MsgUpdateParams struct {
	// Authority is the address that controls the module (defaults to x/gov unless
	// overwritten).
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty" yaml:"authority"`
	// Params define the parameters to update.
	//
	// NOTE: All parameters must be supplied.
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

MsgUpdateParams defines the message structure for the UpdateParams gRPC service method. It allows the authority to update the module parameters.

func NewMsgUpdateParams 

func NewMsgUpdateParams(params Params, authority string) *MsgUpdateParams

func (*MsgUpdateParams) Descriptor 

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

func (*MsgUpdateParams) GetAuthority 

func (m *MsgUpdateParams) GetAuthority() string

func (*MsgUpdateParams) GetParams 

func (m *MsgUpdateParams) GetParams() Params

func (*MsgUpdateParams) GetSignBytes 

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

GetSignBytes implements sdk.Msg

func (*MsgUpdateParams) GetSigners 

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

GetSigners implements sdk.Msg

func (*MsgUpdateParams) Marshal 

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

func (*MsgUpdateParams) MarshalTo 

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

func (*MsgUpdateParams) MarshalToSizedBuffer 

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

func (*MsgUpdateParams) ProtoMessage 

func (*MsgUpdateParams) ProtoMessage()

func (*MsgUpdateParams) Reset 

func (m *MsgUpdateParams) Reset()

func (*MsgUpdateParams) Size 

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

func (*MsgUpdateParams) String 

func (m *MsgUpdateParams) String() string

func (*MsgUpdateParams) Unmarshal 

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

func (*MsgUpdateParams) ValidateBasic 

func (msg *MsgUpdateParams) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgUpdateParams) XXX_DiscardUnknown 

func (m *MsgUpdateParams) XXX_DiscardUnknown()

func (*MsgUpdateParams) XXX_Marshal 

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

func (*MsgUpdateParams) XXX_Merge 

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

func (*MsgUpdateParams) XXX_Size 

func (m *MsgUpdateParams) XXX_Size() int

func (*MsgUpdateParams) XXX_Unmarshal 

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

type MsgUpdateParamsResponse 

type MsgUpdateParamsResponse struct {
}

MsgUpdateParamsResponse is the return value of MsgUpdateParams.

func (*MsgUpdateParamsResponse) Descriptor 

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

func (*MsgUpdateParamsResponse) Marshal 

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

func (*MsgUpdateParamsResponse) MarshalTo 

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

func (*MsgUpdateParamsResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateParamsResponse) ProtoMessage 

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) Reset 

func (m *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) Size 

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

func (*MsgUpdateParamsResponse) String 

func (m *MsgUpdateParamsResponse) String() string

func (*MsgUpdateParamsResponse) Unmarshal 

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

func (*MsgUpdateParamsResponse) XXX_DiscardUnknown 

func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()

func (*MsgUpdateParamsResponse) XXX_Marshal 

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

func (*MsgUpdateParamsResponse) XXX_Merge 

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

func (*MsgUpdateParamsResponse) XXX_Size 

func (m *MsgUpdateParamsResponse) XXX_Size() int

func (*MsgUpdateParamsResponse) XXX_Unmarshal 

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

type MultiOperatorsHooks 

type MultiOperatorsHooks []OperatorsHooks

MultiOperatorsHooks combines multiple operators hooks, all hook functions are run in array sequence

func NewMultiOperatorsHooks 

func NewMultiOperatorsHooks(hooks ...OperatorsHooks) MultiOperatorsHooks

NewMultiOperatorsHooks creates a new MultiOperatorsHooks object

func (MultiOperatorsHooks) AfterOperatorDeleted added in v1.3.0 

func (h MultiOperatorsHooks) AfterOperatorDeleted(ctx sdk.Context, operatorID uint32) error

AfterOperatorDeleted implements OperatorsHooks

func (MultiOperatorsHooks) AfterOperatorInactivatingCompleted 

func (h MultiOperatorsHooks) AfterOperatorInactivatingCompleted(ctx sdk.Context, operatorID uint32) error

AfterOperatorInactivatingCompleted implements OperatorsHooks

func (MultiOperatorsHooks) AfterOperatorInactivatingStarted 

func (h MultiOperatorsHooks) AfterOperatorInactivatingStarted(ctx sdk.Context, operatorID uint32) error

AfterOperatorInactivatingStarted implements OperatorsHooks

func (MultiOperatorsHooks) AfterOperatorRegistered 

func (h MultiOperatorsHooks) AfterOperatorRegistered(ctx sdk.Context, operatorID uint32) error

AfterOperatorRegistered implements OperatorsHooks

type Operator 

type Operator struct {
	// ID is the auto-generated unique identifier for the operator
	ID uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Status is the status of the operator
	Status OperatorStatus `protobuf:"varint,2,opt,name=status,proto3,enum=milkyway.operators.v1.OperatorStatus" json:"status,omitempty"`
	// Admin is the address of the user that can manage the operator
	Admin string `protobuf:"bytes,3,opt,name=admin,proto3" json:"admin,omitempty"`
	// Moniker is the identifier of the operator
	Moniker string `protobuf:"bytes,4,opt,name=moniker,proto3" json:"moniker,omitempty"`
	// Website is the website of the operator
	Website string `protobuf:"bytes,5,opt,name=website,proto3" json:"website,omitempty"`
	// PictureURL is the URL of the picture of the operator
	PictureURL string `protobuf:"bytes,6,opt,name=picture_url,json=pictureUrl,proto3" json:"picture_url,omitempty"`
	// Address is the address of the account associated to the operator.
	// This will be used to store tokens that are delegated to this operator.
	Address string `protobuf:"bytes,7,opt,name=address,proto3" json:"address,omitempty"`
	// Tokens define the delegated tokens.
	Tokens github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,8,rep,name=tokens,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"tokens"`
	// DelegatorShares define the total shares issued to an operator's delegators.
	DelegatorShares github_com_cosmos_cosmos_sdk_types.DecCoins `` /* 153-byte string literal not displayed */
}

Operator defines the fields of an operator

func NewOperator 

func NewOperator(
	id uint32,
	status OperatorStatus,
	moniker string,
	website string,
	pictureURL string,
	admin string,
) Operator

NewOperator creates a new Operator object

func (Operator) AddTokensFromDelegation 

func (o Operator) AddTokensFromDelegation(amount sdk.Coins) (Operator, sdk.DecCoins)

AddTokensFromDelegation adds the given amount of tokens to the operator's total tokens, also updating the operator's delegator shares. It returns the updated operator and the shares issued.

func (*Operator) Descriptor 

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

func (Operator) GetAddress 

func (o Operator) GetAddress() string

func (Operator) GetDelegatorShares 

func (o Operator) GetDelegatorShares() sdk.DecCoins

func (Operator) GetID 

func (o Operator) GetID() uint32

func (Operator) GetSharesDenom 

func (o Operator) GetSharesDenom(tokenDenom string) string

GetSharesDenom returns the shares denom for an operator and token denom

func (Operator) GetTokens 

func (o Operator) GetTokens() sdk.Coins

func (Operator) InvalidExRate 

func (o Operator) InvalidExRate() bool

InvalidExRate returns whether the exchange rates is invalid. This can happen e.g. if Operator loses all tokens due to slashing. In this case, make all future delegations invalid.

func (Operator) IsActive 

func (o Operator) IsActive() bool

IsActive returns whether the operator is active.

func (*Operator) Marshal 

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

func (*Operator) MarshalTo 

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

func (*Operator) MarshalToSizedBuffer 

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

func (*Operator) ProtoMessage 

func (*Operator) ProtoMessage()

func (Operator) RemoveDelShares 

func (o Operator) RemoveDelShares(delShares sdk.DecCoins) (Operator, sdk.Coins)

RemoveDelShares removes delegator shares from an operator and returns the amount of tokens that should be issued for those shares. NOTE: Because token fractions are left in the operator, the exchange rate of future shares of this validator can increase.

func (*Operator) Reset 

func (m *Operator) Reset()

func (Operator) SharesFromDecCoins 

func (o Operator) SharesFromDecCoins(tokens sdk.DecCoins) (sdk.DecCoins, error)

SharesFromDecCoins returns the shares of a delegation given a bond amount. It returns an error if the operator has no tokens.

func (Operator) SharesFromTokens 

func (o Operator) SharesFromTokens(tokens sdk.Coins) (sdk.DecCoins, error)

SharesFromTokens returns the shares of a delegation given a bond amount. It returns an error if the operator has no tokens.

func (Operator) SharesFromTokensTruncated 

func (o Operator) SharesFromTokensTruncated(tokens sdk.Coins) (sdk.DecCoins, error)

SharesFromTokensTruncated returns the truncated shares of a delegation given a bond amount. It returns an error if the operator has no tokens.

func (*Operator) Size 

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

func (*Operator) String 

func (m *Operator) String() string

func (Operator) TokensFromShares 

func (o Operator) TokensFromShares(shares sdk.DecCoins) sdk.DecCoins

TokensFromShares calculates the token worth of provided shares

func (Operator) TokensFromSharesTruncated 

func (o Operator) TokensFromSharesTruncated(shares sdk.DecCoins) sdk.DecCoins

TokensFromSharesTruncated calculates the token worth of provided shares, truncated

func (*Operator) Unmarshal 

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

func (*Operator) Update 

func (o *Operator) Update(update OperatorUpdate) Operator

Update returns a new Operator with updated fields.

func (Operator) Validate 

func (o Operator) Validate() error

Validate checks that the Operator has valid values.

func (*Operator) XXX_DiscardUnknown 

func (m *Operator) XXX_DiscardUnknown()

func (*Operator) XXX_Marshal 

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

func (*Operator) XXX_Merge 

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

func (*Operator) XXX_Size 

func (m *Operator) XXX_Size() int

func (*Operator) XXX_Unmarshal 

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

type OperatorParams added in v1.3.0 

type OperatorParams struct {
	// CommissionRate defines the commission rate charged to delegators, as a
	// fraction.
	CommissionRate cosmossdk_io_math.LegacyDec `` /* 132-byte string literal not displayed */
}

OperatorParams represent the params that have been set for an individual operator.

func DefaultOperatorParams added in v1.3.0 

func DefaultOperatorParams() OperatorParams

DefaultOperatorParams returns the default operator params

func NewOperatorParams added in v1.3.0 

func NewOperatorParams(commissionRate math.LegacyDec) OperatorParams

NewOperatorParams creates a new OperatorParams instance

func (*OperatorParams) Descriptor added in v1.3.0 

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

func (*OperatorParams) Marshal added in v1.3.0 

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

func (*OperatorParams) MarshalTo added in v1.3.0 

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

func (*OperatorParams) MarshalToSizedBuffer added in v1.3.0 

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

func (*OperatorParams) ProtoMessage added in v1.3.0 

func (*OperatorParams) ProtoMessage()

func (*OperatorParams) Reset added in v1.3.0 

func (m *OperatorParams) Reset()

func (*OperatorParams) Size added in v1.3.0 

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

func (*OperatorParams) String added in v1.3.0 

func (m *OperatorParams) String() string

func (*OperatorParams) Unmarshal added in v1.3.0 

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

func (*OperatorParams) Validate added in v1.3.0 

func (p *OperatorParams) Validate() error

Validate validates the operator params

func (*OperatorParams) XXX_DiscardUnknown added in v1.3.0 

func (m *OperatorParams) XXX_DiscardUnknown()

func (*OperatorParams) XXX_Marshal added in v1.3.0 

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

func (*OperatorParams) XXX_Merge added in v1.3.0 

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

func (*OperatorParams) XXX_Size added in v1.3.0 

func (m *OperatorParams) XXX_Size() int

func (*OperatorParams) XXX_Unmarshal added in v1.3.0 

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

type OperatorParamsRecord added in v1.3.0 

type OperatorParamsRecord struct {
	// OperatorID is the ID of the operator.
	OperatorID uint32 `protobuf:"varint,1,opt,name=operator_id,json=operatorId,proto3" json:"operator_id,omitempty"`
	// Params defines the parameters for the operators module.
	Params OperatorParams `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

OperatorParamsRecord represents the params that have been set for an individual operator.

func NewOperatorParamsRecord added in v1.3.0 

func NewOperatorParamsRecord(operatorID uint32, operatorParams OperatorParams) OperatorParamsRecord

NewOperatorParamsRecord creates a new OperatorParamsRecord instance.

func (*OperatorParamsRecord) Descriptor added in v1.3.0 

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

func (*OperatorParamsRecord) GetOperatorID added in v1.3.0 

func (m *OperatorParamsRecord) GetOperatorID() uint32

func (*OperatorParamsRecord) GetParams added in v1.3.0 

func (m *OperatorParamsRecord) GetParams() OperatorParams

func (*OperatorParamsRecord) Marshal added in v1.3.0 

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

func (*OperatorParamsRecord) MarshalTo added in v1.3.0 

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

func (*OperatorParamsRecord) MarshalToSizedBuffer added in v1.3.0 

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

func (*OperatorParamsRecord) ProtoMessage added in v1.3.0 

func (*OperatorParamsRecord) ProtoMessage()

func (*OperatorParamsRecord) Reset added in v1.3.0 

func (m *OperatorParamsRecord) Reset()

func (*OperatorParamsRecord) Size added in v1.3.0 

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

func (*OperatorParamsRecord) String added in v1.3.0 

func (m *OperatorParamsRecord) String() string

func (*OperatorParamsRecord) Unmarshal added in v1.3.0 

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

func (*OperatorParamsRecord) Validate added in v1.3.0 

func (o *OperatorParamsRecord) Validate() error

Validate checks that the OperatorParamsRecord has valid values.

func (*OperatorParamsRecord) XXX_DiscardUnknown added in v1.3.0 

func (m *OperatorParamsRecord) XXX_DiscardUnknown()

func (*OperatorParamsRecord) XXX_Marshal added in v1.3.0 

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

func (*OperatorParamsRecord) XXX_Merge added in v1.3.0 

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

func (*OperatorParamsRecord) XXX_Size added in v1.3.0 

func (m *OperatorParamsRecord) XXX_Size() int

func (*OperatorParamsRecord) XXX_Unmarshal added in v1.3.0 

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

type OperatorStatus 

type OperatorStatus int32

OperatorStatus defines the possible statuses of an operator 

const (
	// OPERATOR_STATUS_UNSPECIFIED defines an unspecified status
	OPERATOR_STATUS_UNSPECIFIED OperatorStatus = 0
	// OPERATOR_STATUS_ACTIVE identifies an active validator which is providing
	// services
	OPERATOR_STATUS_ACTIVE OperatorStatus = 1
	// OPERATOR_STATUS_INACTIVATING identifies an operator that is in the process
	// of becoming inactive
	OPERATOR_STATUS_INACTIVATING OperatorStatus = 2
	// OPERATOR_STATUS_INACTIVE defines an inactive operator that is not providing
	// services
	OPERATOR_STATUS_INACTIVE OperatorStatus = 3
)

func (OperatorStatus) EnumDescriptor 

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

func (OperatorStatus) String 

func (x OperatorStatus) String() string

type OperatorUpdate 

type OperatorUpdate struct {
	Moniker    string
	Website    string
	PictureURL string
}

OperatorUpdate defines the fields that can be updated in an Operator.

func NewOperatorUpdate 

func NewOperatorUpdate(
	moniker string,
	website string,
	pictureURL string,
) OperatorUpdate

type OperatorsHooks 

type OperatorsHooks interface {
	AfterOperatorRegistered(ctx sdk.Context, operatorID uint32) error            // Must be called after an operator is registered
	AfterOperatorInactivatingStarted(ctx sdk.Context, operatorID uint32) error   // Must be called after an operator has started inactivating
	AfterOperatorInactivatingCompleted(ctx sdk.Context, operatorID uint32) error // Must be called after an operator has completed inactivating
	AfterOperatorDeleted(ctx sdk.Context, operatorID uint32) error               // Must be called after an operator has been deleted
}

OperatorsHooks event hooks for operators objects (noalias)

type Params 

type Params struct {
	// OperatorRegistrationFee represents the fee that an operator must pay in
	// order to register itself with the network.
	// The fee is drawn from the MsgRegisterOperator sender's account and
	// transferred to the community pool.
	OperatorRegistrationFee github_com_cosmos_cosmos_sdk_types.Coins `` /* 205-byte string literal not displayed */
	// DeactivationTime represents the amount of time that will pass between
	// the time that an operator signals its willingness to deactivate and the
	// time that it actually becomes inactive.
	DeactivationTime time.Duration `protobuf:"varint,2,opt,name=deactivation_time,json=deactivationTime,proto3,stdduration" json:"deactivation_time,omitempty"`
}

Params defines the parameters for the operators module.

func DefaultParams 

func DefaultParams() Params

DefaultParams returns default Params

func NewParams 

func NewParams(registrationFee sdk.Coins, deactivationTime time.Duration) Params

NewParams creates a new Params object

func (*Params) Descriptor 

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

func (*Params) GetDeactivationTime 

func (m *Params) GetDeactivationTime() time.Duration

func (*Params) GetOperatorRegistrationFee 

func (m *Params) GetOperatorRegistrationFee() github_com_cosmos_cosmos_sdk_types.Coins

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) 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 checks that the parameters have valid values.

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 {
	// Operator defines a gRPC query method that returns the operator by the given
	// operator id.
	Operator(ctx context.Context, in *QueryOperatorRequest, opts ...grpc.CallOption) (*QueryOperatorResponse, error)
	// OperatorParams defines a gRPC query method that returns the operator's
	// params by the given operator id.
	OperatorParams(ctx context.Context, in *QueryOperatorParamsRequest, opts ...grpc.CallOption) (*QueryOperatorParamsResponse, error)
	// Operators defines a gRPC query method that returns the list of operators.
	Operators(ctx context.Context, in *QueryOperatorsRequest, opts ...grpc.CallOption) (*QueryOperatorsResponse, error)
	// Params defines a gRPC query method that returns the parameters of the
	// module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, 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 QueryOperatorParamsRequest added in v1.3.0 

type QueryOperatorParamsRequest struct {
	// OperatorID is the ID of the operator for which to query the params
	OperatorId uint32 `protobuf:"varint,1,opt,name=operator_id,json=operatorId,proto3" json:"operator_id,omitempty"`
}

QueryOperatorParamsRequest is the request type for the Query/OperatorParams RPC method.

func NewQueryOperatorParamsRequest added in v1.3.0 

func NewQueryOperatorParamsRequest(operatorID uint32) *QueryOperatorParamsRequest

NewQueryOperatorParamsRequest creates a new QueryOperatorParamsRequest object

func (*QueryOperatorParamsRequest) Descriptor added in v1.3.0 

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

func (*QueryOperatorParamsRequest) GetOperatorId added in v1.3.0 

func (m *QueryOperatorParamsRequest) GetOperatorId() uint32

func (*QueryOperatorParamsRequest) Marshal added in v1.3.0 

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

func (*QueryOperatorParamsRequest) MarshalTo added in v1.3.0 

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

func (*QueryOperatorParamsRequest) MarshalToSizedBuffer added in v1.3.0 

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

func (*QueryOperatorParamsRequest) ProtoMessage added in v1.3.0 

func (*QueryOperatorParamsRequest) ProtoMessage()

func (*QueryOperatorParamsRequest) Reset added in v1.3.0 

func (m *QueryOperatorParamsRequest) Reset()

func (*QueryOperatorParamsRequest) Size added in v1.3.0 

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

func (*QueryOperatorParamsRequest) String added in v1.3.0 

func (m *QueryOperatorParamsRequest) String() string

func (*QueryOperatorParamsRequest) Unmarshal added in v1.3.0 

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

func (*QueryOperatorParamsRequest) XXX_DiscardUnknown added in v1.3.0 

func (m *QueryOperatorParamsRequest) XXX_DiscardUnknown()

func (*QueryOperatorParamsRequest) XXX_Marshal added in v1.3.0 

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

func (*QueryOperatorParamsRequest) XXX_Merge added in v1.3.0 

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

func (*QueryOperatorParamsRequest) XXX_Size added in v1.3.0 

func (m *QueryOperatorParamsRequest) XXX_Size() int

func (*QueryOperatorParamsRequest) XXX_Unmarshal added in v1.3.0 

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

type QueryOperatorParamsResponse added in v1.3.0 

type QueryOperatorParamsResponse struct {
	OperatorParams OperatorParams `protobuf:"bytes,1,opt,name=operator_params,json=operatorParams,proto3" json:"operator_params"`
}

QueryOperatorParamsResponse is the response type for the Query/OperatorParams RPC method.

func (*QueryOperatorParamsResponse) Descriptor added in v1.3.0 

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

func (*QueryOperatorParamsResponse) GetOperatorParams added in v1.3.0 

func (m *QueryOperatorParamsResponse) GetOperatorParams() OperatorParams

func (*QueryOperatorParamsResponse) Marshal added in v1.3.0 

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

func (*QueryOperatorParamsResponse) MarshalTo added in v1.3.0 

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

func (*QueryOperatorParamsResponse) MarshalToSizedBuffer added in v1.3.0 

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

func (*QueryOperatorParamsResponse) ProtoMessage added in v1.3.0 

func (*QueryOperatorParamsResponse) ProtoMessage()

func (*QueryOperatorParamsResponse) Reset added in v1.3.0 

func (m *QueryOperatorParamsResponse) Reset()

func (*QueryOperatorParamsResponse) Size added in v1.3.0 

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

func (*QueryOperatorParamsResponse) String added in v1.3.0 

func (m *QueryOperatorParamsResponse) String() string

func (*QueryOperatorParamsResponse) Unmarshal added in v1.3.0 

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

func (*QueryOperatorParamsResponse) XXX_DiscardUnknown added in v1.3.0 

func (m *QueryOperatorParamsResponse) XXX_DiscardUnknown()

func (*QueryOperatorParamsResponse) XXX_Marshal added in v1.3.0 

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

func (*QueryOperatorParamsResponse) XXX_Merge added in v1.3.0 

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

func (*QueryOperatorParamsResponse) XXX_Size added in v1.3.0 

func (m *QueryOperatorParamsResponse) XXX_Size() int

func (*QueryOperatorParamsResponse) XXX_Unmarshal added in v1.3.0 

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

type QueryOperatorRequest 

type QueryOperatorRequest struct {
	// OperatorId is the ID of the operator to query
	OperatorId uint32 `protobuf:"varint,1,opt,name=operator_id,json=operatorId,proto3" json:"operator_id,omitempty"`
}

QueryOperatorRequest is the request type for the Query/Operator RPC method.

func NewQueryOperatorRequest 

func NewQueryOperatorRequest(operatorID uint32) *QueryOperatorRequest

NewQueryOperatorRequest creates a new QueryOperatorRequest object

func (*QueryOperatorRequest) Descriptor 

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

func (*QueryOperatorRequest) GetOperatorId 

func (m *QueryOperatorRequest) GetOperatorId() uint32

func (*QueryOperatorRequest) Marshal 

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

func (*QueryOperatorRequest) MarshalTo 

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

func (*QueryOperatorRequest) MarshalToSizedBuffer 

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

func (*QueryOperatorRequest) ProtoMessage 

func (*QueryOperatorRequest) ProtoMessage()

func (*QueryOperatorRequest) Reset 

func (m *QueryOperatorRequest) Reset()

func (*QueryOperatorRequest) Size 

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

func (*QueryOperatorRequest) String 

func (m *QueryOperatorRequest) String() string

func (*QueryOperatorRequest) Unmarshal 

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

func (*QueryOperatorRequest) XXX_DiscardUnknown 

func (m *QueryOperatorRequest) XXX_DiscardUnknown()

func (*QueryOperatorRequest) XXX_Marshal 

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

func (*QueryOperatorRequest) XXX_Merge 

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

func (*QueryOperatorRequest) XXX_Size 

func (m *QueryOperatorRequest) XXX_Size() int

func (*QueryOperatorRequest) XXX_Unmarshal 

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

type QueryOperatorResponse 

type QueryOperatorResponse struct {
	Operator Operator `protobuf:"bytes,1,opt,name=operator,proto3" json:"operator"`
}

QueryOperatorResponse is the response type for the Query/Operator RPC method.

func (*QueryOperatorResponse) Descriptor 

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

func (*QueryOperatorResponse) GetOperator 

func (m *QueryOperatorResponse) GetOperator() Operator

func (*QueryOperatorResponse) Marshal 

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

func (*QueryOperatorResponse) MarshalTo 

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

func (*QueryOperatorResponse) MarshalToSizedBuffer 

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

func (*QueryOperatorResponse) ProtoMessage 

func (*QueryOperatorResponse) ProtoMessage()

func (*QueryOperatorResponse) Reset 

func (m *QueryOperatorResponse) Reset()

func (*QueryOperatorResponse) Size 

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

func (*QueryOperatorResponse) String 

func (m *QueryOperatorResponse) String() string

func (*QueryOperatorResponse) Unmarshal 

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

func (*QueryOperatorResponse) XXX_DiscardUnknown 

func (m *QueryOperatorResponse) XXX_DiscardUnknown()

func (*QueryOperatorResponse) XXX_Marshal 

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

func (*QueryOperatorResponse) XXX_Merge 

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

func (*QueryOperatorResponse) XXX_Size 

func (m *QueryOperatorResponse) XXX_Size() int

func (*QueryOperatorResponse) XXX_Unmarshal 

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

type QueryOperatorsRequest 

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

QueryOperatorsRequest is the request type for the Query/Operators RPC method.

func NewQueryOperatorsRequest 

func NewQueryOperatorsRequest(pagination *query.PageRequest) *QueryOperatorsRequest

NewQueryOperatorsRequest creates a new QueryOperatorsRequest object

func (*QueryOperatorsRequest) Descriptor 

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

func (*QueryOperatorsRequest) GetPagination 

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

func (*QueryOperatorsRequest) Marshal 

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

func (*QueryOperatorsRequest) MarshalTo 

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

func (*QueryOperatorsRequest) MarshalToSizedBuffer 

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

func (*QueryOperatorsRequest) ProtoMessage 

func (*QueryOperatorsRequest) ProtoMessage()

func (*QueryOperatorsRequest) Reset 

func (m *QueryOperatorsRequest) Reset()

func (*QueryOperatorsRequest) Size 

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

func (*QueryOperatorsRequest) String 

func (m *QueryOperatorsRequest) String() string

func (*QueryOperatorsRequest) Unmarshal 

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

func (*QueryOperatorsRequest) XXX_DiscardUnknown 

func (m *QueryOperatorsRequest) XXX_DiscardUnknown()

func (*QueryOperatorsRequest) XXX_Marshal 

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

func (*QueryOperatorsRequest) XXX_Merge 

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

func (*QueryOperatorsRequest) XXX_Size 

func (m *QueryOperatorsRequest) XXX_Size() int

func (*QueryOperatorsRequest) XXX_Unmarshal 

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

type QueryOperatorsResponse 

type QueryOperatorsResponse struct {
	// Operators is the list of operators
	Operators []Operator `protobuf:"bytes,1,rep,name=operators,proto3" json:"operators"`
	// Pagination defines the pagination response
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryOperatorsResponse is the response type for the Query/Operators RPC method.

func (*QueryOperatorsResponse) Descriptor 

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

func (*QueryOperatorsResponse) GetOperators 

func (m *QueryOperatorsResponse) GetOperators() []Operator

func (*QueryOperatorsResponse) GetPagination 

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

func (*QueryOperatorsResponse) Marshal 

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

func (*QueryOperatorsResponse) MarshalTo 

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

func (*QueryOperatorsResponse) MarshalToSizedBuffer 

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

func (*QueryOperatorsResponse) ProtoMessage 

func (*QueryOperatorsResponse) ProtoMessage()

func (*QueryOperatorsResponse) Reset 

func (m *QueryOperatorsResponse) Reset()

func (*QueryOperatorsResponse) Size 

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

func (*QueryOperatorsResponse) String 

func (m *QueryOperatorsResponse) String() string

func (*QueryOperatorsResponse) Unmarshal 

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

func (*QueryOperatorsResponse) XXX_DiscardUnknown 

func (m *QueryOperatorsResponse) XXX_DiscardUnknown()

func (*QueryOperatorsResponse) XXX_Marshal 

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

func (*QueryOperatorsResponse) XXX_Merge 

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

func (*QueryOperatorsResponse) XXX_Size 

func (m *QueryOperatorsResponse) XXX_Size() int

func (*QueryOperatorsResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest is the request type for the Query/Params RPC method.

func NewQueryParamsRequest 

func NewQueryParamsRequest() *QueryParamsRequest

NewQueryParamsRequest creates a new QueryParamsRequest object

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

type QueryParamsResponse struct {
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse is the response type for the Query/Params RPC method.

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Operator defines a gRPC query method that returns the operator by the given
	// operator id.
	Operator(context.Context, *QueryOperatorRequest) (*QueryOperatorResponse, error)
	// OperatorParams defines a gRPC query method that returns the operator's
	// params by the given operator id.
	OperatorParams(context.Context, *QueryOperatorParamsRequest) (*QueryOperatorParamsResponse, error)
	// Operators defines a gRPC query method that returns the list of operators.
	Operators(context.Context, *QueryOperatorsRequest) (*QueryOperatorsResponse, error)
	// Params defines a gRPC query method that returns the parameters of the
	// module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
}

QueryServer is the server API for Query service.

type UnbondingOperator 

type UnbondingOperator struct {
	// OperatorID is the ID of the operator that is being unbonded.
	OperatorID uint32 `protobuf:"varint,1,opt,name=operator_id,json=operatorId,proto3" json:"operator_id,omitempty"`
	// UnbondingCompletionTime is the time at which the unbonding of the operator
	// will be completed
	UnbondingCompletionTime time.Time `` /* 130-byte string literal not displayed */
}

UnbondingOperator contains the data about an operator that is currently being unbonded.

func NewUnbondingOperator 

func NewUnbondingOperator(operatorID uint32, completionTime time.Time) UnbondingOperator

NewUnbondingOperator creates a new UnbondingOperator instance.

func (*UnbondingOperator) Descriptor 

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

func (*UnbondingOperator) GetOperatorID 

func (m *UnbondingOperator) GetOperatorID() uint32

func (*UnbondingOperator) GetUnbondingCompletionTime 

func (m *UnbondingOperator) GetUnbondingCompletionTime() time.Time

func (*UnbondingOperator) Marshal 

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

func (*UnbondingOperator) MarshalTo 

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

func (*UnbondingOperator) MarshalToSizedBuffer 

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

func (*UnbondingOperator) ProtoMessage 

func (*UnbondingOperator) ProtoMessage()

func (*UnbondingOperator) Reset 

func (m *UnbondingOperator) Reset()

func (*UnbondingOperator) Size 

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

func (*UnbondingOperator) String 

func (m *UnbondingOperator) String() string

func (*UnbondingOperator) Unmarshal 

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

func (*UnbondingOperator) Validate 

func (o *UnbondingOperator) Validate() error

Validate checks that the UnbondingOperator has valid values.

func (*UnbondingOperator) XXX_DiscardUnknown 

func (m *UnbondingOperator) XXX_DiscardUnknown()

func (*UnbondingOperator) XXX_Marshal 

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

func (*UnbondingOperator) XXX_Merge 

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

func (*UnbondingOperator) XXX_Size 

func (m *UnbondingOperator) XXX_Size() int

func (*UnbondingOperator) XXX_Unmarshal 

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

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) DeactivateOperator 

func (*UnimplementedMsgServer) DeactivateOperator(ctx context.Context, req *MsgDeactivateOperator) (*MsgDeactivateOperatorResponse, error)

func (*UnimplementedMsgServer) DeleteOperator added in v1.3.0 

func (*UnimplementedMsgServer) DeleteOperator(ctx context.Context, req *MsgDeleteOperator) (*MsgDeleteOperatorResponse, error)

func (*UnimplementedMsgServer) RegisterOperator 

func (*UnimplementedMsgServer) RegisterOperator(ctx context.Context, req *MsgRegisterOperator) (*MsgRegisterOperatorResponse, error)

func (*UnimplementedMsgServer) SetOperatorParams added in v1.3.0 

func (*UnimplementedMsgServer) SetOperatorParams(ctx context.Context, req *MsgSetOperatorParams) (*MsgSetOperatorParamsResponse, error)

func (*UnimplementedMsgServer) TransferOperatorOwnership 

func (*UnimplementedMsgServer) TransferOperatorOwnership(ctx context.Context, req *MsgTransferOperatorOwnership) (*MsgTransferOperatorOwnershipResponse, error)

func (*UnimplementedMsgServer) UpdateOperator 

func (*UnimplementedMsgServer) UpdateOperator(ctx context.Context, req *MsgUpdateOperator) (*MsgUpdateOperatorResponse, error)

func (*UnimplementedMsgServer) UpdateParams 

func (*UnimplementedMsgServer) UpdateParams(ctx context.Context, req *MsgUpdateParams) (*MsgUpdateParamsResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Operator 

func (*UnimplementedQueryServer) Operator(ctx context.Context, req *QueryOperatorRequest) (*QueryOperatorResponse, error)

func (*UnimplementedQueryServer) OperatorParams added in v1.3.0 

func (*UnimplementedQueryServer) OperatorParams(ctx context.Context, req *QueryOperatorParamsRequest) (*QueryOperatorParamsResponse, error)

func (*UnimplementedQueryServer) Operators 

func (*UnimplementedQueryServer) Operators(ctx context.Context, req *QueryOperatorsRequest) (*QueryOperatorsResponse, error)

func (*UnimplementedQueryServer) Params 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, 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.