types

package
v0.9.3 Latest Latest
Warning

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

 Go to latest Published: Oct 14, 2022 License: Apache-2.0 Imports: 33 Imported by: 7

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	ModuleName   = "plan"
	QuerierRoute = ModuleName
)

Variables

View Source 
var (
	ErrorInvalidField    = errors.Register(ModuleName, 101, "invalid field")
	ErrorInvalidFrom     = errors.Register(ModuleName, 102, "invalid from")
	ErrorInvalidPrice    = errors.Register(ModuleName, 103, "invalid price")
	ErrorInvalidValidity = errors.Register(ModuleName, 104, "invalid validity")
	ErrorInvalidBytes    = errors.Register(ModuleName, 105, "invalid bytes")
	ErrorInvalidId       = errors.Register(ModuleName, 106, "invalid id")
	ErrorInvalidStatus   = errors.Register(ModuleName, 107, "invalid status")
	ErrorInvalidAddress  = errors.Register(ModuleName, 108, "invalid address")
)
View Source 
var (
	ErrorProviderDoesNotExist = errors.Register(ModuleName, 201, "provider does not exist")
	ErrorPlanDoesNotExist     = errors.Register(ModuleName, 202, "plan does not exist")
	ErrorNodeDoesNotExist     = errors.Register(ModuleName, 203, "node does not exist")
	ErrorUnauthorized         = errors.Register(ModuleName, 204, "unauthorized")
	DuplicateNodeForPlan      = errors.Register(ModuleName, 205, "duplicate node for plan")
)
View Source 
var (
	ErrInvalidLengthEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group")
)
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 (
	RouterKey = ModuleName
	StoreKey  = ModuleName
)
View Source 
var (
	TypeMsgAddRequest        = ModuleName + ":add"
	TypeMsgSetStatusRequest  = ModuleName + ":set_status"
	TypeMsgAddNodeRequest    = ModuleName + ":add_node"
	TypeMsgRemoveNodeRequest = ModuleName + ":remove_node"
)
View Source 
var (
	CountKey                         = []byte{0x00}
	PlanKeyPrefix                    = []byte{0x10}
	ActivePlanKeyPrefix              = []byte{0x20}
	InactivePlanKeyPrefix            = []byte{0x21}
	ActivePlanForProviderKeyPrefix   = []byte{0x30}
	InactivePlanForProviderKeyPrefix = []byte{0x31}
	NodeForPlanKeyPrefix             = []byte{0x40}
	CountForNodeByProviderKeyPrefix  = []byte{0x50}
)
View Source 
var (
	ErrInvalidLengthMsg        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMsg          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMsg = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPlan        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPlan          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPlan = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuerier        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuerier          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuerier = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ModuleCdc = codec.NewAminoCodec(amino)
)

Functions

func ActivePlanForProviderKey added in v0.4.0 

func ActivePlanForProviderKey(addr hubtypes.ProvAddress, id uint64) []byte

func ActivePlanKey added in v0.4.0 

func ActivePlanKey(id uint64) []byte

func AddressFromNodeForPlanKey added in v0.4.0 

func AddressFromNodeForPlanKey(key []byte) hubtypes.NodeAddress

func CountForNodeByProviderKey added in v0.6.1 

func CountForNodeByProviderKey(provider hubtypes.ProvAddress, node hubtypes.NodeAddress) []byte

func GetActivePlanForProviderKeyPrefix added in v0.4.0 

func GetActivePlanForProviderKeyPrefix(addr hubtypes.ProvAddress) []byte

func GetInactivePlanForProviderKeyPrefix added in v0.4.0 

func GetInactivePlanForProviderKeyPrefix(addr hubtypes.ProvAddress) []byte

func GetNodeForPlanKeyPrefix 

func GetNodeForPlanKeyPrefix(id uint64) []byte

func IDFromStatusPlanForProviderKey added in v0.4.0 

func IDFromStatusPlanForProviderKey(key []byte) uint64

func IDFromStatusPlanKey added in v0.4.0 

func IDFromStatusPlanKey(key []byte) uint64

func InactivePlanForProviderKey added in v0.4.0 

func InactivePlanForProviderKey(addr hubtypes.ProvAddress, id uint64) []byte

func InactivePlanKey added in v0.4.0 

func InactivePlanKey(id uint64) []byte

func NodeForPlanKey 

func NodeForPlanKey(id uint64, addr hubtypes.NodeAddress) []byte

func PlanKey 

func PlanKey(id uint64) []byte

func RegisterInterfaces added in v0.6.0 

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterLegacyAminoCodec added in v0.6.0 

func RegisterLegacyAminoCodec(_ *codec.LegacyAmino)

func RegisterMsgServiceServer added in v0.6.0 

func RegisterMsgServiceServer(s grpc1.Server, srv MsgServiceServer)

func RegisterQueryServiceHandler added in v0.6.0 

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

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

func RegisterQueryServiceHandlerClient added in v0.6.0 

func RegisterQueryServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryServiceClient) error

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

func RegisterQueryServiceHandlerFromEndpoint added in v0.6.0 

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

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

func RegisterQueryServiceHandlerServer added in v0.6.0 

func RegisterQueryServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServiceServer) error

RegisterQueryServiceHandlerServer registers the http handlers for service QueryService to "mux". UnaryRPC :call QueryServiceServer 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 RegisterQueryServiceHandlerFromEndpoint instead.

func RegisterQueryServiceServer added in v0.6.0 

func RegisterQueryServiceServer(s grpc1.Server, srv QueryServiceServer)

func ValidateGenesis added in v0.6.0 

func ValidateGenesis(state GenesisState) error

Types

type EventAdd added in v0.8.0 

type EventAdd struct {
	Id       uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id"`
	Provider string `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty" yaml:"provider"`
}

func (*EventAdd) Descriptor added in v0.8.0 

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

func (*EventAdd) Marshal added in v0.8.0 

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

func (*EventAdd) MarshalTo added in v0.8.0 

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

func (*EventAdd) MarshalToSizedBuffer added in v0.8.0 

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

func (*EventAdd) ProtoMessage added in v0.8.0 

func (*EventAdd) ProtoMessage()

func (*EventAdd) Reset added in v0.8.0 

func (m *EventAdd) Reset()

func (*EventAdd) Size added in v0.8.0 

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

func (*EventAdd) String added in v0.8.0 

func (m *EventAdd) String() string

func (*EventAdd) Unmarshal added in v0.8.0 

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

func (*EventAdd) XXX_DiscardUnknown added in v0.8.0 

func (m *EventAdd) XXX_DiscardUnknown()

func (*EventAdd) XXX_Marshal added in v0.8.0 

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

func (*EventAdd) XXX_Merge added in v0.8.0 

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

func (*EventAdd) XXX_Size added in v0.8.0 

func (m *EventAdd) XXX_Size() int

func (*EventAdd) XXX_Unmarshal added in v0.8.0 

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

type EventAddNode added in v0.8.0 

type EventAddNode struct {
	Id       uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id"`
	Node     string `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty" yaml:"node"`
	Provider string `protobuf:"bytes,3,opt,name=provider,proto3" json:"provider,omitempty" yaml:"provider"`
}

func (*EventAddNode) Descriptor added in v0.8.0 

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

func (*EventAddNode) Marshal added in v0.8.0 

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

func (*EventAddNode) MarshalTo added in v0.8.0 

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

func (*EventAddNode) MarshalToSizedBuffer added in v0.8.0 

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

func (*EventAddNode) ProtoMessage added in v0.8.0 

func (*EventAddNode) ProtoMessage()

func (*EventAddNode) Reset added in v0.8.0 

func (m *EventAddNode) Reset()

func (*EventAddNode) Size added in v0.8.0 

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

func (*EventAddNode) String added in v0.8.0 

func (m *EventAddNode) String() string

func (*EventAddNode) Unmarshal added in v0.8.0 

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

func (*EventAddNode) XXX_DiscardUnknown added in v0.8.0 

func (m *EventAddNode) XXX_DiscardUnknown()

func (*EventAddNode) XXX_Marshal added in v0.8.0 

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

func (*EventAddNode) XXX_Merge added in v0.8.0 

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

func (*EventAddNode) XXX_Size added in v0.8.0 

func (m *EventAddNode) XXX_Size() int

func (*EventAddNode) XXX_Unmarshal added in v0.8.0 

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

type EventRemoveNode added in v0.8.0 

type EventRemoveNode struct {
	Id       uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id"`
	Node     string `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty" yaml:"node"`
	Provider string `protobuf:"bytes,3,opt,name=provider,proto3" json:"provider,omitempty" yaml:"provider"`
}

func (*EventRemoveNode) Descriptor added in v0.8.0 

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

func (*EventRemoveNode) Marshal added in v0.8.0 

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

func (*EventRemoveNode) MarshalTo added in v0.8.0 

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

func (*EventRemoveNode) MarshalToSizedBuffer added in v0.8.0 

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

func (*EventRemoveNode) ProtoMessage added in v0.8.0 

func (*EventRemoveNode) ProtoMessage()

func (*EventRemoveNode) Reset added in v0.8.0 

func (m *EventRemoveNode) Reset()

func (*EventRemoveNode) Size added in v0.8.0 

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

func (*EventRemoveNode) String added in v0.8.0 

func (m *EventRemoveNode) String() string

func (*EventRemoveNode) Unmarshal added in v0.8.0 

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

func (*EventRemoveNode) XXX_DiscardUnknown added in v0.8.0 

func (m *EventRemoveNode) XXX_DiscardUnknown()

func (*EventRemoveNode) XXX_Marshal added in v0.8.0 

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

func (*EventRemoveNode) XXX_Merge added in v0.8.0 

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

func (*EventRemoveNode) XXX_Size added in v0.8.0 

func (m *EventRemoveNode) XXX_Size() int

func (*EventRemoveNode) XXX_Unmarshal added in v0.8.0 

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

type EventSetStatus added in v0.8.0 

type EventSetStatus struct {
	Id       uint64       `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id"`
	Provider string       `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty" yaml:"provider"`
	Status   types.Status `protobuf:"varint,3,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty" yaml:"status"`
}

func (*EventSetStatus) Descriptor added in v0.8.0 

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

func (*EventSetStatus) Marshal added in v0.8.0 

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

func (*EventSetStatus) MarshalTo added in v0.8.0 

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

func (*EventSetStatus) MarshalToSizedBuffer added in v0.8.0 

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

func (*EventSetStatus) ProtoMessage added in v0.8.0 

func (*EventSetStatus) ProtoMessage()

func (*EventSetStatus) Reset added in v0.8.0 

func (m *EventSetStatus) Reset()

func (*EventSetStatus) Size added in v0.8.0 

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

func (*EventSetStatus) String added in v0.8.0 

func (m *EventSetStatus) String() string

func (*EventSetStatus) Unmarshal added in v0.8.0 

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

func (*EventSetStatus) XXX_DiscardUnknown added in v0.8.0 

func (m *EventSetStatus) XXX_DiscardUnknown()

func (*EventSetStatus) XXX_Marshal added in v0.8.0 

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

func (*EventSetStatus) XXX_Merge added in v0.8.0 

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

func (*EventSetStatus) XXX_Size added in v0.8.0 

func (m *EventSetStatus) XXX_Size() int

func (*EventSetStatus) XXX_Unmarshal added in v0.8.0 

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

type GenesisPlan 

type GenesisPlan struct {
	Plan  Plan     `protobuf:"bytes,1,opt,name=plan,proto3" json:"_,omitempty"`
	Nodes []string `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"`
}

func (*GenesisPlan) Descriptor added in v0.6.0 

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

func (*GenesisPlan) Marshal added in v0.6.0 

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

func (*GenesisPlan) MarshalTo added in v0.6.0 

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

func (*GenesisPlan) MarshalToSizedBuffer added in v0.6.0 

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

func (*GenesisPlan) ProtoMessage added in v0.6.0 

func (*GenesisPlan) ProtoMessage()

func (*GenesisPlan) Reset added in v0.6.0 

func (m *GenesisPlan) Reset()

func (*GenesisPlan) Size added in v0.6.0 

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

func (*GenesisPlan) String added in v0.6.0 

func (m *GenesisPlan) String() string

func (*GenesisPlan) Unmarshal added in v0.6.0 

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

func (*GenesisPlan) XXX_DiscardUnknown added in v0.6.0 

func (m *GenesisPlan) XXX_DiscardUnknown()

func (*GenesisPlan) XXX_Marshal added in v0.6.0 

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

func (*GenesisPlan) XXX_Merge added in v0.6.0 

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

func (*GenesisPlan) XXX_Size added in v0.6.0 

func (m *GenesisPlan) XXX_Size() int

func (*GenesisPlan) XXX_Unmarshal added in v0.6.0 

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

type GenesisPlans 

type GenesisPlans []GenesisPlan

type GenesisState 

type GenesisState GenesisPlans

func DefaultGenesisState 

func DefaultGenesisState() GenesisState

func NewGenesisState 

func NewGenesisState(plans GenesisPlans) GenesisState

type MsgAddNodeRequest added in v0.6.0 

type MsgAddNodeRequest struct {
	From    string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	Id      uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
}

MsgAddNodeRequest defines the SDK message for adding a node to a plan

func NewMsgAddNodeRequest added in v0.6.0 

func NewMsgAddNodeRequest(from hubtypes.ProvAddress, id uint64, address hubtypes.NodeAddress) *MsgAddNodeRequest

func (*MsgAddNodeRequest) Descriptor added in v0.6.0 

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

func (*MsgAddNodeRequest) GetSignBytes added in v0.6.0 

func (m *MsgAddNodeRequest) GetSignBytes() []byte

func (*MsgAddNodeRequest) GetSigners added in v0.6.0 

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

func (*MsgAddNodeRequest) Marshal added in v0.6.0 

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

func (*MsgAddNodeRequest) MarshalTo added in v0.6.0 

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

func (*MsgAddNodeRequest) MarshalToSizedBuffer added in v0.6.0 

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

func (*MsgAddNodeRequest) ProtoMessage added in v0.6.0 

func (*MsgAddNodeRequest) ProtoMessage()

func (*MsgAddNodeRequest) Reset added in v0.6.0 

func (m *MsgAddNodeRequest) Reset()

func (*MsgAddNodeRequest) Route added in v0.6.0 

func (m *MsgAddNodeRequest) Route() string

func (*MsgAddNodeRequest) Size added in v0.6.0 

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

func (*MsgAddNodeRequest) String added in v0.6.0 

func (m *MsgAddNodeRequest) String() string

func (*MsgAddNodeRequest) Type added in v0.6.0 

func (m *MsgAddNodeRequest) Type() string

func (*MsgAddNodeRequest) Unmarshal added in v0.6.0 

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

func (*MsgAddNodeRequest) ValidateBasic added in v0.6.0 

func (m *MsgAddNodeRequest) ValidateBasic() error

func (*MsgAddNodeRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *MsgAddNodeRequest) XXX_DiscardUnknown()

func (*MsgAddNodeRequest) XXX_Marshal added in v0.6.0 

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

func (*MsgAddNodeRequest) XXX_Merge added in v0.6.0 

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

func (*MsgAddNodeRequest) XXX_Size added in v0.6.0 

func (m *MsgAddNodeRequest) XXX_Size() int

func (*MsgAddNodeRequest) XXX_Unmarshal added in v0.6.0 

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

type MsgAddNodeResponse added in v0.6.0 

type MsgAddNodeResponse struct {
}

MsgAddNodeResponse defines the response of message MsgAddNodeRequest

func (*MsgAddNodeResponse) Descriptor added in v0.6.0 

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

func (*MsgAddNodeResponse) Marshal added in v0.6.0 

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

func (*MsgAddNodeResponse) MarshalTo added in v0.6.0 

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

func (*MsgAddNodeResponse) MarshalToSizedBuffer added in v0.6.0 

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

func (*MsgAddNodeResponse) ProtoMessage added in v0.6.0 

func (*MsgAddNodeResponse) ProtoMessage()

func (*MsgAddNodeResponse) Reset added in v0.6.0 

func (m *MsgAddNodeResponse) Reset()

func (*MsgAddNodeResponse) Size added in v0.6.0 

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

func (*MsgAddNodeResponse) String added in v0.6.0 

func (m *MsgAddNodeResponse) String() string

func (*MsgAddNodeResponse) Unmarshal added in v0.6.0 

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

func (*MsgAddNodeResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *MsgAddNodeResponse) XXX_DiscardUnknown()

func (*MsgAddNodeResponse) XXX_Marshal added in v0.6.0 

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

func (*MsgAddNodeResponse) XXX_Merge added in v0.6.0 

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

func (*MsgAddNodeResponse) XXX_Size added in v0.6.0 

func (m *MsgAddNodeResponse) XXX_Size() int

func (*MsgAddNodeResponse) XXX_Unmarshal added in v0.6.0 

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

type MsgAddRequest added in v0.6.0 

type MsgAddRequest struct {
	From     string                                   `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	Price    github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,2,rep,name=price,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"price"`
	Validity time.Duration                            `protobuf:"bytes,3,opt,name=validity,proto3,stdduration" json:"validity"`
	Bytes    github_com_cosmos_cosmos_sdk_types.Int   `protobuf:"bytes,4,opt,name=bytes,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"bytes"`
}

MsgAddRequest defines the SDK message for adding a plan

func NewMsgAddRequest added in v0.6.0 

func NewMsgAddRequest(from hubtypes.ProvAddress, price sdk.Coins, validity time.Duration, bytes sdk.Int) *MsgAddRequest

func (*MsgAddRequest) Descriptor added in v0.6.0 

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

func (*MsgAddRequest) GetSignBytes added in v0.6.0 

func (m *MsgAddRequest) GetSignBytes() []byte

func (*MsgAddRequest) GetSigners added in v0.6.0 

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

func (*MsgAddRequest) Marshal added in v0.6.0 

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

func (*MsgAddRequest) MarshalTo added in v0.6.0 

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

func (*MsgAddRequest) MarshalToSizedBuffer added in v0.6.0 

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

func (*MsgAddRequest) ProtoMessage added in v0.6.0 

func (*MsgAddRequest) ProtoMessage()

func (*MsgAddRequest) Reset added in v0.6.0 

func (m *MsgAddRequest) Reset()

func (*MsgAddRequest) Route added in v0.6.0 

func (m *MsgAddRequest) Route() string

func (*MsgAddRequest) Size added in v0.6.0 

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

func (*MsgAddRequest) String added in v0.6.0 

func (m *MsgAddRequest) String() string

func (*MsgAddRequest) Type added in v0.6.0 

func (m *MsgAddRequest) Type() string

func (*MsgAddRequest) Unmarshal added in v0.6.0 

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

func (*MsgAddRequest) ValidateBasic added in v0.6.0 

func (m *MsgAddRequest) ValidateBasic() error

func (*MsgAddRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *MsgAddRequest) XXX_DiscardUnknown()

func (*MsgAddRequest) XXX_Marshal added in v0.6.0 

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

func (*MsgAddRequest) XXX_Merge added in v0.6.0 

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

func (*MsgAddRequest) XXX_Size added in v0.6.0 

func (m *MsgAddRequest) XXX_Size() int

func (*MsgAddRequest) XXX_Unmarshal added in v0.6.0 

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

type MsgAddResponse added in v0.6.0 

type MsgAddResponse struct {
}

MsgAddResponse defines the response of message MsgRegisterRequest

func (*MsgAddResponse) Descriptor added in v0.6.0 

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

func (*MsgAddResponse) Marshal added in v0.6.0 

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

func (*MsgAddResponse) MarshalTo added in v0.6.0 

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

func (*MsgAddResponse) MarshalToSizedBuffer added in v0.6.0 

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

func (*MsgAddResponse) ProtoMessage added in v0.6.0 

func (*MsgAddResponse) ProtoMessage()

func (*MsgAddResponse) Reset added in v0.6.0 

func (m *MsgAddResponse) Reset()

func (*MsgAddResponse) Size added in v0.6.0 

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

func (*MsgAddResponse) String added in v0.6.0 

func (m *MsgAddResponse) String() string

func (*MsgAddResponse) Unmarshal added in v0.6.0 

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

func (*MsgAddResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *MsgAddResponse) XXX_DiscardUnknown()

func (*MsgAddResponse) XXX_Marshal added in v0.6.0 

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

func (*MsgAddResponse) XXX_Merge added in v0.6.0 

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

func (*MsgAddResponse) XXX_Size added in v0.6.0 

func (m *MsgAddResponse) XXX_Size() int

func (*MsgAddResponse) XXX_Unmarshal added in v0.6.0 

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

type MsgRemoveNodeRequest added in v0.6.0 

type MsgRemoveNodeRequest struct {
	From    string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	Id      uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
}

MsgRemoveNodeRequest defines the SDK message for removing a node from a plan

func NewMsgRemoveNodeRequest added in v0.6.0 

func NewMsgRemoveNodeRequest(from sdk.AccAddress, id uint64, address hubtypes.NodeAddress) *MsgRemoveNodeRequest

func (*MsgRemoveNodeRequest) Descriptor added in v0.6.0 

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

func (*MsgRemoveNodeRequest) GetSignBytes added in v0.6.0 

func (m *MsgRemoveNodeRequest) GetSignBytes() []byte

func (*MsgRemoveNodeRequest) GetSigners added in v0.6.0 

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

func (*MsgRemoveNodeRequest) Marshal added in v0.6.0 

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

func (*MsgRemoveNodeRequest) MarshalTo added in v0.6.0 

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

func (*MsgRemoveNodeRequest) MarshalToSizedBuffer added in v0.6.0 

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

func (*MsgRemoveNodeRequest) ProtoMessage added in v0.6.0 

func (*MsgRemoveNodeRequest) ProtoMessage()

func (*MsgRemoveNodeRequest) Reset added in v0.6.0 

func (m *MsgRemoveNodeRequest) Reset()

func (*MsgRemoveNodeRequest) Route added in v0.6.0 

func (m *MsgRemoveNodeRequest) Route() string

func (*MsgRemoveNodeRequest) Size added in v0.6.0 

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

func (*MsgRemoveNodeRequest) String added in v0.6.0 

func (m *MsgRemoveNodeRequest) String() string

func (*MsgRemoveNodeRequest) Type added in v0.6.0 

func (m *MsgRemoveNodeRequest) Type() string

func (*MsgRemoveNodeRequest) Unmarshal added in v0.6.0 

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

func (*MsgRemoveNodeRequest) ValidateBasic added in v0.6.0 

func (m *MsgRemoveNodeRequest) ValidateBasic() error

func (*MsgRemoveNodeRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *MsgRemoveNodeRequest) XXX_DiscardUnknown()

func (*MsgRemoveNodeRequest) XXX_Marshal added in v0.6.0 

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

func (*MsgRemoveNodeRequest) XXX_Merge added in v0.6.0 

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

func (*MsgRemoveNodeRequest) XXX_Size added in v0.6.0 

func (m *MsgRemoveNodeRequest) XXX_Size() int

func (*MsgRemoveNodeRequest) XXX_Unmarshal added in v0.6.0 

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

type MsgRemoveNodeResponse added in v0.6.0 

type MsgRemoveNodeResponse struct {
}

MsgRemoveNodeResponse defines the response of message MsgRemoveNodeRequest

func (*MsgRemoveNodeResponse) Descriptor added in v0.6.0 

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

func (*MsgRemoveNodeResponse) Marshal added in v0.6.0 

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

func (*MsgRemoveNodeResponse) MarshalTo added in v0.6.0 

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

func (*MsgRemoveNodeResponse) MarshalToSizedBuffer added in v0.6.0 

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

func (*MsgRemoveNodeResponse) ProtoMessage added in v0.6.0 

func (*MsgRemoveNodeResponse) ProtoMessage()

func (*MsgRemoveNodeResponse) Reset added in v0.6.0 

func (m *MsgRemoveNodeResponse) Reset()

func (*MsgRemoveNodeResponse) Size added in v0.6.0 

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

func (*MsgRemoveNodeResponse) String added in v0.6.0 

func (m *MsgRemoveNodeResponse) String() string

func (*MsgRemoveNodeResponse) Unmarshal added in v0.6.0 

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

func (*MsgRemoveNodeResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *MsgRemoveNodeResponse) XXX_DiscardUnknown()

func (*MsgRemoveNodeResponse) XXX_Marshal added in v0.6.0 

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

func (*MsgRemoveNodeResponse) XXX_Merge added in v0.6.0 

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

func (*MsgRemoveNodeResponse) XXX_Size added in v0.6.0 

func (m *MsgRemoveNodeResponse) XXX_Size() int

func (*MsgRemoveNodeResponse) XXX_Unmarshal added in v0.6.0 

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

type MsgServiceClient added in v0.6.0 

type MsgServiceClient interface {
	MsgAdd(ctx context.Context, in *MsgAddRequest, opts ...grpc.CallOption) (*MsgAddResponse, error)
	MsgSetStatus(ctx context.Context, in *MsgSetStatusRequest, opts ...grpc.CallOption) (*MsgSetStatusResponse, error)
	MsgAddNode(ctx context.Context, in *MsgAddNodeRequest, opts ...grpc.CallOption) (*MsgAddNodeResponse, error)
	MsgRemoveNode(ctx context.Context, in *MsgRemoveNodeRequest, opts ...grpc.CallOption) (*MsgRemoveNodeResponse, error)
}

MsgServiceClient is the client API for MsgService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMsgServiceClient added in v0.6.0 

func NewMsgServiceClient(cc grpc1.ClientConn) MsgServiceClient

type MsgServiceServer added in v0.6.0 

type MsgServiceServer interface {
	MsgAdd(context.Context, *MsgAddRequest) (*MsgAddResponse, error)
	MsgSetStatus(context.Context, *MsgSetStatusRequest) (*MsgSetStatusResponse, error)
	MsgAddNode(context.Context, *MsgAddNodeRequest) (*MsgAddNodeResponse, error)
	MsgRemoveNode(context.Context, *MsgRemoveNodeRequest) (*MsgRemoveNodeResponse, error)
}

MsgServiceServer is the server API for MsgService service.

type MsgSetStatusRequest added in v0.6.0 

type MsgSetStatusRequest struct {
	From   string        `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	Id     uint64        `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Status types1.Status `protobuf:"varint,3,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"`
}

MsgSetStatusRequest defines the SDK message for modifying the status of a plan

func NewMsgSetStatusRequest added in v0.6.0 

func NewMsgSetStatusRequest(from hubtypes.ProvAddress, id uint64, status hubtypes.Status) *MsgSetStatusRequest

func (*MsgSetStatusRequest) Descriptor added in v0.6.0 

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

func (*MsgSetStatusRequest) GetSignBytes added in v0.6.0 

func (m *MsgSetStatusRequest) GetSignBytes() []byte

func (*MsgSetStatusRequest) GetSigners added in v0.6.0 

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

func (*MsgSetStatusRequest) Marshal added in v0.6.0 

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

func (*MsgSetStatusRequest) MarshalTo added in v0.6.0 

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

func (*MsgSetStatusRequest) MarshalToSizedBuffer added in v0.6.0 

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

func (*MsgSetStatusRequest) ProtoMessage added in v0.6.0 

func (*MsgSetStatusRequest) ProtoMessage()

func (*MsgSetStatusRequest) Reset added in v0.6.0 

func (m *MsgSetStatusRequest) Reset()

func (*MsgSetStatusRequest) Route added in v0.6.0 

func (m *MsgSetStatusRequest) Route() string

func (*MsgSetStatusRequest) Size added in v0.6.0 

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

func (*MsgSetStatusRequest) String added in v0.6.0 

func (m *MsgSetStatusRequest) String() string

func (*MsgSetStatusRequest) Type added in v0.6.0 

func (m *MsgSetStatusRequest) Type() string

func (*MsgSetStatusRequest) Unmarshal added in v0.6.0 

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

func (*MsgSetStatusRequest) ValidateBasic added in v0.6.0 

func (m *MsgSetStatusRequest) ValidateBasic() error

func (*MsgSetStatusRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *MsgSetStatusRequest) XXX_DiscardUnknown()

func (*MsgSetStatusRequest) XXX_Marshal added in v0.6.0 

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

func (*MsgSetStatusRequest) XXX_Merge added in v0.6.0 

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

func (*MsgSetStatusRequest) XXX_Size added in v0.6.0 

func (m *MsgSetStatusRequest) XXX_Size() int

func (*MsgSetStatusRequest) XXX_Unmarshal added in v0.6.0 

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

type MsgSetStatusResponse added in v0.6.0 

type MsgSetStatusResponse struct {
}

MsgSetStatusResponse defines the response of message MsgSetStatusRequest

func (*MsgSetStatusResponse) Descriptor added in v0.6.0 

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

func (*MsgSetStatusResponse) Marshal added in v0.6.0 

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

func (*MsgSetStatusResponse) MarshalTo added in v0.6.0 

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

func (*MsgSetStatusResponse) MarshalToSizedBuffer added in v0.6.0 

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

func (*MsgSetStatusResponse) ProtoMessage added in v0.6.0 

func (*MsgSetStatusResponse) ProtoMessage()

func (*MsgSetStatusResponse) Reset added in v0.6.0 

func (m *MsgSetStatusResponse) Reset()

func (*MsgSetStatusResponse) Size added in v0.6.0 

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

func (*MsgSetStatusResponse) String added in v0.6.0 

func (m *MsgSetStatusResponse) String() string

func (*MsgSetStatusResponse) Unmarshal added in v0.6.0 

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

func (*MsgSetStatusResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *MsgSetStatusResponse) XXX_DiscardUnknown()

func (*MsgSetStatusResponse) XXX_Marshal added in v0.6.0 

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

func (*MsgSetStatusResponse) XXX_Merge added in v0.6.0 

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

func (*MsgSetStatusResponse) XXX_Size added in v0.6.0 

func (m *MsgSetStatusResponse) XXX_Size() int

func (*MsgSetStatusResponse) XXX_Unmarshal added in v0.6.0 

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

type Plan 

type Plan struct {
	Id       uint64                                   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Provider string                                   `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
	Price    github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,3,rep,name=price,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"price"`
	Validity time.Duration                            `protobuf:"bytes,4,opt,name=validity,proto3,stdduration" json:"validity"`
	Bytes    github_com_cosmos_cosmos_sdk_types.Int   `protobuf:"bytes,5,opt,name=bytes,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"bytes"`
	Status   types1.Status                            `protobuf:"varint,6,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"`
	StatusAt time.Time                                `protobuf:"bytes,7,opt,name=status_at,json=statusAt,proto3,stdtime" json:"status_at"`
}

func (*Plan) Descriptor added in v0.6.0 

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

func (*Plan) GetProvider added in v0.6.0 

func (m *Plan) GetProvider() hubtypes.ProvAddress

func (*Plan) Marshal added in v0.6.0 

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

func (*Plan) MarshalTo added in v0.6.0 

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

func (*Plan) MarshalToSizedBuffer added in v0.6.0 

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

func (*Plan) PriceForDenom 

func (m *Plan) PriceForDenom(d string) (sdk.Coin, bool)

func (*Plan) ProtoMessage added in v0.6.0 

func (*Plan) ProtoMessage()

func (*Plan) Reset added in v0.6.0 

func (m *Plan) Reset()

func (*Plan) Size added in v0.6.0 

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

func (*Plan) String 

func (m *Plan) String() string

func (*Plan) Unmarshal added in v0.6.0 

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

func (*Plan) Validate 

func (m *Plan) Validate() error

func (*Plan) XXX_DiscardUnknown added in v0.6.0 

func (m *Plan) XXX_DiscardUnknown()

func (*Plan) XXX_Marshal added in v0.6.0 

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

func (*Plan) XXX_Merge added in v0.6.0 

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

func (*Plan) XXX_Size added in v0.6.0 

func (m *Plan) XXX_Size() int

func (*Plan) XXX_Unmarshal added in v0.6.0 

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

type Plans 

type Plans []Plan

type QueryNodesForPlanRequest added in v0.6.0 

type QueryNodesForPlanRequest struct {
	Id         uint64             `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func NewQueryNodesForPlanRequest added in v0.6.0 

func NewQueryNodesForPlanRequest(id uint64, pagination *query.PageRequest) *QueryNodesForPlanRequest

func (*QueryNodesForPlanRequest) Descriptor added in v0.6.0 

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

func (*QueryNodesForPlanRequest) Marshal added in v0.6.0 

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

func (*QueryNodesForPlanRequest) MarshalTo added in v0.6.0 

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

func (*QueryNodesForPlanRequest) MarshalToSizedBuffer added in v0.6.0 

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

func (*QueryNodesForPlanRequest) ProtoMessage added in v0.6.0 

func (*QueryNodesForPlanRequest) ProtoMessage()

func (*QueryNodesForPlanRequest) Reset added in v0.6.0 

func (m *QueryNodesForPlanRequest) Reset()

func (*QueryNodesForPlanRequest) Size added in v0.6.0 

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

func (*QueryNodesForPlanRequest) String added in v0.6.0 

func (m *QueryNodesForPlanRequest) String() string

func (*QueryNodesForPlanRequest) Unmarshal added in v0.6.0 

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

func (*QueryNodesForPlanRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *QueryNodesForPlanRequest) XXX_DiscardUnknown()

func (*QueryNodesForPlanRequest) XXX_Marshal added in v0.6.0 

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

func (*QueryNodesForPlanRequest) XXX_Merge added in v0.6.0 

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

func (*QueryNodesForPlanRequest) XXX_Size added in v0.6.0 

func (m *QueryNodesForPlanRequest) XXX_Size() int

func (*QueryNodesForPlanRequest) XXX_Unmarshal added in v0.6.0 

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

type QueryNodesForPlanResponse added in v0.6.0 

type QueryNodesForPlanResponse struct {
	Nodes      []types1.Node       `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*QueryNodesForPlanResponse) Descriptor added in v0.6.0 

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

func (*QueryNodesForPlanResponse) Marshal added in v0.6.0 

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

func (*QueryNodesForPlanResponse) MarshalTo added in v0.6.0 

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

func (*QueryNodesForPlanResponse) MarshalToSizedBuffer added in v0.6.0 

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

func (*QueryNodesForPlanResponse) ProtoMessage added in v0.6.0 

func (*QueryNodesForPlanResponse) ProtoMessage()

func (*QueryNodesForPlanResponse) Reset added in v0.6.0 

func (m *QueryNodesForPlanResponse) Reset()

func (*QueryNodesForPlanResponse) Size added in v0.6.0 

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

func (*QueryNodesForPlanResponse) String added in v0.6.0 

func (m *QueryNodesForPlanResponse) String() string

func (*QueryNodesForPlanResponse) Unmarshal added in v0.6.0 

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

func (*QueryNodesForPlanResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *QueryNodesForPlanResponse) XXX_DiscardUnknown()

func (*QueryNodesForPlanResponse) XXX_Marshal added in v0.6.0 

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

func (*QueryNodesForPlanResponse) XXX_Merge added in v0.6.0 

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

func (*QueryNodesForPlanResponse) XXX_Size added in v0.6.0 

func (m *QueryNodesForPlanResponse) XXX_Size() int

func (*QueryNodesForPlanResponse) XXX_Unmarshal added in v0.6.0 

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

type QueryPlanRequest added in v0.6.0 

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

func NewQueryPlanRequest added in v0.6.0 

func NewQueryPlanRequest(id uint64) *QueryPlanRequest

func (*QueryPlanRequest) Descriptor added in v0.6.0 

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

func (*QueryPlanRequest) Marshal added in v0.6.0 

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

func (*QueryPlanRequest) MarshalTo added in v0.6.0 

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

func (*QueryPlanRequest) MarshalToSizedBuffer added in v0.6.0 

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

func (*QueryPlanRequest) ProtoMessage added in v0.6.0 

func (*QueryPlanRequest) ProtoMessage()

func (*QueryPlanRequest) Reset added in v0.6.0 

func (m *QueryPlanRequest) Reset()

func (*QueryPlanRequest) Size added in v0.6.0 

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

func (*QueryPlanRequest) String added in v0.6.0 

func (m *QueryPlanRequest) String() string

func (*QueryPlanRequest) Unmarshal added in v0.6.0 

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

func (*QueryPlanRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *QueryPlanRequest) XXX_DiscardUnknown()

func (*QueryPlanRequest) XXX_Marshal added in v0.6.0 

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

func (*QueryPlanRequest) XXX_Merge added in v0.6.0 

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

func (*QueryPlanRequest) XXX_Size added in v0.6.0 

func (m *QueryPlanRequest) XXX_Size() int

func (*QueryPlanRequest) XXX_Unmarshal added in v0.6.0 

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

type QueryPlanResponse added in v0.6.0 

type QueryPlanResponse struct {
	Plan Plan `protobuf:"bytes,1,opt,name=plan,proto3" json:"plan"`
}

func (*QueryPlanResponse) Descriptor added in v0.6.0 

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

func (*QueryPlanResponse) Marshal added in v0.6.0 

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

func (*QueryPlanResponse) MarshalTo added in v0.6.0 

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

func (*QueryPlanResponse) MarshalToSizedBuffer added in v0.6.0 

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

func (*QueryPlanResponse) ProtoMessage added in v0.6.0 

func (*QueryPlanResponse) ProtoMessage()

func (*QueryPlanResponse) Reset added in v0.6.0 

func (m *QueryPlanResponse) Reset()

func (*QueryPlanResponse) Size added in v0.6.0 

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

func (*QueryPlanResponse) String added in v0.6.0 

func (m *QueryPlanResponse) String() string

func (*QueryPlanResponse) Unmarshal added in v0.6.0 

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

func (*QueryPlanResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *QueryPlanResponse) XXX_DiscardUnknown()

func (*QueryPlanResponse) XXX_Marshal added in v0.6.0 

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

func (*QueryPlanResponse) XXX_Merge added in v0.6.0 

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

func (*QueryPlanResponse) XXX_Size added in v0.6.0 

func (m *QueryPlanResponse) XXX_Size() int

func (*QueryPlanResponse) XXX_Unmarshal added in v0.6.0 

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

type QueryPlansForProviderRequest added in v0.6.0 

type QueryPlansForProviderRequest struct {
	Address    string             `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Status     types.Status       `protobuf:"varint,2,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func NewQueryPlansForProviderRequest added in v0.6.0 

func NewQueryPlansForProviderRequest(address hubtypes.ProvAddress, status hubtypes.Status, pagination *query.PageRequest) *QueryPlansForProviderRequest

func (*QueryPlansForProviderRequest) Descriptor added in v0.6.0 

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

func (*QueryPlansForProviderRequest) Marshal added in v0.6.0 

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

func (*QueryPlansForProviderRequest) MarshalTo added in v0.6.0 

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

func (*QueryPlansForProviderRequest) MarshalToSizedBuffer added in v0.6.0 

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

func (*QueryPlansForProviderRequest) ProtoMessage added in v0.6.0 

func (*QueryPlansForProviderRequest) ProtoMessage()

func (*QueryPlansForProviderRequest) Reset added in v0.6.0 

func (m *QueryPlansForProviderRequest) Reset()

func (*QueryPlansForProviderRequest) Size added in v0.6.0 

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

func (*QueryPlansForProviderRequest) String added in v0.6.0 

func (m *QueryPlansForProviderRequest) String() string

func (*QueryPlansForProviderRequest) Unmarshal added in v0.6.0 

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

func (*QueryPlansForProviderRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *QueryPlansForProviderRequest) XXX_DiscardUnknown()

func (*QueryPlansForProviderRequest) XXX_Marshal added in v0.6.0 

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

func (*QueryPlansForProviderRequest) XXX_Merge added in v0.6.0 

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

func (*QueryPlansForProviderRequest) XXX_Size added in v0.6.0 

func (m *QueryPlansForProviderRequest) XXX_Size() int

func (*QueryPlansForProviderRequest) XXX_Unmarshal added in v0.6.0 

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

type QueryPlansForProviderResponse added in v0.6.0 

type QueryPlansForProviderResponse struct {
	Plans      []Plan              `protobuf:"bytes,1,rep,name=plans,proto3" json:"plans"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*QueryPlansForProviderResponse) Descriptor added in v0.6.0 

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

func (*QueryPlansForProviderResponse) Marshal added in v0.6.0 

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

func (*QueryPlansForProviderResponse) MarshalTo added in v0.6.0 

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

func (*QueryPlansForProviderResponse) MarshalToSizedBuffer added in v0.6.0 

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

func (*QueryPlansForProviderResponse) ProtoMessage added in v0.6.0 

func (*QueryPlansForProviderResponse) ProtoMessage()

func (*QueryPlansForProviderResponse) Reset added in v0.6.0 

func (m *QueryPlansForProviderResponse) Reset()

func (*QueryPlansForProviderResponse) Size added in v0.6.0 

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

func (*QueryPlansForProviderResponse) String added in v0.6.0 

func (m *QueryPlansForProviderResponse) String() string

func (*QueryPlansForProviderResponse) Unmarshal added in v0.6.0 

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

func (*QueryPlansForProviderResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *QueryPlansForProviderResponse) XXX_DiscardUnknown()

func (*QueryPlansForProviderResponse) XXX_Marshal added in v0.6.0 

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

func (*QueryPlansForProviderResponse) XXX_Merge added in v0.6.0 

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

func (*QueryPlansForProviderResponse) XXX_Size added in v0.6.0 

func (m *QueryPlansForProviderResponse) XXX_Size() int

func (*QueryPlansForProviderResponse) XXX_Unmarshal added in v0.6.0 

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

type QueryPlansRequest added in v0.6.0 

type QueryPlansRequest struct {
	Status     types.Status       `protobuf:"varint,1,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func NewQueryPlansRequest added in v0.6.0 

func NewQueryPlansRequest(status hubtypes.Status, pagination *query.PageRequest) *QueryPlansRequest

func (*QueryPlansRequest) Descriptor added in v0.6.0 

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

func (*QueryPlansRequest) Marshal added in v0.6.0 

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

func (*QueryPlansRequest) MarshalTo added in v0.6.0 

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

func (*QueryPlansRequest) MarshalToSizedBuffer added in v0.6.0 

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

func (*QueryPlansRequest) ProtoMessage added in v0.6.0 

func (*QueryPlansRequest) ProtoMessage()

func (*QueryPlansRequest) Reset added in v0.6.0 

func (m *QueryPlansRequest) Reset()

func (*QueryPlansRequest) Size added in v0.6.0 

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

func (*QueryPlansRequest) String added in v0.6.0 

func (m *QueryPlansRequest) String() string

func (*QueryPlansRequest) Unmarshal added in v0.6.0 

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

func (*QueryPlansRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *QueryPlansRequest) XXX_DiscardUnknown()

func (*QueryPlansRequest) XXX_Marshal added in v0.6.0 

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

func (*QueryPlansRequest) XXX_Merge added in v0.6.0 

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

func (*QueryPlansRequest) XXX_Size added in v0.6.0 

func (m *QueryPlansRequest) XXX_Size() int

func (*QueryPlansRequest) XXX_Unmarshal added in v0.6.0 

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

type QueryPlansResponse added in v0.6.0 

type QueryPlansResponse struct {
	Plans      []Plan              `protobuf:"bytes,1,rep,name=plans,proto3" json:"plans"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*QueryPlansResponse) Descriptor added in v0.6.0 

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

func (*QueryPlansResponse) Marshal added in v0.6.0 

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

func (*QueryPlansResponse) MarshalTo added in v0.6.0 

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

func (*QueryPlansResponse) MarshalToSizedBuffer added in v0.6.0 

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

func (*QueryPlansResponse) ProtoMessage added in v0.6.0 

func (*QueryPlansResponse) ProtoMessage()

func (*QueryPlansResponse) Reset added in v0.6.0 

func (m *QueryPlansResponse) Reset()

func (*QueryPlansResponse) Size added in v0.6.0 

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

func (*QueryPlansResponse) String added in v0.6.0 

func (m *QueryPlansResponse) String() string

func (*QueryPlansResponse) Unmarshal added in v0.6.0 

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

func (*QueryPlansResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *QueryPlansResponse) XXX_DiscardUnknown()

func (*QueryPlansResponse) XXX_Marshal added in v0.6.0 

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

func (*QueryPlansResponse) XXX_Merge added in v0.6.0 

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

func (*QueryPlansResponse) XXX_Size added in v0.6.0 

func (m *QueryPlansResponse) XXX_Size() int

func (*QueryPlansResponse) XXX_Unmarshal added in v0.6.0 

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

type QueryServiceClient added in v0.6.0 

type QueryServiceClient interface {
	QueryPlans(ctx context.Context, in *QueryPlansRequest, opts ...grpc.CallOption) (*QueryPlansResponse, error)
	QueryPlansForProvider(ctx context.Context, in *QueryPlansForProviderRequest, opts ...grpc.CallOption) (*QueryPlansForProviderResponse, error)
	QueryPlan(ctx context.Context, in *QueryPlanRequest, opts ...grpc.CallOption) (*QueryPlanResponse, error)
	QueryNodesForPlan(ctx context.Context, in *QueryNodesForPlanRequest, opts ...grpc.CallOption) (*QueryNodesForPlanResponse, error)
}

QueryServiceClient is the client API for QueryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueryServiceClient added in v0.6.0 

func NewQueryServiceClient(cc grpc1.ClientConn) QueryServiceClient

type QueryServiceServer added in v0.6.0 

type QueryServiceServer interface {
	QueryPlans(context.Context, *QueryPlansRequest) (*QueryPlansResponse, error)
	QueryPlansForProvider(context.Context, *QueryPlansForProviderRequest) (*QueryPlansForProviderResponse, error)
	QueryPlan(context.Context, *QueryPlanRequest) (*QueryPlanResponse, error)
	QueryNodesForPlan(context.Context, *QueryNodesForPlanRequest) (*QueryNodesForPlanResponse, error)
}

QueryServiceServer is the server API for QueryService service.

type UnimplementedMsgServiceServer added in v0.6.0 

type UnimplementedMsgServiceServer struct {
}

UnimplementedMsgServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServiceServer) MsgAdd added in v0.6.0 

func (*UnimplementedMsgServiceServer) MsgAdd(ctx context.Context, req *MsgAddRequest) (*MsgAddResponse, error)

func (*UnimplementedMsgServiceServer) MsgAddNode added in v0.6.0 

func (*UnimplementedMsgServiceServer) MsgAddNode(ctx context.Context, req *MsgAddNodeRequest) (*MsgAddNodeResponse, error)

func (*UnimplementedMsgServiceServer) MsgRemoveNode added in v0.6.0 

func (*UnimplementedMsgServiceServer) MsgRemoveNode(ctx context.Context, req *MsgRemoveNodeRequest) (*MsgRemoveNodeResponse, error)

func (*UnimplementedMsgServiceServer) MsgSetStatus added in v0.6.0 

func (*UnimplementedMsgServiceServer) MsgSetStatus(ctx context.Context, req *MsgSetStatusRequest) (*MsgSetStatusResponse, error)

type UnimplementedQueryServiceServer added in v0.6.0 

type UnimplementedQueryServiceServer struct {
}

UnimplementedQueryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServiceServer) QueryNodesForPlan added in v0.6.0 

func (*UnimplementedQueryServiceServer) QueryNodesForPlan(ctx context.Context, req *QueryNodesForPlanRequest) (*QueryNodesForPlanResponse, error)

func (*UnimplementedQueryServiceServer) QueryPlan added in v0.6.0 

func (*UnimplementedQueryServiceServer) QueryPlan(ctx context.Context, req *QueryPlanRequest) (*QueryPlanResponse, error)

func (*UnimplementedQueryServiceServer) QueryPlans added in v0.6.0 

func (*UnimplementedQueryServiceServer) QueryPlans(ctx context.Context, req *QueryPlansRequest) (*QueryPlansResponse, error)

func (*UnimplementedQueryServiceServer) QueryPlansForProvider added in v0.6.0 

func (*UnimplementedQueryServiceServer) QueryPlansForProvider(ctx context.Context, req *QueryPlansForProviderRequest) (*QueryPlansForProviderResponse, error)

Source Files

View all Source files

Directories

Path Synopsis
legacy
v0.5
v0.6

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.