v3

package
v12.0.0-rc8 Latest Latest
Warning

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

 Go to latest Published: Dec 19, 2024 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Overview

Package v3 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

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 (
	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 MsgService_serviceDesc = _MsgService_serviceDesc
View Source 
var QueryService_serviceDesc = _QueryService_serviceDesc

Functions

func RegisterInterfaces 

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

func RegisterMsgServiceServer 

func RegisterMsgServiceServer(s grpc1.Server, srv MsgServiceServer)

func RegisterQueryServiceHandler 

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 

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 

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 

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 

func RegisterQueryServiceServer(s grpc1.Server, srv QueryServiceServer)

func ValidateGenesis 

func ValidateGenesis(state *GenesisState) error

Types

type EventCreate 

type EventCreate struct {
	ID          uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	ProvAddress string `protobuf:"bytes,2,opt,name=prov_address,json=provAddress,proto3" json:"prov_address,omitempty"`
	Gigabytes   int64  `protobuf:"varint,3,opt,name=gigabytes,proto3" json:"gigabytes,omitempty"`
	Hours       int64  `protobuf:"varint,4,opt,name=hours,proto3" json:"hours,omitempty"`
	Prices      string `protobuf:"bytes,5,opt,name=prices,proto3" json:"prices,omitempty"`
	Private     bool   `protobuf:"varint,6,opt,name=private,proto3" json:"private,omitempty"`
}

func (*EventCreate) Descriptor 

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

func (*EventCreate) Marshal 

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

func (*EventCreate) MarshalTo 

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

func (*EventCreate) MarshalToSizedBuffer 

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

func (*EventCreate) ProtoMessage 

func (*EventCreate) ProtoMessage()

func (*EventCreate) Reset 

func (m *EventCreate) Reset()

func (*EventCreate) Size 

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

func (*EventCreate) String 

func (m *EventCreate) String() string

func (*EventCreate) Unmarshal 

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

func (*EventCreate) XXX_DiscardUnknown 

func (m *EventCreate) XXX_DiscardUnknown()

func (*EventCreate) XXX_Marshal 

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

func (*EventCreate) XXX_Merge 

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

func (*EventCreate) XXX_Size 

func (m *EventCreate) XXX_Size() int

func (*EventCreate) XXX_Unmarshal 

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

type EventLinkNode 

type EventLinkNode struct {
	ID          uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	ProvAddress string `protobuf:"bytes,2,opt,name=prov_address,json=provAddress,proto3" json:"prov_address,omitempty"`
	NodeAddress string `protobuf:"bytes,3,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
}

func (*EventLinkNode) Descriptor 

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

func (*EventLinkNode) Marshal 

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

func (*EventLinkNode) MarshalTo 

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

func (*EventLinkNode) MarshalToSizedBuffer 

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

func (*EventLinkNode) ProtoMessage 

func (*EventLinkNode) ProtoMessage()

func (*EventLinkNode) Reset 

func (m *EventLinkNode) Reset()

func (*EventLinkNode) Size 

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

func (*EventLinkNode) String 

func (m *EventLinkNode) String() string

func (*EventLinkNode) Unmarshal 

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

func (*EventLinkNode) XXX_DiscardUnknown 

func (m *EventLinkNode) XXX_DiscardUnknown()

func (*EventLinkNode) XXX_Marshal 

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

func (*EventLinkNode) XXX_Merge 

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

func (*EventLinkNode) XXX_Size 

func (m *EventLinkNode) XXX_Size() int

func (*EventLinkNode) XXX_Unmarshal 

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

type EventUnlinkNode 

type EventUnlinkNode struct {
	ID          uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	ProvAddress string `protobuf:"bytes,2,opt,name=prov_address,json=provAddress,proto3" json:"prov_address,omitempty"`
	NodeAddress string `protobuf:"bytes,3,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
}

func (*EventUnlinkNode) Descriptor 

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

func (*EventUnlinkNode) Marshal 

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

func (*EventUnlinkNode) MarshalTo 

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

func (*EventUnlinkNode) MarshalToSizedBuffer 

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

func (*EventUnlinkNode) ProtoMessage 

func (*EventUnlinkNode) ProtoMessage()

func (*EventUnlinkNode) Reset 

func (m *EventUnlinkNode) Reset()

func (*EventUnlinkNode) Size 

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

func (*EventUnlinkNode) String 

func (m *EventUnlinkNode) String() string

func (*EventUnlinkNode) Unmarshal 

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

func (*EventUnlinkNode) XXX_DiscardUnknown 

func (m *EventUnlinkNode) XXX_DiscardUnknown()

func (*EventUnlinkNode) XXX_Marshal 

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

func (*EventUnlinkNode) XXX_Merge 

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

func (*EventUnlinkNode) XXX_Size 

func (m *EventUnlinkNode) XXX_Size() int

func (*EventUnlinkNode) XXX_Unmarshal 

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

type EventUpdate 

type EventUpdate struct {
	ID          uint64    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	ProvAddress string    `protobuf:"bytes,2,opt,name=prov_address,json=provAddress,proto3" json:"prov_address,omitempty"`
	Status      v1.Status `protobuf:"varint,3,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"`
}

func (*EventUpdate) Descriptor 

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

func (*EventUpdate) Marshal 

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

func (*EventUpdate) MarshalTo 

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

func (*EventUpdate) MarshalToSizedBuffer 

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

func (*EventUpdate) ProtoMessage 

func (*EventUpdate) ProtoMessage()

func (*EventUpdate) Reset 

func (m *EventUpdate) Reset()

func (*EventUpdate) Size 

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

func (*EventUpdate) String 

func (m *EventUpdate) String() string

func (*EventUpdate) Unmarshal 

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

func (*EventUpdate) XXX_DiscardUnknown 

func (m *EventUpdate) XXX_DiscardUnknown()

func (*EventUpdate) XXX_Marshal 

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

func (*EventUpdate) XXX_Merge 

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

func (*EventUpdate) XXX_Size 

func (m *EventUpdate) XXX_Size() int

func (*EventUpdate) XXX_Unmarshal 

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

type GenesisPlan 

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

func (*GenesisPlan) Descriptor 

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

func (*GenesisPlan) Marshal 

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

func (*GenesisPlan) MarshalTo 

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

func (*GenesisPlan) MarshalToSizedBuffer 

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

func (*GenesisPlan) ProtoMessage 

func (*GenesisPlan) ProtoMessage()

func (*GenesisPlan) Reset 

func (m *GenesisPlan) Reset()

func (*GenesisPlan) Size 

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

func (*GenesisPlan) String 

func (m *GenesisPlan) String() string

func (*GenesisPlan) Unmarshal 

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

func (*GenesisPlan) XXX_DiscardUnknown 

func (m *GenesisPlan) XXX_DiscardUnknown()

func (*GenesisPlan) XXX_Marshal 

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

func (*GenesisPlan) XXX_Merge 

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

func (*GenesisPlan) XXX_Size 

func (m *GenesisPlan) XXX_Size() int

func (*GenesisPlan) XXX_Unmarshal 

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

type GenesisPlans 

type GenesisPlans []GenesisPlan

type GenesisState 

type GenesisState struct {
	Plans []GenesisPlan `protobuf:"bytes,1,rep,name=plans,proto3" json:"plans" yaml:"plans"`
}

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

func NewGenesisState 

func NewGenesisState(plans GenesisPlans) *GenesisState

func (*GenesisState) Descriptor 

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

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) 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 MsgCreatePlanRequest 

type MsgCreatePlanRequest struct {
	From      string     `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	Gigabytes int64      `protobuf:"varint,2,opt,name=gigabytes,proto3" json:"gigabytes,omitempty"`
	Hours     int64      `protobuf:"varint,3,opt,name=hours,proto3" json:"hours,omitempty"`
	Prices    []v1.Price `protobuf:"bytes,4,rep,name=prices,proto3" json:"prices"`
	Private   bool       `protobuf:"varint,5,opt,name=private,proto3" json:"private,omitempty"`
}

func NewMsgCreatePlanRequest 

func NewMsgCreatePlanRequest(from base.ProvAddress, gigabytes, hours int64, prices v1base.Prices, private bool) *MsgCreatePlanRequest

func (*MsgCreatePlanRequest) Descriptor 

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

func (*MsgCreatePlanRequest) GetPrices 

func (m *MsgCreatePlanRequest) GetPrices() v1base.Prices

func (*MsgCreatePlanRequest) GetSigners 

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

func (*MsgCreatePlanRequest) Marshal 

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

func (*MsgCreatePlanRequest) MarshalTo 

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

func (*MsgCreatePlanRequest) MarshalToSizedBuffer 

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

func (*MsgCreatePlanRequest) ProtoMessage 

func (*MsgCreatePlanRequest) ProtoMessage()

func (*MsgCreatePlanRequest) Reset 

func (m *MsgCreatePlanRequest) Reset()

func (*MsgCreatePlanRequest) Size 

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

func (*MsgCreatePlanRequest) String 

func (m *MsgCreatePlanRequest) String() string

func (*MsgCreatePlanRequest) Unmarshal 

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

func (*MsgCreatePlanRequest) ValidateBasic 

func (m *MsgCreatePlanRequest) ValidateBasic() error

func (*MsgCreatePlanRequest) XXX_DiscardUnknown 

func (m *MsgCreatePlanRequest) XXX_DiscardUnknown()

func (*MsgCreatePlanRequest) XXX_Marshal 

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

func (*MsgCreatePlanRequest) XXX_Merge 

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

func (*MsgCreatePlanRequest) XXX_Size 

func (m *MsgCreatePlanRequest) XXX_Size() int

func (*MsgCreatePlanRequest) XXX_Unmarshal 

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

type MsgCreatePlanResponse 

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

func (*MsgCreatePlanResponse) Descriptor 

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

func (*MsgCreatePlanResponse) Marshal 

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

func (*MsgCreatePlanResponse) MarshalTo 

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

func (*MsgCreatePlanResponse) MarshalToSizedBuffer 

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

func (*MsgCreatePlanResponse) ProtoMessage 

func (*MsgCreatePlanResponse) ProtoMessage()

func (*MsgCreatePlanResponse) Reset 

func (m *MsgCreatePlanResponse) Reset()

func (*MsgCreatePlanResponse) Size 

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

func (*MsgCreatePlanResponse) String 

func (m *MsgCreatePlanResponse) String() string

func (*MsgCreatePlanResponse) Unmarshal 

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

func (*MsgCreatePlanResponse) XXX_DiscardUnknown 

func (m *MsgCreatePlanResponse) XXX_DiscardUnknown()

func (*MsgCreatePlanResponse) XXX_Marshal 

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

func (*MsgCreatePlanResponse) XXX_Merge 

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

func (*MsgCreatePlanResponse) XXX_Size 

func (m *MsgCreatePlanResponse) XXX_Size() int

func (*MsgCreatePlanResponse) XXX_Unmarshal 

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

type MsgLinkNodeRequest 

type MsgLinkNodeRequest 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"`
	NodeAddress string `protobuf:"bytes,3,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
}

func NewMsgLinkNodeRequest 

func NewMsgLinkNodeRequest(from base.ProvAddress, id uint64, addr base.NodeAddress) *MsgLinkNodeRequest

func (*MsgLinkNodeRequest) Descriptor 

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

func (*MsgLinkNodeRequest) GetSigners 

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

func (*MsgLinkNodeRequest) Marshal 

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

func (*MsgLinkNodeRequest) MarshalTo 

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

func (*MsgLinkNodeRequest) MarshalToSizedBuffer 

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

func (*MsgLinkNodeRequest) ProtoMessage 

func (*MsgLinkNodeRequest) ProtoMessage()

func (*MsgLinkNodeRequest) Reset 

func (m *MsgLinkNodeRequest) Reset()

func (*MsgLinkNodeRequest) Size 

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

func (*MsgLinkNodeRequest) String 

func (m *MsgLinkNodeRequest) String() string

func (*MsgLinkNodeRequest) Unmarshal 

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

func (*MsgLinkNodeRequest) ValidateBasic 

func (m *MsgLinkNodeRequest) ValidateBasic() error

func (*MsgLinkNodeRequest) XXX_DiscardUnknown 

func (m *MsgLinkNodeRequest) XXX_DiscardUnknown()

func (*MsgLinkNodeRequest) XXX_Marshal 

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

func (*MsgLinkNodeRequest) XXX_Merge 

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

func (*MsgLinkNodeRequest) XXX_Size 

func (m *MsgLinkNodeRequest) XXX_Size() int

func (*MsgLinkNodeRequest) XXX_Unmarshal 

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

type MsgLinkNodeResponse 

type MsgLinkNodeResponse struct {
}

func (*MsgLinkNodeResponse) Descriptor 

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

func (*MsgLinkNodeResponse) Marshal 

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

func (*MsgLinkNodeResponse) MarshalTo 

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

func (*MsgLinkNodeResponse) MarshalToSizedBuffer 

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

func (*MsgLinkNodeResponse) ProtoMessage 

func (*MsgLinkNodeResponse) ProtoMessage()

func (*MsgLinkNodeResponse) Reset 

func (m *MsgLinkNodeResponse) Reset()

func (*MsgLinkNodeResponse) Size 

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

func (*MsgLinkNodeResponse) String 

func (m *MsgLinkNodeResponse) String() string

func (*MsgLinkNodeResponse) Unmarshal 

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

func (*MsgLinkNodeResponse) XXX_DiscardUnknown 

func (m *MsgLinkNodeResponse) XXX_DiscardUnknown()

func (*MsgLinkNodeResponse) XXX_Marshal 

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

func (*MsgLinkNodeResponse) XXX_Merge 

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

func (*MsgLinkNodeResponse) XXX_Size 

func (m *MsgLinkNodeResponse) XXX_Size() int

func (*MsgLinkNodeResponse) XXX_Unmarshal 

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

type MsgServiceClient 

type MsgServiceClient interface {
	MsgCreatePlan(ctx context.Context, in *MsgCreatePlanRequest, opts ...grpc.CallOption) (*MsgCreatePlanResponse, error)
	MsgLinkNode(ctx context.Context, in *MsgLinkNodeRequest, opts ...grpc.CallOption) (*MsgLinkNodeResponse, error)
	MsgUnlinkNode(ctx context.Context, in *MsgUnlinkNodeRequest, opts ...grpc.CallOption) (*MsgUnlinkNodeResponse, error)
	MsgUpdatePlanStatus(ctx context.Context, in *MsgUpdatePlanStatusRequest, opts ...grpc.CallOption) (*MsgUpdatePlanStatusResponse, error)
	MsgStartSession(ctx context.Context, in *MsgStartSessionRequest, opts ...grpc.CallOption) (*MsgStartSessionResponse, 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 

func NewMsgServiceClient(cc grpc1.ClientConn) MsgServiceClient

type MsgServiceServer 

type MsgServiceServer interface {
	MsgCreatePlan(context.Context, *MsgCreatePlanRequest) (*MsgCreatePlanResponse, error)
	MsgLinkNode(context.Context, *MsgLinkNodeRequest) (*MsgLinkNodeResponse, error)
	MsgUnlinkNode(context.Context, *MsgUnlinkNodeRequest) (*MsgUnlinkNodeResponse, error)
	MsgUpdatePlanStatus(context.Context, *MsgUpdatePlanStatusRequest) (*MsgUpdatePlanStatusResponse, error)
	MsgStartSession(context.Context, *MsgStartSessionRequest) (*MsgStartSessionResponse, error)
}

MsgServiceServer is the server API for MsgService service.

type MsgStartSessionRequest 

type MsgStartSessionRequest 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"`
	Denom              string                `protobuf:"bytes,3,opt,name=denom,proto3" json:"denom,omitempty"`
	RenewalPricePolicy v1.RenewalPricePolicy `` /* 160-byte string literal not displayed */
	NodeAddress        string                `protobuf:"bytes,5,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
}

func NewMsgStartSessionRequest 

func NewMsgStartSessionRequest(from sdk.AccAddress, id uint64, denom string, renewalPricePolicy v1base.RenewalPricePolicy, nodeAddr base.NodeAddress) *MsgStartSessionRequest

func (*MsgStartSessionRequest) Descriptor 

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

func (*MsgStartSessionRequest) GetSigners 

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

func (*MsgStartSessionRequest) Marshal 

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

func (*MsgStartSessionRequest) MarshalTo 

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

func (*MsgStartSessionRequest) MarshalToSizedBuffer 

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

func (*MsgStartSessionRequest) ProtoMessage 

func (*MsgStartSessionRequest) ProtoMessage()

func (*MsgStartSessionRequest) Reset 

func (m *MsgStartSessionRequest) Reset()

func (*MsgStartSessionRequest) Size 

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

func (*MsgStartSessionRequest) String 

func (m *MsgStartSessionRequest) String() string

func (*MsgStartSessionRequest) Unmarshal 

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

func (*MsgStartSessionRequest) ValidateBasic 

func (m *MsgStartSessionRequest) ValidateBasic() error

func (*MsgStartSessionRequest) XXX_DiscardUnknown 

func (m *MsgStartSessionRequest) XXX_DiscardUnknown()

func (*MsgStartSessionRequest) XXX_Marshal 

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

func (*MsgStartSessionRequest) XXX_Merge 

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

func (*MsgStartSessionRequest) XXX_Size 

func (m *MsgStartSessionRequest) XXX_Size() int

func (*MsgStartSessionRequest) XXX_Unmarshal 

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

type MsgStartSessionResponse 

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

func (*MsgStartSessionResponse) Descriptor 

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

func (*MsgStartSessionResponse) Marshal 

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

func (*MsgStartSessionResponse) MarshalTo 

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

func (*MsgStartSessionResponse) MarshalToSizedBuffer 

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

func (*MsgStartSessionResponse) ProtoMessage 

func (*MsgStartSessionResponse) ProtoMessage()

func (*MsgStartSessionResponse) Reset 

func (m *MsgStartSessionResponse) Reset()

func (*MsgStartSessionResponse) Size 

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

func (*MsgStartSessionResponse) String 

func (m *MsgStartSessionResponse) String() string

func (*MsgStartSessionResponse) Unmarshal 

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

func (*MsgStartSessionResponse) XXX_DiscardUnknown 

func (m *MsgStartSessionResponse) XXX_DiscardUnknown()

func (*MsgStartSessionResponse) XXX_Marshal 

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

func (*MsgStartSessionResponse) XXX_Merge 

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

func (*MsgStartSessionResponse) XXX_Size 

func (m *MsgStartSessionResponse) XXX_Size() int

func (*MsgStartSessionResponse) XXX_Unmarshal 

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

type MsgUnlinkNodeRequest 

type MsgUnlinkNodeRequest 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"`
	NodeAddress string `protobuf:"bytes,3,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
}

func NewMsgUnlinkNodeRequest 

func NewMsgUnlinkNodeRequest(from base.ProvAddress, id uint64, addr base.NodeAddress) *MsgUnlinkNodeRequest

func (*MsgUnlinkNodeRequest) Descriptor 

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

func (*MsgUnlinkNodeRequest) GetSigners 

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

func (*MsgUnlinkNodeRequest) Marshal 

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

func (*MsgUnlinkNodeRequest) MarshalTo 

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

func (*MsgUnlinkNodeRequest) MarshalToSizedBuffer 

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

func (*MsgUnlinkNodeRequest) ProtoMessage 

func (*MsgUnlinkNodeRequest) ProtoMessage()

func (*MsgUnlinkNodeRequest) Reset 

func (m *MsgUnlinkNodeRequest) Reset()

func (*MsgUnlinkNodeRequest) Size 

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

func (*MsgUnlinkNodeRequest) String 

func (m *MsgUnlinkNodeRequest) String() string

func (*MsgUnlinkNodeRequest) Unmarshal 

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

func (*MsgUnlinkNodeRequest) ValidateBasic 

func (m *MsgUnlinkNodeRequest) ValidateBasic() error

func (*MsgUnlinkNodeRequest) XXX_DiscardUnknown 

func (m *MsgUnlinkNodeRequest) XXX_DiscardUnknown()

func (*MsgUnlinkNodeRequest) XXX_Marshal 

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

func (*MsgUnlinkNodeRequest) XXX_Merge 

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

func (*MsgUnlinkNodeRequest) XXX_Size 

func (m *MsgUnlinkNodeRequest) XXX_Size() int

func (*MsgUnlinkNodeRequest) XXX_Unmarshal 

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

type MsgUnlinkNodeResponse 

type MsgUnlinkNodeResponse struct {
}

func (*MsgUnlinkNodeResponse) Descriptor 

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

func (*MsgUnlinkNodeResponse) Marshal 

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

func (*MsgUnlinkNodeResponse) MarshalTo 

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

func (*MsgUnlinkNodeResponse) MarshalToSizedBuffer 

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

func (*MsgUnlinkNodeResponse) ProtoMessage 

func (*MsgUnlinkNodeResponse) ProtoMessage()

func (*MsgUnlinkNodeResponse) Reset 

func (m *MsgUnlinkNodeResponse) Reset()

func (*MsgUnlinkNodeResponse) Size 

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

func (*MsgUnlinkNodeResponse) String 

func (m *MsgUnlinkNodeResponse) String() string

func (*MsgUnlinkNodeResponse) Unmarshal 

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

func (*MsgUnlinkNodeResponse) XXX_DiscardUnknown 

func (m *MsgUnlinkNodeResponse) XXX_DiscardUnknown()

func (*MsgUnlinkNodeResponse) XXX_Marshal 

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

func (*MsgUnlinkNodeResponse) XXX_Merge 

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

func (*MsgUnlinkNodeResponse) XXX_Size 

func (m *MsgUnlinkNodeResponse) XXX_Size() int

func (*MsgUnlinkNodeResponse) XXX_Unmarshal 

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

type MsgUpdatePlanStatusRequest 

type MsgUpdatePlanStatusRequest 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 v1.Status `protobuf:"varint,3,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"`
}

func NewMsgUpdatePlanStatusRequest 

func NewMsgUpdatePlanStatusRequest(from base.ProvAddress, id uint64, status v1base.Status) *MsgUpdatePlanStatusRequest

func (*MsgUpdatePlanStatusRequest) Descriptor 

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

func (*MsgUpdatePlanStatusRequest) GetSigners 

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

func (*MsgUpdatePlanStatusRequest) Marshal 

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

func (*MsgUpdatePlanStatusRequest) MarshalTo 

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

func (*MsgUpdatePlanStatusRequest) MarshalToSizedBuffer 

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

func (*MsgUpdatePlanStatusRequest) ProtoMessage 

func (*MsgUpdatePlanStatusRequest) ProtoMessage()

func (*MsgUpdatePlanStatusRequest) Reset 

func (m *MsgUpdatePlanStatusRequest) Reset()

func (*MsgUpdatePlanStatusRequest) Size 

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

func (*MsgUpdatePlanStatusRequest) String 

func (m *MsgUpdatePlanStatusRequest) String() string

func (*MsgUpdatePlanStatusRequest) Unmarshal 

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

func (*MsgUpdatePlanStatusRequest) ValidateBasic 

func (m *MsgUpdatePlanStatusRequest) ValidateBasic() error

func (*MsgUpdatePlanStatusRequest) XXX_DiscardUnknown 

func (m *MsgUpdatePlanStatusRequest) XXX_DiscardUnknown()

func (*MsgUpdatePlanStatusRequest) XXX_Marshal 

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

func (*MsgUpdatePlanStatusRequest) XXX_Merge 

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

func (*MsgUpdatePlanStatusRequest) XXX_Size 

func (m *MsgUpdatePlanStatusRequest) XXX_Size() int

func (*MsgUpdatePlanStatusRequest) XXX_Unmarshal 

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

type MsgUpdatePlanStatusResponse 

type MsgUpdatePlanStatusResponse struct {
}

func (*MsgUpdatePlanStatusResponse) Descriptor 

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

func (*MsgUpdatePlanStatusResponse) Marshal 

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

func (*MsgUpdatePlanStatusResponse) MarshalTo 

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

func (*MsgUpdatePlanStatusResponse) MarshalToSizedBuffer 

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

func (*MsgUpdatePlanStatusResponse) ProtoMessage 

func (*MsgUpdatePlanStatusResponse) ProtoMessage()

func (*MsgUpdatePlanStatusResponse) Reset 

func (m *MsgUpdatePlanStatusResponse) Reset()

func (*MsgUpdatePlanStatusResponse) Size 

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

func (*MsgUpdatePlanStatusResponse) String 

func (m *MsgUpdatePlanStatusResponse) String() string

func (*MsgUpdatePlanStatusResponse) Unmarshal 

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

func (*MsgUpdatePlanStatusResponse) XXX_DiscardUnknown 

func (m *MsgUpdatePlanStatusResponse) XXX_DiscardUnknown()

func (*MsgUpdatePlanStatusResponse) XXX_Marshal 

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

func (*MsgUpdatePlanStatusResponse) XXX_Merge 

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

func (*MsgUpdatePlanStatusResponse) XXX_Size 

func (m *MsgUpdatePlanStatusResponse) XXX_Size() int

func (*MsgUpdatePlanStatusResponse) XXX_Unmarshal 

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

type Plan 

type Plan struct {
	ID          uint64     `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	ProvAddress string     `protobuf:"bytes,2,opt,name=prov_address,json=provAddress,proto3" json:"prov_address,omitempty"`
	Gigabytes   int64      `protobuf:"varint,3,opt,name=gigabytes,proto3" json:"gigabytes,omitempty"`
	Hours       int64      `protobuf:"varint,4,opt,name=hours,proto3" json:"hours,omitempty"`
	Prices      []v1.Price `protobuf:"bytes,5,rep,name=prices,proto3" json:"prices"`
	Private     bool       `protobuf:"varint,6,opt,name=private,proto3" json:"private,omitempty"`
	Status      v1.Status  `protobuf:"varint,7,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"`
	StatusAt    time.Time  `protobuf:"bytes,8,opt,name=status_at,json=statusAt,proto3,stdtime" json:"status_at"`
}

func (*Plan) Descriptor 

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

func (*Plan) GetBytes 

func (m *Plan) GetBytes() sdkmath.Int

func (*Plan) GetDuration 

func (m *Plan) GetDuration() time.Duration

func (*Plan) GetPrices 

func (m *Plan) GetPrices() v1base.Prices

func (*Plan) Marshal 

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

func (*Plan) MarshalTo 

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

func (*Plan) MarshalToSizedBuffer 

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

func (*Plan) Price 

func (m *Plan) Price(denom string) (v1base.Price, bool)

func (*Plan) ProtoMessage 

func (*Plan) ProtoMessage()

func (*Plan) Reset 

func (m *Plan) Reset()

func (*Plan) Size 

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

func (*Plan) String 

func (m *Plan) String() string

func (*Plan) Unmarshal 

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

func (*Plan) Validate 

func (m *Plan) Validate() error

func (*Plan) XXX_DiscardUnknown 

func (m *Plan) XXX_DiscardUnknown()

func (*Plan) XXX_Marshal 

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

func (*Plan) XXX_Merge 

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

func (*Plan) XXX_Size 

func (m *Plan) XXX_Size() int

func (*Plan) XXX_Unmarshal 

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

type QueryPlanRequest 

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

func NewQueryPlanRequest 

func NewQueryPlanRequest(id uint64) *QueryPlanRequest

func (*QueryPlanRequest) Descriptor 

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

func (*QueryPlanRequest) Marshal 

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

func (*QueryPlanRequest) MarshalTo 

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

func (*QueryPlanRequest) MarshalToSizedBuffer 

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

func (*QueryPlanRequest) ProtoMessage 

func (*QueryPlanRequest) ProtoMessage()

func (*QueryPlanRequest) Reset 

func (m *QueryPlanRequest) Reset()

func (*QueryPlanRequest) Size 

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

func (*QueryPlanRequest) String 

func (m *QueryPlanRequest) String() string

func (*QueryPlanRequest) Unmarshal 

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

func (*QueryPlanRequest) XXX_DiscardUnknown 

func (m *QueryPlanRequest) XXX_DiscardUnknown()

func (*QueryPlanRequest) XXX_Marshal 

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

func (*QueryPlanRequest) XXX_Merge 

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

func (*QueryPlanRequest) XXX_Size 

func (m *QueryPlanRequest) XXX_Size() int

func (*QueryPlanRequest) XXX_Unmarshal 

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

type QueryPlanResponse 

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

func (*QueryPlanResponse) Descriptor 

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

func (*QueryPlanResponse) Marshal 

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

func (*QueryPlanResponse) MarshalTo 

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

func (*QueryPlanResponse) MarshalToSizedBuffer 

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

func (*QueryPlanResponse) ProtoMessage 

func (*QueryPlanResponse) ProtoMessage()

func (*QueryPlanResponse) Reset 

func (m *QueryPlanResponse) Reset()

func (*QueryPlanResponse) Size 

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

func (*QueryPlanResponse) String 

func (m *QueryPlanResponse) String() string

func (*QueryPlanResponse) Unmarshal 

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

func (*QueryPlanResponse) XXX_DiscardUnknown 

func (m *QueryPlanResponse) XXX_DiscardUnknown()

func (*QueryPlanResponse) XXX_Marshal 

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

func (*QueryPlanResponse) XXX_Merge 

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

func (*QueryPlanResponse) XXX_Size 

func (m *QueryPlanResponse) XXX_Size() int

func (*QueryPlanResponse) XXX_Unmarshal 

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

type QueryPlansForProviderRequest 

type QueryPlansForProviderRequest struct {
	Address    string             `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Status     v1.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 

func NewQueryPlansForProviderRequest(addr base.ProvAddress, status v1base.Status, pagination *sdkquery.PageRequest) *QueryPlansForProviderRequest

func (*QueryPlansForProviderRequest) Descriptor 

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

func (*QueryPlansForProviderRequest) Marshal 

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

func (*QueryPlansForProviderRequest) MarshalTo 

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

func (*QueryPlansForProviderRequest) MarshalToSizedBuffer 

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

func (*QueryPlansForProviderRequest) ProtoMessage 

func (*QueryPlansForProviderRequest) ProtoMessage()

func (*QueryPlansForProviderRequest) Reset 

func (m *QueryPlansForProviderRequest) Reset()

func (*QueryPlansForProviderRequest) Size 

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

func (*QueryPlansForProviderRequest) String 

func (m *QueryPlansForProviderRequest) String() string

func (*QueryPlansForProviderRequest) Unmarshal 

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

func (*QueryPlansForProviderRequest) XXX_DiscardUnknown 

func (m *QueryPlansForProviderRequest) XXX_DiscardUnknown()

func (*QueryPlansForProviderRequest) XXX_Marshal 

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

func (*QueryPlansForProviderRequest) XXX_Merge 

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

func (*QueryPlansForProviderRequest) XXX_Size 

func (m *QueryPlansForProviderRequest) XXX_Size() int

func (*QueryPlansForProviderRequest) XXX_Unmarshal 

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

type QueryPlansForProviderResponse 

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 

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

func (*QueryPlansForProviderResponse) Marshal 

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

func (*QueryPlansForProviderResponse) MarshalTo 

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

func (*QueryPlansForProviderResponse) MarshalToSizedBuffer 

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

func (*QueryPlansForProviderResponse) ProtoMessage 

func (*QueryPlansForProviderResponse) ProtoMessage()

func (*QueryPlansForProviderResponse) Reset 

func (m *QueryPlansForProviderResponse) Reset()

func (*QueryPlansForProviderResponse) Size 

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

func (*QueryPlansForProviderResponse) String 

func (m *QueryPlansForProviderResponse) String() string

func (*QueryPlansForProviderResponse) Unmarshal 

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

func (*QueryPlansForProviderResponse) XXX_DiscardUnknown 

func (m *QueryPlansForProviderResponse) XXX_DiscardUnknown()

func (*QueryPlansForProviderResponse) XXX_Marshal 

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

func (*QueryPlansForProviderResponse) XXX_Merge 

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

func (*QueryPlansForProviderResponse) XXX_Size 

func (m *QueryPlansForProviderResponse) XXX_Size() int

func (*QueryPlansForProviderResponse) XXX_Unmarshal 

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

type QueryPlansRequest 

type QueryPlansRequest struct {
	Status     v1.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 

func NewQueryPlansRequest(status v1base.Status, pagination *sdkquery.PageRequest) *QueryPlansRequest

func (*QueryPlansRequest) Descriptor 

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

func (*QueryPlansRequest) Marshal 

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

func (*QueryPlansRequest) MarshalTo 

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

func (*QueryPlansRequest) MarshalToSizedBuffer 

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

func (*QueryPlansRequest) ProtoMessage 

func (*QueryPlansRequest) ProtoMessage()

func (*QueryPlansRequest) Reset 

func (m *QueryPlansRequest) Reset()

func (*QueryPlansRequest) Size 

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

func (*QueryPlansRequest) String 

func (m *QueryPlansRequest) String() string

func (*QueryPlansRequest) Unmarshal 

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

func (*QueryPlansRequest) XXX_DiscardUnknown 

func (m *QueryPlansRequest) XXX_DiscardUnknown()

func (*QueryPlansRequest) XXX_Marshal 

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

func (*QueryPlansRequest) XXX_Merge 

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

func (*QueryPlansRequest) XXX_Size 

func (m *QueryPlansRequest) XXX_Size() int

func (*QueryPlansRequest) XXX_Unmarshal 

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

type QueryPlansResponse 

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 

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

func (*QueryPlansResponse) Marshal 

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

func (*QueryPlansResponse) MarshalTo 

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

func (*QueryPlansResponse) MarshalToSizedBuffer 

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

func (*QueryPlansResponse) ProtoMessage 

func (*QueryPlansResponse) ProtoMessage()

func (*QueryPlansResponse) Reset 

func (m *QueryPlansResponse) Reset()

func (*QueryPlansResponse) Size 

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

func (*QueryPlansResponse) String 

func (m *QueryPlansResponse) String() string

func (*QueryPlansResponse) Unmarshal 

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

func (*QueryPlansResponse) XXX_DiscardUnknown 

func (m *QueryPlansResponse) XXX_DiscardUnknown()

func (*QueryPlansResponse) XXX_Marshal 

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

func (*QueryPlansResponse) XXX_Merge 

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

func (*QueryPlansResponse) XXX_Size 

func (m *QueryPlansResponse) XXX_Size() int

func (*QueryPlansResponse) XXX_Unmarshal 

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

type QueryServiceClient 

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)
}

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 

func NewQueryServiceClient(cc grpc1.ClientConn) QueryServiceClient

type QueryServiceServer 

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

QueryServiceServer is the server API for QueryService service.

type UnimplementedMsgServiceServer 

type UnimplementedMsgServiceServer struct {
}

UnimplementedMsgServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServiceServer) MsgCreatePlan 

func (*UnimplementedMsgServiceServer) MsgCreatePlan(ctx context.Context, req *MsgCreatePlanRequest) (*MsgCreatePlanResponse, error)

func (*UnimplementedMsgServiceServer) MsgLinkNode 

func (*UnimplementedMsgServiceServer) MsgLinkNode(ctx context.Context, req *MsgLinkNodeRequest) (*MsgLinkNodeResponse, error)

func (*UnimplementedMsgServiceServer) MsgStartSession 

func (*UnimplementedMsgServiceServer) MsgStartSession(ctx context.Context, req *MsgStartSessionRequest) (*MsgStartSessionResponse, error)

func (*UnimplementedMsgServiceServer) MsgUnlinkNode 

func (*UnimplementedMsgServiceServer) MsgUnlinkNode(ctx context.Context, req *MsgUnlinkNodeRequest) (*MsgUnlinkNodeResponse, error)

func (*UnimplementedMsgServiceServer) MsgUpdatePlanStatus 

func (*UnimplementedMsgServiceServer) MsgUpdatePlanStatus(ctx context.Context, req *MsgUpdatePlanStatusRequest) (*MsgUpdatePlanStatusResponse, error)

type UnimplementedQueryServiceServer 

type UnimplementedQueryServiceServer struct {
}

UnimplementedQueryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServiceServer) QueryPlan 

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

func (*UnimplementedQueryServiceServer) QueryPlans 

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

func (*UnimplementedQueryServiceServer) QueryPlansForProvider 

func (*UnimplementedQueryServiceServer) QueryPlansForProvider(ctx context.Context, req *QueryPlansForProviderRequest) (*QueryPlansForProviderResponse, 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.