Documentation ¶
Overview ¶
Package types is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func DeploymentIDEVAttributes(id DeploymentID) []sdk.Attribute
- func GroupIDEVAttributes(id GroupID) []sdk.Attribute
- func ParseEVDeploymentVersion(attrs []sdk.Attribute) ([]byte, error)
- func ParseEvent(ev sdkutil.Event) (sdkutil.ModuleEvent, error)
- func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
- func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)
- func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
- func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
- func RegisterQueryServer(s grpc1.Server, srv QueryServer)
- type Deployment
- func (*Deployment) Descriptor() ([]byte, []int)
- func (m *Deployment) GetDeploymentID() DeploymentID
- func (m *Deployment) GetState() Deployment_State
- func (m *Deployment) GetVersion() []byte
- func (obj Deployment) ID() DeploymentID
- func (m *Deployment) Marshal() (dAtA []byte, err error)
- func (m *Deployment) MarshalTo(dAtA []byte) (int, error)
- func (m *Deployment) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Deployment) ProtoMessage()
- func (m *Deployment) Reset()
- func (m *Deployment) Size() (n int)
- func (m *Deployment) String() string
- func (m *Deployment) Unmarshal(dAtA []byte) error
- func (m *Deployment) XXX_DiscardUnknown()
- func (m *Deployment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Deployment) XXX_Merge(src proto.Message)
- func (m *Deployment) XXX_Size() int
- func (m *Deployment) XXX_Unmarshal(b []byte) error
- type DeploymentFilters
- func (filters DeploymentFilters) Accept(obj Deployment, stateVal Deployment_State) bool
- func (*DeploymentFilters) Descriptor() ([]byte, []int)
- func (m *DeploymentFilters) GetDSeq() uint64
- func (m *DeploymentFilters) GetOwner() string
- func (m *DeploymentFilters) GetState() string
- func (m *DeploymentFilters) Marshal() (dAtA []byte, err error)
- func (m *DeploymentFilters) MarshalTo(dAtA []byte) (int, error)
- func (m *DeploymentFilters) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DeploymentFilters) ProtoMessage()
- func (m *DeploymentFilters) Reset()
- func (m *DeploymentFilters) Size() (n int)
- func (m *DeploymentFilters) String() string
- func (m *DeploymentFilters) Unmarshal(dAtA []byte) error
- func (m *DeploymentFilters) XXX_DiscardUnknown()
- func (m *DeploymentFilters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeploymentFilters) XXX_Merge(src proto.Message)
- func (m *DeploymentFilters) XXX_Size() int
- func (m *DeploymentFilters) XXX_Unmarshal(b []byte) error
- type DeploymentID
- func (*DeploymentID) Descriptor() ([]byte, []int)
- func (id DeploymentID) Equals(other DeploymentID) bool
- func (m *DeploymentID) GetDSeq() uint64
- func (m *DeploymentID) GetOwner() string
- func (m *DeploymentID) Marshal() (dAtA []byte, err error)
- func (m *DeploymentID) MarshalTo(dAtA []byte) (int, error)
- func (m *DeploymentID) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DeploymentID) ProtoMessage()
- func (m *DeploymentID) Reset()
- func (m *DeploymentID) Size() (n int)
- func (id DeploymentID) String() string
- func (m *DeploymentID) Unmarshal(dAtA []byte) error
- func (id DeploymentID) Validate() error
- func (m *DeploymentID) XXX_DiscardUnknown()
- func (m *DeploymentID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeploymentID) XXX_Merge(src proto.Message)
- func (m *DeploymentID) XXX_Size() int
- func (m *DeploymentID) XXX_Unmarshal(b []byte) error
- type DeploymentResponse
- func (*DeploymentResponse) Descriptor() ([]byte, []int)
- func (m *DeploymentResponse) GetDeployment() Deployment
- func (m *DeploymentResponse) GetGroups() []Group
- func (m *DeploymentResponse) GetVersion() []byte
- func (m *DeploymentResponse) Marshal() (dAtA []byte, err error)
- func (m *DeploymentResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *DeploymentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DeploymentResponse) ProtoMessage()
- func (m *DeploymentResponse) Reset()
- func (m *DeploymentResponse) Size() (n int)
- func (d DeploymentResponse) String() string
- func (m *DeploymentResponse) Unmarshal(dAtA []byte) error
- func (m *DeploymentResponse) XXX_DiscardUnknown()
- func (m *DeploymentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeploymentResponse) XXX_Merge(src proto.Message)
- func (m *DeploymentResponse) XXX_Size() int
- func (m *DeploymentResponse) XXX_Unmarshal(b []byte) error
- type DeploymentResponses
- type Deployment_State
- type EventDeploymentClosed
- type EventDeploymentCreated
- type EventDeploymentUpdated
- type EventGroupClosed
- type GenesisDeployment
- func (*GenesisDeployment) Descriptor() ([]byte, []int)
- func (m *GenesisDeployment) GetDeployment() Deployment
- func (m *GenesisDeployment) GetGroups() []Group
- func (m *GenesisDeployment) Marshal() (dAtA []byte, err error)
- func (m *GenesisDeployment) MarshalTo(dAtA []byte) (int, error)
- func (m *GenesisDeployment) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GenesisDeployment) ProtoMessage()
- func (m *GenesisDeployment) Reset()
- func (m *GenesisDeployment) Size() (n int)
- func (m *GenesisDeployment) String() string
- func (m *GenesisDeployment) Unmarshal(dAtA []byte) error
- func (m *GenesisDeployment) XXX_DiscardUnknown()
- func (m *GenesisDeployment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GenesisDeployment) XXX_Merge(src proto.Message)
- func (m *GenesisDeployment) XXX_Size() int
- func (m *GenesisDeployment) XXX_Unmarshal(b []byte) error
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)
- func (m *GenesisState) GetDeployments() []GenesisDeployment
- func (m *GenesisState) Marshal() (dAtA []byte, err error)
- func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)
- func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GenesisState) ProtoMessage()
- func (m *GenesisState) Reset()
- func (m *GenesisState) Size() (n int)
- func (m *GenesisState) String() string
- func (m *GenesisState) Unmarshal(dAtA []byte) error
- func (m *GenesisState) XXX_DiscardUnknown()
- func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GenesisState) XXX_Merge(src proto.Message)
- func (m *GenesisState) XXX_Size() int
- func (m *GenesisState) XXX_Unmarshal(b []byte) error
- type Group
- func (*Group) Descriptor() ([]byte, []int)
- func (m *Group) GetGroupID() GroupID
- func (m *Group) GetGroupSpec() GroupSpec
- func (g Group) GetName() string
- func (g Group) GetResources() []types.Resources
- func (m *Group) GetState() Group_State
- func (g Group) ID() GroupID
- func (m *Group) Marshal() (dAtA []byte, err error)
- func (m *Group) MarshalTo(dAtA []byte) (int, error)
- func (m *Group) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Group) ProtoMessage()
- func (m *Group) Reset()
- func (m *Group) Size() (n int)
- func (m *Group) String() string
- func (m *Group) Unmarshal(dAtA []byte) error
- func (g Group) ValidateClosable() error
- func (g Group) ValidateOrderable() error
- func (m *Group) XXX_DiscardUnknown()
- func (m *Group) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Group) XXX_Merge(src proto.Message)
- func (m *Group) XXX_Size() int
- func (m *Group) XXX_Unmarshal(b []byte) error
- type GroupID
- func (id GroupID) DeploymentID() DeploymentID
- func (*GroupID) Descriptor() ([]byte, []int)
- func (id GroupID) Equals(other GroupID) bool
- func (m *GroupID) GetDSeq() uint64
- func (m *GroupID) GetGSeq() uint32
- func (m *GroupID) GetOwner() string
- func (m *GroupID) Marshal() (dAtA []byte, err error)
- func (m *GroupID) MarshalTo(dAtA []byte) (int, error)
- func (m *GroupID) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GroupID) ProtoMessage()
- func (m *GroupID) Reset()
- func (m *GroupID) Size() (n int)
- func (id GroupID) String() string
- func (m *GroupID) Unmarshal(dAtA []byte) error
- func (id GroupID) Validate() error
- func (m *GroupID) XXX_DiscardUnknown()
- func (m *GroupID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GroupID) XXX_Merge(src proto.Message)
- func (m *GroupID) XXX_Size() int
- func (m *GroupID) XXX_Unmarshal(b []byte) error
- type GroupSpec
- func (*GroupSpec) Descriptor() ([]byte, []int)
- func (g GroupSpec) GetName() string
- func (g GroupSpec) GetResources() []types.Resources
- func (m *GroupSpec) Marshal() (dAtA []byte, err error)
- func (m *GroupSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *GroupSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (g GroupSpec) MatchAttributes(attrs []types.Attribute) bool
- func (g GroupSpec) Price() sdk.Coin
- func (*GroupSpec) ProtoMessage()
- func (m *GroupSpec) Reset()
- func (m *GroupSpec) Size() (n int)
- func (m *GroupSpec) String() string
- func (m *GroupSpec) Unmarshal(dAtA []byte) error
- func (g GroupSpec) ValidateBasic() error
- func (m *GroupSpec) XXX_DiscardUnknown()
- func (m *GroupSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GroupSpec) XXX_Merge(src proto.Message)
- func (m *GroupSpec) XXX_Size() int
- func (m *GroupSpec) XXX_Unmarshal(b []byte) error
- type Group_State
- type MsgCloseDeployment
- func (*MsgCloseDeployment) Descriptor() ([]byte, []int)
- func (m *MsgCloseDeployment) GetID() DeploymentID
- func (msg MsgCloseDeployment) GetSignBytes() []byte
- func (msg MsgCloseDeployment) GetSigners() []sdk.AccAddress
- func (m *MsgCloseDeployment) Marshal() (dAtA []byte, err error)
- func (m *MsgCloseDeployment) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgCloseDeployment) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgCloseDeployment) ProtoMessage()
- func (m *MsgCloseDeployment) Reset()
- func (msg MsgCloseDeployment) Route() string
- func (m *MsgCloseDeployment) Size() (n int)
- func (m *MsgCloseDeployment) String() string
- func (msg MsgCloseDeployment) Type() string
- func (m *MsgCloseDeployment) Unmarshal(dAtA []byte) error
- func (msg MsgCloseDeployment) ValidateBasic() error
- func (m *MsgCloseDeployment) XXX_DiscardUnknown()
- func (m *MsgCloseDeployment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgCloseDeployment) XXX_Merge(src proto.Message)
- func (m *MsgCloseDeployment) XXX_Size() int
- func (m *MsgCloseDeployment) XXX_Unmarshal(b []byte) error
- type MsgCloseGroup
- func (*MsgCloseGroup) Descriptor() ([]byte, []int)
- func (m *MsgCloseGroup) GetID() GroupID
- func (msg MsgCloseGroup) GetSignBytes() []byte
- func (msg MsgCloseGroup) GetSigners() []sdk.AccAddress
- func (m *MsgCloseGroup) Marshal() (dAtA []byte, err error)
- func (m *MsgCloseGroup) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgCloseGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgCloseGroup) ProtoMessage()
- func (m *MsgCloseGroup) Reset()
- func (msg MsgCloseGroup) Route() string
- func (m *MsgCloseGroup) Size() (n int)
- func (m *MsgCloseGroup) String() string
- func (msg MsgCloseGroup) Type() string
- func (m *MsgCloseGroup) Unmarshal(dAtA []byte) error
- func (msg MsgCloseGroup) ValidateBasic() error
- func (m *MsgCloseGroup) XXX_DiscardUnknown()
- func (m *MsgCloseGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgCloseGroup) XXX_Merge(src proto.Message)
- func (m *MsgCloseGroup) XXX_Size() int
- func (m *MsgCloseGroup) XXX_Unmarshal(b []byte) error
- type MsgCreateDeployment
- func (*MsgCreateDeployment) Descriptor() ([]byte, []int)
- func (m *MsgCreateDeployment) GetGroups() []GroupSpec
- func (m *MsgCreateDeployment) GetID() DeploymentID
- func (msg MsgCreateDeployment) GetSignBytes() []byte
- func (msg MsgCreateDeployment) GetSigners() []sdk.AccAddress
- func (m *MsgCreateDeployment) GetVersion() []byte
- func (m *MsgCreateDeployment) Marshal() (dAtA []byte, err error)
- func (m *MsgCreateDeployment) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgCreateDeployment) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgCreateDeployment) ProtoMessage()
- func (m *MsgCreateDeployment) Reset()
- func (msg MsgCreateDeployment) Route() string
- func (m *MsgCreateDeployment) Size() (n int)
- func (m *MsgCreateDeployment) String() string
- func (msg MsgCreateDeployment) Type() string
- func (m *MsgCreateDeployment) Unmarshal(dAtA []byte) error
- func (msg MsgCreateDeployment) ValidateBasic() error
- func (m *MsgCreateDeployment) XXX_DiscardUnknown()
- func (m *MsgCreateDeployment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgCreateDeployment) XXX_Merge(src proto.Message)
- func (m *MsgCreateDeployment) XXX_Size() int
- func (m *MsgCreateDeployment) XXX_Unmarshal(b []byte) error
- type MsgUpdateDeployment
- func (*MsgUpdateDeployment) Descriptor() ([]byte, []int)
- func (m *MsgUpdateDeployment) GetGroups() []GroupSpec
- func (m *MsgUpdateDeployment) GetID() DeploymentID
- func (msg MsgUpdateDeployment) GetSignBytes() []byte
- func (msg MsgUpdateDeployment) GetSigners() []sdk.AccAddress
- func (m *MsgUpdateDeployment) GetVersion() []byte
- func (m *MsgUpdateDeployment) Marshal() (dAtA []byte, err error)
- func (m *MsgUpdateDeployment) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgUpdateDeployment) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgUpdateDeployment) ProtoMessage()
- func (m *MsgUpdateDeployment) Reset()
- func (msg MsgUpdateDeployment) Route() string
- func (m *MsgUpdateDeployment) Size() (n int)
- func (m *MsgUpdateDeployment) String() string
- func (msg MsgUpdateDeployment) Type() string
- func (m *MsgUpdateDeployment) Unmarshal(dAtA []byte) error
- func (msg MsgUpdateDeployment) ValidateBasic() error
- func (m *MsgUpdateDeployment) XXX_DiscardUnknown()
- func (m *MsgUpdateDeployment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgUpdateDeployment) XXX_Merge(src proto.Message)
- func (m *MsgUpdateDeployment) XXX_Size() int
- func (m *MsgUpdateDeployment) XXX_Unmarshal(b []byte) error
- type QueryClient
- type QueryDeploymentRequest
- func (*QueryDeploymentRequest) Descriptor() ([]byte, []int)
- func (m *QueryDeploymentRequest) GetID() DeploymentID
- func (m *QueryDeploymentRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryDeploymentRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryDeploymentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryDeploymentRequest) ProtoMessage()
- func (m *QueryDeploymentRequest) Reset()
- func (m *QueryDeploymentRequest) Size() (n int)
- func (m *QueryDeploymentRequest) String() string
- func (m *QueryDeploymentRequest) Unmarshal(dAtA []byte) error
- func (m *QueryDeploymentRequest) XXX_DiscardUnknown()
- func (m *QueryDeploymentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryDeploymentRequest) XXX_Merge(src proto.Message)
- func (m *QueryDeploymentRequest) XXX_Size() int
- func (m *QueryDeploymentRequest) XXX_Unmarshal(b []byte) error
- type QueryDeploymentResponse
- func (*QueryDeploymentResponse) Descriptor() ([]byte, []int)
- func (m *QueryDeploymentResponse) GetDeployment() DeploymentResponse
- func (m *QueryDeploymentResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryDeploymentResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryDeploymentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryDeploymentResponse) ProtoMessage()
- func (m *QueryDeploymentResponse) Reset()
- func (m *QueryDeploymentResponse) Size() (n int)
- func (m *QueryDeploymentResponse) String() string
- func (m *QueryDeploymentResponse) Unmarshal(dAtA []byte) error
- func (m *QueryDeploymentResponse) XXX_DiscardUnknown()
- func (m *QueryDeploymentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryDeploymentResponse) XXX_Merge(src proto.Message)
- func (m *QueryDeploymentResponse) XXX_Size() int
- func (m *QueryDeploymentResponse) XXX_Unmarshal(b []byte) error
- type QueryDeploymentsRequest
- func (*QueryDeploymentsRequest) Descriptor() ([]byte, []int)
- func (m *QueryDeploymentsRequest) GetFilters() DeploymentFilters
- func (m *QueryDeploymentsRequest) GetPagination() *query.PageRequest
- func (m *QueryDeploymentsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryDeploymentsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryDeploymentsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryDeploymentsRequest) ProtoMessage()
- func (m *QueryDeploymentsRequest) Reset()
- func (m *QueryDeploymentsRequest) Size() (n int)
- func (m *QueryDeploymentsRequest) String() string
- func (m *QueryDeploymentsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryDeploymentsRequest) XXX_DiscardUnknown()
- func (m *QueryDeploymentsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryDeploymentsRequest) XXX_Merge(src proto.Message)
- func (m *QueryDeploymentsRequest) XXX_Size() int
- func (m *QueryDeploymentsRequest) XXX_Unmarshal(b []byte) error
- type QueryDeploymentsResponse
- func (*QueryDeploymentsResponse) Descriptor() ([]byte, []int)
- func (m *QueryDeploymentsResponse) GetDeployments() DeploymentResponses
- func (m *QueryDeploymentsResponse) GetPagination() *query.PageResponse
- func (m *QueryDeploymentsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryDeploymentsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryDeploymentsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryDeploymentsResponse) ProtoMessage()
- func (m *QueryDeploymentsResponse) Reset()
- func (m *QueryDeploymentsResponse) Size() (n int)
- func (m *QueryDeploymentsResponse) String() string
- func (m *QueryDeploymentsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryDeploymentsResponse) XXX_DiscardUnknown()
- func (m *QueryDeploymentsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryDeploymentsResponse) XXX_Merge(src proto.Message)
- func (m *QueryDeploymentsResponse) XXX_Size() int
- func (m *QueryDeploymentsResponse) XXX_Unmarshal(b []byte) error
- type QueryGroupRequest
- func (*QueryGroupRequest) Descriptor() ([]byte, []int)
- func (m *QueryGroupRequest) GetID() GroupID
- func (m *QueryGroupRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryGroupRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryGroupRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryGroupRequest) ProtoMessage()
- func (m *QueryGroupRequest) Reset()
- func (m *QueryGroupRequest) Size() (n int)
- func (m *QueryGroupRequest) String() string
- func (m *QueryGroupRequest) Unmarshal(dAtA []byte) error
- func (m *QueryGroupRequest) XXX_DiscardUnknown()
- func (m *QueryGroupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryGroupRequest) XXX_Merge(src proto.Message)
- func (m *QueryGroupRequest) XXX_Size() int
- func (m *QueryGroupRequest) XXX_Unmarshal(b []byte) error
- type QueryGroupResponse
- func (*QueryGroupResponse) Descriptor() ([]byte, []int)
- func (m *QueryGroupResponse) GetGroup() Group
- func (m *QueryGroupResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryGroupResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryGroupResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryGroupResponse) ProtoMessage()
- func (m *QueryGroupResponse) Reset()
- func (m *QueryGroupResponse) Size() (n int)
- func (m *QueryGroupResponse) String() string
- func (m *QueryGroupResponse) Unmarshal(dAtA []byte) error
- func (m *QueryGroupResponse) XXX_DiscardUnknown()
- func (m *QueryGroupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryGroupResponse) XXX_Merge(src proto.Message)
- func (m *QueryGroupResponse) XXX_Size() int
- func (m *QueryGroupResponse) XXX_Unmarshal(b []byte) error
- type QueryServer
- type Resource
- func (*Resource) Descriptor() ([]byte, []int)
- func (r Resource) FullPrice() sdk.Coin
- func (m *Resource) GetCount() uint32
- func (m *Resource) GetPrice() types1.Coin
- func (m *Resource) GetResources() types.ResourceUnits
- func (m *Resource) Marshal() (dAtA []byte, err error)
- func (m *Resource) MarshalTo(dAtA []byte) (int, error)
- func (m *Resource) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Resource) ProtoMessage()
- func (m *Resource) Reset()
- func (m *Resource) Size() (n int)
- func (m *Resource) String() string
- func (m *Resource) Unmarshal(dAtA []byte) error
- func (m *Resource) XXX_DiscardUnknown()
- func (m *Resource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Resource) XXX_Merge(src proto.Message)
- func (m *Resource) XXX_Size() int
- func (m *Resource) XXX_Unmarshal(b []byte) error
- type UnimplementedQueryServer
- func (*UnimplementedQueryServer) Deployment(ctx context.Context, req *QueryDeploymentRequest) (*QueryDeploymentResponse, error)
- func (*UnimplementedQueryServer) Deployments(ctx context.Context, req *QueryDeploymentsRequest) (*QueryDeploymentsResponse, error)
- func (*UnimplementedQueryServer) Group(ctx context.Context, req *QueryGroupRequest) (*QueryGroupResponse, error)
Constants ¶
const ( // ModuleName is the module name constant used in many places ModuleName = "deployment" // StoreKey is the store key string for deployment StoreKey = ModuleName // RouterKey is the message route for deployment RouterKey = ModuleName )
const ( MsgTypeCreateDeployment = "create-deployment" MsgTypeUpdateDeployment = "update-deployment" MsgTypeCloseDeployment = "close-deployment" MsgTypeCloseGroup = "close-group" )
const DefaultOrderBiddingDuration = int64(12342)
DefaultOrderBiddingDuration is the default time limit for an Order being active. After the duration, the Order is automatically closed. ( 24(hr) * 3600(seconds per hour) ) / 7s-Block
const MaxBiddingDuration = DefaultOrderBiddingDuration * int64(30)
MaxBiddingDuration is roughly 30 days of block height
Variables ¶
var ( ErrInvalidLengthDeployment = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowDeployment = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupDeployment = fmt.Errorf("proto: unexpected end of group") )
var ( // ErrNameDoesNotExist is the error when name does not exist ErrNameDoesNotExist = sdkerrors.Register(ModuleName, errNameDoesNotExist, "Name does not exist") // ErrInvalidRequest is the error for invalid request ErrInvalidRequest = sdkerrors.Register(ModuleName, errInvalidRequest, "Invalid request") // ErrDeploymentExists is the error when already deployment exists ErrDeploymentExists = sdkerrors.Register(ModuleName, errDeploymentExists, "Deployment exists") // ErrDeploymentNotFound is the error when deployment not found ErrDeploymentNotFound = sdkerrors.Register(ModuleName, errDeploymentNotFound, "Deployment not found") // ErrDeploymentClosed is the error when deployment is closed ErrDeploymentClosed = sdkerrors.Register(ModuleName, errDeploymentClosed, "Deployment closed") // ErrOwnerAcctMissing is the error for owner account missing ErrOwnerAcctMissing = sdkerrors.Register(ModuleName, errOwnerAcctMissing, "Owner account missing") // ErrInvalidGroups is the error when groups are empty ErrInvalidGroups = sdkerrors.Register(ModuleName, errInvalidGroups, "Invalid groups") // ErrInvalidDeploymentID is the error for invalid deployment id ErrInvalidDeploymentID = sdkerrors.Register(ModuleName, errInvalidDeploymentID, "Invalid: deployment id") // ErrEmptyVersion is the error when version is empty ErrEmptyVersion = sdkerrors.Register(ModuleName, errEmptyVersion, "Invalid: empty version") // ErrInternal is the error for internal error ErrInternal = sdkerrors.Register(ModuleName, errInternal, "internal error") // ErrInvalidDeployment = is the error when deployment does not pass validation ErrInvalidDeployment = sdkerrors.Register(ModuleName, errInvalidDeployment, "Invalid deployment") // ErrInvalidGroupID is the error when already deployment exists ErrInvalidGroupID = sdkerrors.Register(ModuleName, errInvalidGroupID, "Deployment exists") // ErrGroupNotFound is the keeper's error for not finding a group ErrGroupNotFound = sdkerrors.Register(ModuleName, errGroupNotFound, "Group not found") // ErrGroupClosed is the error when deployment is closed ErrGroupClosed = sdkerrors.Register(ModuleName, errGroupClosed, "Group already closed") // ErrGroupNotOpen indicates the Group state has progressed beyond initial Open. ErrGroupNotOpen = sdkerrors.Register(ModuleName, errGroupNotOpen, "Group not open") // ErrGroupSpecInvalid indicates a GroupSpec has invalid configuration ErrGroupSpecInvalid = sdkerrors.Register(ModuleName, errGroupSpec, "GroupSpec invalid") )
var ( ErrInvalidLengthGenesis = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowGenesis = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthGroup = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowGroup = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupGroup = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") )
var Deployment_State_name = map[int32]string{
0: "invalid",
1: "active",
2: "closed",
}
var Deployment_State_value = map[string]int32{
"invalid": 0,
"active": 1,
"closed": 2,
}
var Group_State_name = map[int32]string{
0: "invalid",
1: "open",
2: "ordered",
3: "matched",
4: "insufficient_funds",
5: "closed",
}
var Group_State_value = map[string]int32{
"invalid": 0,
"open": 1,
"ordered": 2,
"matched": 3,
"insufficient_funds": 4,
"closed": 5,
}
var ( // ModuleCdc references the global x/deployment module codec. Note, the codec should // ONLY be used in certain instances of tests and for JSON encoding as Amino is // still used for that purpose. // // The actual codec used for serialization should be provided to x/deployment and // defined at the application level. ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry()) )
Functions ¶
func DeploymentIDEVAttributes ¶
func DeploymentIDEVAttributes(id DeploymentID) []sdk.Attribute
DeploymentIDEVAttributes returns event attribues for given DeploymentID
func GroupIDEVAttributes ¶
GroupIDEVAttributes returns event attribues for given GroupID
func ParseEVDeploymentVersion ¶ added in v0.7.8
ParseEVDeploymentVersion returns the Deployment's SDL sha256 sum
func ParseEvent ¶
func ParseEvent(ev sdkutil.Event) (sdkutil.ModuleEvent, error)
ParseEvent parses event and returns details of event and error if occurred
func RegisterInterfaces ¶ added in v0.9.1
func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
RegisterInterfaces registers the x/deployment interfaces types with the interface registry
func RegisterLegacyAminoCodec ¶ added in v0.9.1
func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)
RegisterLegacyAminoCodec register concrete types on codec
func RegisterQueryHandler ¶ added in v0.9.1
RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterQueryHandlerClient ¶ added in v0.9.1
func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.
func RegisterQueryHandlerFromEndpoint ¶ added in v0.9.1
func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterQueryHandlerServer ¶ added in v0.9.1
func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features (such as grpc.SendHeader, etc) to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.
func RegisterQueryServer ¶ added in v0.9.1
func RegisterQueryServer(s grpc1.Server, srv QueryServer)
Types ¶
type Deployment ¶
type Deployment struct { DeploymentID DeploymentID `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"id" yaml:"id"` State Deployment_State `protobuf:"varint,2,opt,name=state,proto3,enum=akash.deployment.v1beta1.Deployment_State" json:"state" yaml:"state"` Version []byte `protobuf:"bytes,3,opt,name=version,proto3" json:"version" yaml:"version"` }
Deployment stores deploymentID, state and version details
func (*Deployment) Descriptor ¶ added in v0.9.1
func (*Deployment) Descriptor() ([]byte, []int)
func (*Deployment) GetDeploymentID ¶ added in v0.9.1
func (m *Deployment) GetDeploymentID() DeploymentID
func (*Deployment) GetState ¶ added in v0.9.1
func (m *Deployment) GetState() Deployment_State
func (*Deployment) GetVersion ¶ added in v0.9.1
func (m *Deployment) GetVersion() []byte
func (Deployment) ID ¶
func (obj Deployment) ID() DeploymentID
ID method returns DeploymentID details of specific deployment
func (*Deployment) Marshal ¶ added in v0.9.1
func (m *Deployment) Marshal() (dAtA []byte, err error)
func (*Deployment) MarshalTo ¶ added in v0.9.1
func (m *Deployment) MarshalTo(dAtA []byte) (int, error)
func (*Deployment) MarshalToSizedBuffer ¶ added in v0.9.1
func (m *Deployment) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Deployment) ProtoMessage ¶ added in v0.9.1
func (*Deployment) ProtoMessage()
func (*Deployment) Reset ¶ added in v0.9.1
func (m *Deployment) Reset()
func (*Deployment) Size ¶ added in v0.9.1
func (m *Deployment) Size() (n int)
func (*Deployment) String ¶ added in v0.9.1
func (m *Deployment) String() string
func (*Deployment) Unmarshal ¶ added in v0.9.1
func (m *Deployment) Unmarshal(dAtA []byte) error
func (*Deployment) XXX_DiscardUnknown ¶ added in v0.9.1
func (m *Deployment) XXX_DiscardUnknown()
func (*Deployment) XXX_Marshal ¶ added in v0.9.1
func (m *Deployment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Deployment) XXX_Merge ¶ added in v0.9.1
func (m *Deployment) XXX_Merge(src proto.Message)
func (*Deployment) XXX_Size ¶ added in v0.9.1
func (m *Deployment) XXX_Size() int
func (*Deployment) XXX_Unmarshal ¶ added in v0.9.1
func (m *Deployment) XXX_Unmarshal(b []byte) error
type DeploymentFilters ¶
type DeploymentFilters struct { Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner" yaml:"owner"` DSeq uint64 `protobuf:"varint,2,opt,name=dseq,proto3" json:"dseq" yaml:"dseq"` State string `protobuf:"bytes,3,opt,name=state,proto3" json:"state" yaml:"state"` }
DeploymentFilters defines filters used to filter deployments
func (DeploymentFilters) Accept ¶ added in v0.9.1
func (filters DeploymentFilters) Accept(obj Deployment, stateVal Deployment_State) bool
Accept returns whether deployment filters valid or not
func (*DeploymentFilters) Descriptor ¶ added in v0.9.1
func (*DeploymentFilters) Descriptor() ([]byte, []int)
func (*DeploymentFilters) GetDSeq ¶ added in v0.9.1
func (m *DeploymentFilters) GetDSeq() uint64
func (*DeploymentFilters) GetOwner ¶ added in v0.9.1
func (m *DeploymentFilters) GetOwner() string
func (*DeploymentFilters) GetState ¶ added in v0.9.1
func (m *DeploymentFilters) GetState() string
func (*DeploymentFilters) Marshal ¶ added in v0.9.1
func (m *DeploymentFilters) Marshal() (dAtA []byte, err error)
func (*DeploymentFilters) MarshalTo ¶ added in v0.9.1
func (m *DeploymentFilters) MarshalTo(dAtA []byte) (int, error)
func (*DeploymentFilters) MarshalToSizedBuffer ¶ added in v0.9.1
func (m *DeploymentFilters) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DeploymentFilters) ProtoMessage ¶ added in v0.9.1
func (*DeploymentFilters) ProtoMessage()
func (*DeploymentFilters) Reset ¶ added in v0.9.1
func (m *DeploymentFilters) Reset()
func (*DeploymentFilters) Size ¶ added in v0.9.1
func (m *DeploymentFilters) Size() (n int)
func (*DeploymentFilters) String ¶ added in v0.9.1
func (m *DeploymentFilters) String() string
func (*DeploymentFilters) Unmarshal ¶ added in v0.9.1
func (m *DeploymentFilters) Unmarshal(dAtA []byte) error
func (*DeploymentFilters) XXX_DiscardUnknown ¶ added in v0.9.1
func (m *DeploymentFilters) XXX_DiscardUnknown()
func (*DeploymentFilters) XXX_Marshal ¶ added in v0.9.1
func (m *DeploymentFilters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeploymentFilters) XXX_Merge ¶ added in v0.9.1
func (m *DeploymentFilters) XXX_Merge(src proto.Message)
func (*DeploymentFilters) XXX_Size ¶ added in v0.9.1
func (m *DeploymentFilters) XXX_Size() int
func (*DeploymentFilters) XXX_Unmarshal ¶ added in v0.9.1
func (m *DeploymentFilters) XXX_Unmarshal(b []byte) error
type DeploymentID ¶
type DeploymentID struct { Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner" yaml:"owner"` DSeq uint64 `protobuf:"varint,2,opt,name=dseq,proto3" json:"dseq" yaml:"dseq"` }
DeploymentID stores owner and sequence number
func ParseEVDeploymentID ¶
func ParseEVDeploymentID(attrs []sdk.Attribute) (DeploymentID, error)
ParseEVDeploymentID returns deploymentID details for given event attributes
func (*DeploymentID) Descriptor ¶ added in v0.9.1
func (*DeploymentID) Descriptor() ([]byte, []int)
func (DeploymentID) Equals ¶
func (id DeploymentID) Equals(other DeploymentID) bool
Equals method compares specific deployment with provided deployment
func (*DeploymentID) GetDSeq ¶ added in v0.9.1
func (m *DeploymentID) GetDSeq() uint64
func (*DeploymentID) GetOwner ¶ added in v0.9.1
func (m *DeploymentID) GetOwner() string
func (*DeploymentID) Marshal ¶ added in v0.9.1
func (m *DeploymentID) Marshal() (dAtA []byte, err error)
func (*DeploymentID) MarshalTo ¶ added in v0.9.1
func (m *DeploymentID) MarshalTo(dAtA []byte) (int, error)
func (*DeploymentID) MarshalToSizedBuffer ¶ added in v0.9.1
func (m *DeploymentID) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DeploymentID) ProtoMessage ¶ added in v0.9.1
func (*DeploymentID) ProtoMessage()
func (*DeploymentID) Reset ¶ added in v0.9.1
func (m *DeploymentID) Reset()
func (*DeploymentID) Size ¶ added in v0.9.1
func (m *DeploymentID) Size() (n int)
func (DeploymentID) String ¶ added in v0.7.8
func (id DeploymentID) String() string
String method for deployment IDs
func (*DeploymentID) Unmarshal ¶ added in v0.9.1
func (m *DeploymentID) Unmarshal(dAtA []byte) error
func (DeploymentID) Validate ¶
func (id DeploymentID) Validate() error
Validate method for DeploymentID and returns nil
func (*DeploymentID) XXX_DiscardUnknown ¶ added in v0.9.1
func (m *DeploymentID) XXX_DiscardUnknown()
func (*DeploymentID) XXX_Marshal ¶ added in v0.9.1
func (m *DeploymentID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeploymentID) XXX_Merge ¶ added in v0.9.1
func (m *DeploymentID) XXX_Merge(src proto.Message)
func (*DeploymentID) XXX_Size ¶ added in v0.9.1
func (m *DeploymentID) XXX_Size() int
func (*DeploymentID) XXX_Unmarshal ¶ added in v0.9.1
func (m *DeploymentID) XXX_Unmarshal(b []byte) error
type DeploymentResponse ¶ added in v0.9.1
type DeploymentResponse struct { Deployment Deployment `protobuf:"bytes,1,opt,name=deployment,proto3" json:"deployment" yaml:"deployment"` Groups []Group `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups" yaml:"groups"` Version []byte `protobuf:"bytes,3,opt,name=version,proto3" json:"version" yaml:"version"` }
DeploymentResponse represents details of deployment along with group details
func (*DeploymentResponse) Descriptor ¶ added in v0.9.1
func (*DeploymentResponse) Descriptor() ([]byte, []int)
func (*DeploymentResponse) GetDeployment ¶ added in v0.9.1
func (m *DeploymentResponse) GetDeployment() Deployment
func (*DeploymentResponse) GetGroups ¶ added in v0.9.1
func (m *DeploymentResponse) GetGroups() []Group
func (*DeploymentResponse) GetVersion ¶ added in v0.9.1
func (m *DeploymentResponse) GetVersion() []byte
func (*DeploymentResponse) Marshal ¶ added in v0.9.1
func (m *DeploymentResponse) Marshal() (dAtA []byte, err error)
func (*DeploymentResponse) MarshalTo ¶ added in v0.9.1
func (m *DeploymentResponse) MarshalTo(dAtA []byte) (int, error)
func (*DeploymentResponse) MarshalToSizedBuffer ¶ added in v0.9.1
func (m *DeploymentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DeploymentResponse) ProtoMessage ¶ added in v0.9.1
func (*DeploymentResponse) ProtoMessage()
func (*DeploymentResponse) Reset ¶ added in v0.9.1
func (m *DeploymentResponse) Reset()
func (*DeploymentResponse) Size ¶ added in v0.9.1
func (m *DeploymentResponse) Size() (n int)
func (DeploymentResponse) String ¶ added in v0.9.1
func (d DeploymentResponse) String() string
func (*DeploymentResponse) Unmarshal ¶ added in v0.9.1
func (m *DeploymentResponse) Unmarshal(dAtA []byte) error
func (*DeploymentResponse) XXX_DiscardUnknown ¶ added in v0.9.1
func (m *DeploymentResponse) XXX_DiscardUnknown()
func (*DeploymentResponse) XXX_Marshal ¶ added in v0.9.1
func (m *DeploymentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeploymentResponse) XXX_Merge ¶ added in v0.9.1
func (m *DeploymentResponse) XXX_Merge(src proto.Message)
func (*DeploymentResponse) XXX_Size ¶ added in v0.9.1
func (m *DeploymentResponse) XXX_Size() int
func (*DeploymentResponse) XXX_Unmarshal ¶ added in v0.9.1
func (m *DeploymentResponse) XXX_Unmarshal(b []byte) error
type DeploymentResponses ¶ added in v0.9.1
type DeploymentResponses []DeploymentResponse
DeploymentResponses is a collection of DeploymentResponse
func (DeploymentResponses) String ¶ added in v0.9.1
func (ds DeploymentResponses) String() string
type Deployment_State ¶ added in v0.9.1
type Deployment_State int32
State is an enum which refers to state of deployment
const ( // Prefix should start with 0 in enum. So declaring dummy state DeploymentStateInvalid Deployment_State = 0 // DeploymentActive denotes state for deployment active DeploymentActive Deployment_State = 1 // DeploymentClosed denotes state for deployment closed DeploymentClosed Deployment_State = 2 )
func (Deployment_State) EnumDescriptor ¶ added in v0.9.1
func (Deployment_State) EnumDescriptor() ([]byte, []int)
func (Deployment_State) String ¶ added in v0.9.1
func (x Deployment_State) String() string
type EventDeploymentClosed ¶ added in v0.7.6
type EventDeploymentClosed struct { Context sdkutil.BaseModuleEvent `json:"context"` ID DeploymentID `json:"id"` }
EventDeploymentClosed struct
func NewEventDeploymentClosed ¶ added in v0.7.6
func NewEventDeploymentClosed(id DeploymentID) EventDeploymentClosed
func (EventDeploymentClosed) ToSDKEvent ¶ added in v0.7.6
func (ev EventDeploymentClosed) ToSDKEvent() sdk.Event
ToSDKEvent method creates new sdk event for EventDeploymentClosed struct
type EventDeploymentCreated ¶ added in v0.7.6
type EventDeploymentCreated struct { Context sdkutil.BaseModuleEvent `json:"context"` ID DeploymentID `json:"id"` Version []byte `json:"version"` }
EventDeploymentCreated struct
func NewEventDeploymentCreated ¶ added in v0.7.6
func NewEventDeploymentCreated(id DeploymentID, version []byte) EventDeploymentCreated
NewEventDeploymentCreated initializes creation event.
func (EventDeploymentCreated) ToSDKEvent ¶ added in v0.7.6
func (ev EventDeploymentCreated) ToSDKEvent() sdk.Event
ToSDKEvent method creates new sdk event for EventDeploymentCreated struct
type EventDeploymentUpdated ¶ added in v0.7.6
type EventDeploymentUpdated struct { Context sdkutil.BaseModuleEvent `json:"context"` ID DeploymentID `json:"id"` Version []byte `json:"version"` }
EventDeploymentUpdated struct
func NewEventDeploymentUpdated ¶ added in v0.7.6
func NewEventDeploymentUpdated(id DeploymentID, version []byte) EventDeploymentUpdated
NewEventDeploymentUpdated initializes SDK type
func (EventDeploymentUpdated) ToSDKEvent ¶ added in v0.7.6
func (ev EventDeploymentUpdated) ToSDKEvent() sdk.Event
ToSDKEvent method creates new sdk event for EventDeploymentUpdated struct
type EventGroupClosed ¶ added in v0.7.6
type EventGroupClosed struct { Context sdkutil.BaseModuleEvent `json:"context"` ID GroupID `json:"id"` }
EventGroupClosed provides SDK event to signal group termination
func NewEventGroupClosed ¶ added in v0.7.6
func NewEventGroupClosed(id GroupID) EventGroupClosed
func (EventGroupClosed) ToSDKEvent ¶ added in v0.7.6
func (ev EventGroupClosed) ToSDKEvent() sdk.Event
ToSDKEvent produces the SDK notification for Event
type GenesisDeployment ¶ added in v0.9.1
type GenesisDeployment struct { Deployment Deployment `protobuf:"bytes,1,opt,name=deployment,proto3" json:"deployment" yaml:"deployment"` Groups []Group `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups" yaml:"groups"` }
GenesisDeployment defines the basic genesis state used by deployment module
func (*GenesisDeployment) Descriptor ¶ added in v0.9.1
func (*GenesisDeployment) Descriptor() ([]byte, []int)
func (*GenesisDeployment) GetDeployment ¶ added in v0.9.1
func (m *GenesisDeployment) GetDeployment() Deployment
func (*GenesisDeployment) GetGroups ¶ added in v0.9.1
func (m *GenesisDeployment) GetGroups() []Group
func (*GenesisDeployment) Marshal ¶ added in v0.9.1
func (m *GenesisDeployment) Marshal() (dAtA []byte, err error)
func (*GenesisDeployment) MarshalTo ¶ added in v0.9.1
func (m *GenesisDeployment) MarshalTo(dAtA []byte) (int, error)
func (*GenesisDeployment) MarshalToSizedBuffer ¶ added in v0.9.1
func (m *GenesisDeployment) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GenesisDeployment) ProtoMessage ¶ added in v0.9.1
func (*GenesisDeployment) ProtoMessage()
func (*GenesisDeployment) Reset ¶ added in v0.9.1
func (m *GenesisDeployment) Reset()
func (*GenesisDeployment) Size ¶ added in v0.9.1
func (m *GenesisDeployment) Size() (n int)
func (*GenesisDeployment) String ¶ added in v0.9.1
func (m *GenesisDeployment) String() string
func (*GenesisDeployment) Unmarshal ¶ added in v0.9.1
func (m *GenesisDeployment) Unmarshal(dAtA []byte) error
func (*GenesisDeployment) XXX_DiscardUnknown ¶ added in v0.9.1
func (m *GenesisDeployment) XXX_DiscardUnknown()
func (*GenesisDeployment) XXX_Marshal ¶ added in v0.9.1
func (m *GenesisDeployment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GenesisDeployment) XXX_Merge ¶ added in v0.9.1
func (m *GenesisDeployment) XXX_Merge(src proto.Message)
func (*GenesisDeployment) XXX_Size ¶ added in v0.9.1
func (m *GenesisDeployment) XXX_Size() int
func (*GenesisDeployment) XXX_Unmarshal ¶ added in v0.9.1
func (m *GenesisDeployment) XXX_Unmarshal(b []byte) error
type GenesisState ¶ added in v0.9.1
type GenesisState struct {
Deployments []GenesisDeployment `protobuf:"bytes,1,rep,name=deployments,proto3" json:"deployments" yaml:"deployments"`
}
GenesisState stores slice of genesis deployment instance
func (*GenesisState) Descriptor ¶ added in v0.9.1
func (*GenesisState) Descriptor() ([]byte, []int)
func (*GenesisState) GetDeployments ¶ added in v0.9.1
func (m *GenesisState) GetDeployments() []GenesisDeployment
func (*GenesisState) Marshal ¶ added in v0.9.1
func (m *GenesisState) Marshal() (dAtA []byte, err error)
func (*GenesisState) MarshalTo ¶ added in v0.9.1
func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)
func (*GenesisState) MarshalToSizedBuffer ¶ added in v0.9.1
func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GenesisState) ProtoMessage ¶ added in v0.9.1
func (*GenesisState) ProtoMessage()
func (*GenesisState) Reset ¶ added in v0.9.1
func (m *GenesisState) Reset()
func (*GenesisState) Size ¶ added in v0.9.1
func (m *GenesisState) Size() (n int)
func (*GenesisState) String ¶ added in v0.9.1
func (m *GenesisState) String() string
func (*GenesisState) Unmarshal ¶ added in v0.9.1
func (m *GenesisState) Unmarshal(dAtA []byte) error
func (*GenesisState) XXX_DiscardUnknown ¶ added in v0.9.1
func (m *GenesisState) XXX_DiscardUnknown()
func (*GenesisState) XXX_Marshal ¶ added in v0.9.1
func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GenesisState) XXX_Merge ¶ added in v0.9.1
func (m *GenesisState) XXX_Merge(src proto.Message)
func (*GenesisState) XXX_Size ¶ added in v0.9.1
func (m *GenesisState) XXX_Size() int
func (*GenesisState) XXX_Unmarshal ¶ added in v0.9.1
func (m *GenesisState) XXX_Unmarshal(b []byte) error
type Group ¶
type Group struct { GroupID GroupID `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3" json:"id" yaml:"id"` State Group_State `protobuf:"varint,2,opt,name=state,proto3,enum=akash.deployment.v1beta1.Group_State" json:"state" yaml:"state"` GroupSpec GroupSpec `protobuf:"bytes,3,opt,name=group_spec,json=groupSpec,proto3" json:"spec" yaml:"spec"` }
Group stores group id, state and specifications of group
func (*Group) Descriptor ¶ added in v0.9.1
func (*Group) GetGroupID ¶ added in v0.9.1
func (*Group) GetGroupSpec ¶ added in v0.9.1
func (Group) GetResources ¶ added in v0.9.1
GetResources method returns resources list in group
func (*Group) GetState ¶ added in v0.9.1
func (m *Group) GetState() Group_State
func (*Group) MarshalToSizedBuffer ¶ added in v0.9.1
func (*Group) ProtoMessage ¶ added in v0.9.1
func (*Group) ProtoMessage()
func (Group) ValidateClosable ¶ added in v0.7.5
ValidateClosable provides error response if group is already closed, and thus should not be closed again, else nil.
func (Group) ValidateOrderable ¶
ValidateOrderable method checks whether group status is Open or not
func (*Group) XXX_DiscardUnknown ¶ added in v0.9.1
func (m *Group) XXX_DiscardUnknown()
func (*Group) XXX_Marshal ¶ added in v0.9.1
func (*Group) XXX_Unmarshal ¶ added in v0.9.1
type GroupID ¶
type GroupID struct { Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner" yaml:"owner"` DSeq uint64 `protobuf:"varint,2,opt,name=dseq,proto3" json:"dseq" yaml:"dseq"` GSeq uint32 `protobuf:"varint,3,opt,name=gseq,proto3" json:"gseq" yaml:"gseq"` }
GroupID stores owner, deployment sequence number and group sequence number
func MakeGroupID ¶
func MakeGroupID(id DeploymentID, gseq uint32) GroupID
MakeGroupID returns GroupID instance with provided deployment details and group sequence number.
func ParseEVGroupID ¶
ParseEVGroupID returns GroupID details for given event attributes
func (GroupID) DeploymentID ¶
func (id GroupID) DeploymentID() DeploymentID
DeploymentID method returns DeploymentID details with specific group details
func (*GroupID) Descriptor ¶ added in v0.9.1
func (*GroupID) MarshalToSizedBuffer ¶ added in v0.9.1
func (*GroupID) ProtoMessage ¶ added in v0.9.1
func (*GroupID) ProtoMessage()
func (GroupID) String ¶ added in v0.7.8
String method provides human readable representation of GroupID.
func (*GroupID) XXX_DiscardUnknown ¶ added in v0.9.1
func (m *GroupID) XXX_DiscardUnknown()
func (*GroupID) XXX_Marshal ¶ added in v0.9.1
func (*GroupID) XXX_Unmarshal ¶ added in v0.9.1
type GroupSpec ¶
type GroupSpec struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name" yaml:"name"` Requirements []types.Attribute `protobuf:"bytes,2,rep,name=requirements,proto3" json:"requirements" yaml:"requirements"` Resources []Resource `protobuf:"bytes,3,rep,name=resources,proto3" json:"resources" yaml:"resources"` OrderBidDuration int64 `` /* 128-byte string literal not displayed */ }
GroupSpec stores group specifications
func (*GroupSpec) Descriptor ¶ added in v0.9.1
func (GroupSpec) GetResources ¶
GetResources method returns resources list in group
func (*GroupSpec) MarshalToSizedBuffer ¶ added in v0.9.1
func (GroupSpec) MatchAttributes ¶
MatchAttributes method compares provided attributes with specific group attributes
func (*GroupSpec) ProtoMessage ¶ added in v0.9.1
func (*GroupSpec) ProtoMessage()
func (GroupSpec) ValidateBasic ¶ added in v0.7.8
ValidateBasic asserts non-zero values TODO: This is causing an import cycle. I think there is some pattern here I'm missing tho..
func (*GroupSpec) XXX_DiscardUnknown ¶ added in v0.9.1
func (m *GroupSpec) XXX_DiscardUnknown()
func (*GroupSpec) XXX_Marshal ¶ added in v0.9.1
func (*GroupSpec) XXX_Unmarshal ¶ added in v0.9.1
type Group_State ¶ added in v0.9.1
type Group_State int32
State is an enum which refers to state of group
const ( // Prefix should start with 0 in enum. So declaring dummy state GroupStateInvalid Group_State = 0 // GroupOpen denotes state for group open GroupOpen Group_State = 1 // GroupOrdered denotes state for group ordered GroupOrdered Group_State = 2 // GroupMatched denotes state for group matched GroupMatched Group_State = 3 // GroupInsufficientFunds denotes state for group insufficient_funds GroupInsufficientFunds Group_State = 4 // GroupClosed denotes state for group closed GroupClosed Group_State = 5 )
func (Group_State) EnumDescriptor ¶ added in v0.9.1
func (Group_State) EnumDescriptor() ([]byte, []int)
func (Group_State) String ¶ added in v0.9.1
func (x Group_State) String() string
type MsgCloseDeployment ¶ added in v0.6.5
type MsgCloseDeployment struct {
ID DeploymentID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
}
MsgCloseDeployment defines an SDK message for closing deployment
func NewMsgCloseDeployment ¶ added in v0.9.1
func NewMsgCloseDeployment(id DeploymentID) *MsgCloseDeployment
NewMsgCloseDeployment creates a new MsgCloseDeployment instance
func (*MsgCloseDeployment) Descriptor ¶ added in v0.9.1
func (*MsgCloseDeployment) Descriptor() ([]byte, []int)
func (*MsgCloseDeployment) GetID ¶ added in v0.9.1
func (m *MsgCloseDeployment) GetID() DeploymentID
func (MsgCloseDeployment) GetSignBytes ¶ added in v0.6.5
func (msg MsgCloseDeployment) GetSignBytes() []byte
GetSignBytes encodes the message for signing
func (MsgCloseDeployment) GetSigners ¶ added in v0.6.5
func (msg MsgCloseDeployment) GetSigners() []sdk.AccAddress
GetSigners defines whose signature is required
func (*MsgCloseDeployment) Marshal ¶ added in v0.9.1
func (m *MsgCloseDeployment) Marshal() (dAtA []byte, err error)
func (*MsgCloseDeployment) MarshalTo ¶ added in v0.9.1
func (m *MsgCloseDeployment) MarshalTo(dAtA []byte) (int, error)
func (*MsgCloseDeployment) MarshalToSizedBuffer ¶ added in v0.9.1
func (m *MsgCloseDeployment) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgCloseDeployment) ProtoMessage ¶ added in v0.9.1
func (*MsgCloseDeployment) ProtoMessage()
func (*MsgCloseDeployment) Reset ¶ added in v0.9.1
func (m *MsgCloseDeployment) Reset()
func (MsgCloseDeployment) Route ¶ added in v0.6.5
func (msg MsgCloseDeployment) Route() string
Route implements the sdk.Msg interface
func (*MsgCloseDeployment) Size ¶ added in v0.9.1
func (m *MsgCloseDeployment) Size() (n int)
func (*MsgCloseDeployment) String ¶ added in v0.9.1
func (m *MsgCloseDeployment) String() string
func (MsgCloseDeployment) Type ¶ added in v0.6.5
func (msg MsgCloseDeployment) Type() string
Type implements the sdk.Msg interface
func (*MsgCloseDeployment) Unmarshal ¶ added in v0.9.1
func (m *MsgCloseDeployment) Unmarshal(dAtA []byte) error
func (MsgCloseDeployment) ValidateBasic ¶ added in v0.6.5
func (msg MsgCloseDeployment) ValidateBasic() error
ValidateBasic does basic validation with deployment details
func (*MsgCloseDeployment) XXX_DiscardUnknown ¶ added in v0.9.1
func (m *MsgCloseDeployment) XXX_DiscardUnknown()
func (*MsgCloseDeployment) XXX_Marshal ¶ added in v0.9.1
func (m *MsgCloseDeployment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgCloseDeployment) XXX_Merge ¶ added in v0.9.1
func (m *MsgCloseDeployment) XXX_Merge(src proto.Message)
func (*MsgCloseDeployment) XXX_Size ¶ added in v0.9.1
func (m *MsgCloseDeployment) XXX_Size() int
func (*MsgCloseDeployment) XXX_Unmarshal ¶ added in v0.9.1
func (m *MsgCloseDeployment) XXX_Unmarshal(b []byte) error
type MsgCloseGroup ¶ added in v0.7.5
type MsgCloseGroup struct {
ID GroupID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
}
MsgCloseGroup defines SDK message to close a single Group within a Deployment.
func NewMsgCloseGroup ¶ added in v0.9.1
func NewMsgCloseGroup(id GroupID) *MsgCloseGroup
NewMsgCloseGroup creates a new MsgCloseGroup instance
func (*MsgCloseGroup) Descriptor ¶ added in v0.9.1
func (*MsgCloseGroup) Descriptor() ([]byte, []int)
func (*MsgCloseGroup) GetID ¶ added in v0.9.1
func (m *MsgCloseGroup) GetID() GroupID
func (MsgCloseGroup) GetSignBytes ¶ added in v0.7.5
func (msg MsgCloseGroup) GetSignBytes() []byte
GetSignBytes encodes the message for signing
func (MsgCloseGroup) GetSigners ¶ added in v0.7.5
func (msg MsgCloseGroup) GetSigners() []sdk.AccAddress
GetSigners defines whose signature is required
func (*MsgCloseGroup) Marshal ¶ added in v0.9.1
func (m *MsgCloseGroup) Marshal() (dAtA []byte, err error)
func (*MsgCloseGroup) MarshalTo ¶ added in v0.9.1
func (m *MsgCloseGroup) MarshalTo(dAtA []byte) (int, error)
func (*MsgCloseGroup) MarshalToSizedBuffer ¶ added in v0.9.1
func (m *MsgCloseGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgCloseGroup) ProtoMessage ¶ added in v0.9.1
func (*MsgCloseGroup) ProtoMessage()
func (*MsgCloseGroup) Reset ¶ added in v0.9.1
func (m *MsgCloseGroup) Reset()
func (MsgCloseGroup) Route ¶ added in v0.7.5
func (msg MsgCloseGroup) Route() string
Route implements the sdk.Msg interface for routing
func (*MsgCloseGroup) Size ¶ added in v0.9.1
func (m *MsgCloseGroup) Size() (n int)
func (*MsgCloseGroup) String ¶ added in v0.9.1
func (m *MsgCloseGroup) String() string
func (MsgCloseGroup) Type ¶ added in v0.7.5
func (msg MsgCloseGroup) Type() string
Type implements the sdk.Msg interface exposing message type
func (*MsgCloseGroup) Unmarshal ¶ added in v0.9.1
func (m *MsgCloseGroup) Unmarshal(dAtA []byte) error
func (MsgCloseGroup) ValidateBasic ¶ added in v0.7.5
func (msg MsgCloseGroup) ValidateBasic() error
ValidateBasic calls underlying GroupID.Validate() check and returns result
func (*MsgCloseGroup) XXX_DiscardUnknown ¶ added in v0.9.1
func (m *MsgCloseGroup) XXX_DiscardUnknown()
func (*MsgCloseGroup) XXX_Marshal ¶ added in v0.9.1
func (m *MsgCloseGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgCloseGroup) XXX_Merge ¶ added in v0.9.1
func (m *MsgCloseGroup) XXX_Merge(src proto.Message)
func (*MsgCloseGroup) XXX_Size ¶ added in v0.9.1
func (m *MsgCloseGroup) XXX_Size() int
func (*MsgCloseGroup) XXX_Unmarshal ¶ added in v0.9.1
func (m *MsgCloseGroup) XXX_Unmarshal(b []byte) error
type MsgCreateDeployment ¶ added in v0.6.5
type MsgCreateDeployment struct { ID DeploymentID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"` Groups []GroupSpec `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups" yaml:"groups"` Version []byte `protobuf:"bytes,3,opt,name=version,proto3" json:"version" yaml:"version"` }
MsgCreateDeployment defines an SDK message for creating deployment
func NewMsgCreateDeployment ¶ added in v0.9.1
func NewMsgCreateDeployment(id DeploymentID, groups []GroupSpec, version []byte) *MsgCreateDeployment
NewMsgCreateDeployment creates a new MsgCreateDeployment instance
func (*MsgCreateDeployment) Descriptor ¶ added in v0.9.1
func (*MsgCreateDeployment) Descriptor() ([]byte, []int)
func (*MsgCreateDeployment) GetGroups ¶ added in v0.9.1
func (m *MsgCreateDeployment) GetGroups() []GroupSpec
func (*MsgCreateDeployment) GetID ¶ added in v0.9.1
func (m *MsgCreateDeployment) GetID() DeploymentID
func (MsgCreateDeployment) GetSignBytes ¶ added in v0.6.5
func (msg MsgCreateDeployment) GetSignBytes() []byte
GetSignBytes encodes the message for signing
func (MsgCreateDeployment) GetSigners ¶ added in v0.6.5
func (msg MsgCreateDeployment) GetSigners() []sdk.AccAddress
GetSigners defines whose signature is required
func (*MsgCreateDeployment) GetVersion ¶ added in v0.9.1
func (m *MsgCreateDeployment) GetVersion() []byte
func (*MsgCreateDeployment) Marshal ¶ added in v0.9.1
func (m *MsgCreateDeployment) Marshal() (dAtA []byte, err error)
func (*MsgCreateDeployment) MarshalTo ¶ added in v0.9.1
func (m *MsgCreateDeployment) MarshalTo(dAtA []byte) (int, error)
func (*MsgCreateDeployment) MarshalToSizedBuffer ¶ added in v0.9.1
func (m *MsgCreateDeployment) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgCreateDeployment) ProtoMessage ¶ added in v0.9.1
func (*MsgCreateDeployment) ProtoMessage()
func (*MsgCreateDeployment) Reset ¶ added in v0.9.1
func (m *MsgCreateDeployment) Reset()
func (MsgCreateDeployment) Route ¶ added in v0.6.5
func (msg MsgCreateDeployment) Route() string
Route implements the sdk.Msg interface
func (*MsgCreateDeployment) Size ¶ added in v0.9.1
func (m *MsgCreateDeployment) Size() (n int)
func (*MsgCreateDeployment) String ¶ added in v0.9.1
func (m *MsgCreateDeployment) String() string
func (MsgCreateDeployment) Type ¶ added in v0.6.5
func (msg MsgCreateDeployment) Type() string
Type implements the sdk.Msg interface
func (*MsgCreateDeployment) Unmarshal ¶ added in v0.9.1
func (m *MsgCreateDeployment) Unmarshal(dAtA []byte) error
func (MsgCreateDeployment) ValidateBasic ¶ added in v0.6.5
func (msg MsgCreateDeployment) ValidateBasic() error
ValidateBasic does basic validation like check owner and groups length
func (*MsgCreateDeployment) XXX_DiscardUnknown ¶ added in v0.9.1
func (m *MsgCreateDeployment) XXX_DiscardUnknown()
func (*MsgCreateDeployment) XXX_Marshal ¶ added in v0.9.1
func (m *MsgCreateDeployment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgCreateDeployment) XXX_Merge ¶ added in v0.9.1
func (m *MsgCreateDeployment) XXX_Merge(src proto.Message)
func (*MsgCreateDeployment) XXX_Size ¶ added in v0.9.1
func (m *MsgCreateDeployment) XXX_Size() int
func (*MsgCreateDeployment) XXX_Unmarshal ¶ added in v0.9.1
func (m *MsgCreateDeployment) XXX_Unmarshal(b []byte) error
type MsgUpdateDeployment ¶ added in v0.6.5
type MsgUpdateDeployment struct { ID DeploymentID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"` Groups []GroupSpec `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups" yaml:"groups"` Version []byte `protobuf:"bytes,3,opt,name=version,proto3" json:"version" yaml:"version"` }
MsgUpdateDeployment defines an SDK message for updating deployment
func NewMsgUpdateDeployment ¶ added in v0.9.1
func NewMsgUpdateDeployment(id DeploymentID, groups []GroupSpec, version []byte) *MsgUpdateDeployment
NewMsgUpdateDeployment creates a new MsgUpdateDeployment instance
func (*MsgUpdateDeployment) Descriptor ¶ added in v0.9.1
func (*MsgUpdateDeployment) Descriptor() ([]byte, []int)
func (*MsgUpdateDeployment) GetGroups ¶ added in v0.9.1
func (m *MsgUpdateDeployment) GetGroups() []GroupSpec
func (*MsgUpdateDeployment) GetID ¶ added in v0.9.1
func (m *MsgUpdateDeployment) GetID() DeploymentID
func (MsgUpdateDeployment) GetSignBytes ¶ added in v0.6.5
func (msg MsgUpdateDeployment) GetSignBytes() []byte
GetSignBytes encodes the message for signing
func (MsgUpdateDeployment) GetSigners ¶ added in v0.6.5
func (msg MsgUpdateDeployment) GetSigners() []sdk.AccAddress
GetSigners defines whose signature is required
func (*MsgUpdateDeployment) GetVersion ¶ added in v0.9.1
func (m *MsgUpdateDeployment) GetVersion() []byte
func (*MsgUpdateDeployment) Marshal ¶ added in v0.9.1
func (m *MsgUpdateDeployment) Marshal() (dAtA []byte, err error)
func (*MsgUpdateDeployment) MarshalTo ¶ added in v0.9.1
func (m *MsgUpdateDeployment) MarshalTo(dAtA []byte) (int, error)
func (*MsgUpdateDeployment) MarshalToSizedBuffer ¶ added in v0.9.1
func (m *MsgUpdateDeployment) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgUpdateDeployment) ProtoMessage ¶ added in v0.9.1
func (*MsgUpdateDeployment) ProtoMessage()
func (*MsgUpdateDeployment) Reset ¶ added in v0.9.1
func (m *MsgUpdateDeployment) Reset()
func (MsgUpdateDeployment) Route ¶ added in v0.6.5
func (msg MsgUpdateDeployment) Route() string
Route implements the sdk.Msg interface
func (*MsgUpdateDeployment) Size ¶ added in v0.9.1
func (m *MsgUpdateDeployment) Size() (n int)
func (*MsgUpdateDeployment) String ¶ added in v0.9.1
func (m *MsgUpdateDeployment) String() string
func (MsgUpdateDeployment) Type ¶ added in v0.6.5
func (msg MsgUpdateDeployment) Type() string
Type implements the sdk.Msg interface
func (*MsgUpdateDeployment) Unmarshal ¶ added in v0.9.1
func (m *MsgUpdateDeployment) Unmarshal(dAtA []byte) error
func (MsgUpdateDeployment) ValidateBasic ¶ added in v0.6.5
func (msg MsgUpdateDeployment) ValidateBasic() error
ValidateBasic does basic validation
func (*MsgUpdateDeployment) XXX_DiscardUnknown ¶ added in v0.9.1
func (m *MsgUpdateDeployment) XXX_DiscardUnknown()
func (*MsgUpdateDeployment) XXX_Marshal ¶ added in v0.9.1
func (m *MsgUpdateDeployment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgUpdateDeployment) XXX_Merge ¶ added in v0.9.1
func (m *MsgUpdateDeployment) XXX_Merge(src proto.Message)
func (*MsgUpdateDeployment) XXX_Size ¶ added in v0.9.1
func (m *MsgUpdateDeployment) XXX_Size() int
func (*MsgUpdateDeployment) XXX_Unmarshal ¶ added in v0.9.1
func (m *MsgUpdateDeployment) XXX_Unmarshal(b []byte) error
type QueryClient ¶ added in v0.9.1
type QueryClient interface { // Deployments queries deployments Deployments(ctx context.Context, in *QueryDeploymentsRequest, opts ...grpc.CallOption) (*QueryDeploymentsResponse, error) // Deployment queries deployment details Deployment(ctx context.Context, in *QueryDeploymentRequest, opts ...grpc.CallOption) (*QueryDeploymentResponse, error) // Group queries group details Group(ctx context.Context, in *QueryGroupRequest, opts ...grpc.CallOption) (*QueryGroupResponse, error) }
QueryClient is the client API for Query service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewQueryClient ¶ added in v0.9.1
func NewQueryClient(cc grpc1.ClientConn) QueryClient
type QueryDeploymentRequest ¶ added in v0.9.1
type QueryDeploymentRequest struct {
ID DeploymentID `protobuf:"bytes,1,opt,name=id,proto3" json:"id"`
}
QueryDeploymentRequest is request type for the Query/Deployment RPC method
func (*QueryDeploymentRequest) Descriptor ¶ added in v0.9.1
func (*QueryDeploymentRequest) Descriptor() ([]byte, []int)
func (*QueryDeploymentRequest) GetID ¶ added in v0.9.1
func (m *QueryDeploymentRequest) GetID() DeploymentID
func (*QueryDeploymentRequest) Marshal ¶ added in v0.9.1
func (m *QueryDeploymentRequest) Marshal() (dAtA []byte, err error)
func (*QueryDeploymentRequest) MarshalTo ¶ added in v0.9.1
func (m *QueryDeploymentRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryDeploymentRequest) MarshalToSizedBuffer ¶ added in v0.9.1
func (m *QueryDeploymentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryDeploymentRequest) ProtoMessage ¶ added in v0.9.1
func (*QueryDeploymentRequest) ProtoMessage()
func (*QueryDeploymentRequest) Reset ¶ added in v0.9.1
func (m *QueryDeploymentRequest) Reset()
func (*QueryDeploymentRequest) Size ¶ added in v0.9.1
func (m *QueryDeploymentRequest) Size() (n int)
func (*QueryDeploymentRequest) String ¶ added in v0.9.1
func (m *QueryDeploymentRequest) String() string
func (*QueryDeploymentRequest) Unmarshal ¶ added in v0.9.1
func (m *QueryDeploymentRequest) Unmarshal(dAtA []byte) error
func (*QueryDeploymentRequest) XXX_DiscardUnknown ¶ added in v0.9.1
func (m *QueryDeploymentRequest) XXX_DiscardUnknown()
func (*QueryDeploymentRequest) XXX_Marshal ¶ added in v0.9.1
func (m *QueryDeploymentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryDeploymentRequest) XXX_Merge ¶ added in v0.9.1
func (m *QueryDeploymentRequest) XXX_Merge(src proto.Message)
func (*QueryDeploymentRequest) XXX_Size ¶ added in v0.9.1
func (m *QueryDeploymentRequest) XXX_Size() int
func (*QueryDeploymentRequest) XXX_Unmarshal ¶ added in v0.9.1
func (m *QueryDeploymentRequest) XXX_Unmarshal(b []byte) error
type QueryDeploymentResponse ¶ added in v0.9.1
type QueryDeploymentResponse struct {
Deployment DeploymentResponse `protobuf:"bytes,1,opt,name=deployment,proto3" json:"deployment"`
}
QueryDeploymentResponse is response type for the Query/Deployment RPC method
func (*QueryDeploymentResponse) Descriptor ¶ added in v0.9.1
func (*QueryDeploymentResponse) Descriptor() ([]byte, []int)
func (*QueryDeploymentResponse) GetDeployment ¶ added in v0.9.1
func (m *QueryDeploymentResponse) GetDeployment() DeploymentResponse
func (*QueryDeploymentResponse) Marshal ¶ added in v0.9.1
func (m *QueryDeploymentResponse) Marshal() (dAtA []byte, err error)
func (*QueryDeploymentResponse) MarshalTo ¶ added in v0.9.1
func (m *QueryDeploymentResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryDeploymentResponse) MarshalToSizedBuffer ¶ added in v0.9.1
func (m *QueryDeploymentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryDeploymentResponse) ProtoMessage ¶ added in v0.9.1
func (*QueryDeploymentResponse) ProtoMessage()
func (*QueryDeploymentResponse) Reset ¶ added in v0.9.1
func (m *QueryDeploymentResponse) Reset()
func (*QueryDeploymentResponse) Size ¶ added in v0.9.1
func (m *QueryDeploymentResponse) Size() (n int)
func (*QueryDeploymentResponse) String ¶ added in v0.9.1
func (m *QueryDeploymentResponse) String() string
func (*QueryDeploymentResponse) Unmarshal ¶ added in v0.9.1
func (m *QueryDeploymentResponse) Unmarshal(dAtA []byte) error
func (*QueryDeploymentResponse) XXX_DiscardUnknown ¶ added in v0.9.1
func (m *QueryDeploymentResponse) XXX_DiscardUnknown()
func (*QueryDeploymentResponse) XXX_Marshal ¶ added in v0.9.1
func (m *QueryDeploymentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryDeploymentResponse) XXX_Merge ¶ added in v0.9.1
func (m *QueryDeploymentResponse) XXX_Merge(src proto.Message)
func (*QueryDeploymentResponse) XXX_Size ¶ added in v0.9.1
func (m *QueryDeploymentResponse) XXX_Size() int
func (*QueryDeploymentResponse) XXX_Unmarshal ¶ added in v0.9.1
func (m *QueryDeploymentResponse) XXX_Unmarshal(b []byte) error
type QueryDeploymentsRequest ¶ added in v0.9.1
type QueryDeploymentsRequest struct { Filters DeploymentFilters `protobuf:"bytes,1,opt,name=filters,proto3" json:"filters"` Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
QueryDeploymentsRequest is request type for the Query/Deployments RPC method
func (*QueryDeploymentsRequest) Descriptor ¶ added in v0.9.1
func (*QueryDeploymentsRequest) Descriptor() ([]byte, []int)
func (*QueryDeploymentsRequest) GetFilters ¶ added in v0.9.1
func (m *QueryDeploymentsRequest) GetFilters() DeploymentFilters
func (*QueryDeploymentsRequest) GetPagination ¶ added in v0.9.1
func (m *QueryDeploymentsRequest) GetPagination() *query.PageRequest
func (*QueryDeploymentsRequest) Marshal ¶ added in v0.9.1
func (m *QueryDeploymentsRequest) Marshal() (dAtA []byte, err error)
func (*QueryDeploymentsRequest) MarshalTo ¶ added in v0.9.1
func (m *QueryDeploymentsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryDeploymentsRequest) MarshalToSizedBuffer ¶ added in v0.9.1
func (m *QueryDeploymentsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryDeploymentsRequest) ProtoMessage ¶ added in v0.9.1
func (*QueryDeploymentsRequest) ProtoMessage()
func (*QueryDeploymentsRequest) Reset ¶ added in v0.9.1
func (m *QueryDeploymentsRequest) Reset()
func (*QueryDeploymentsRequest) Size ¶ added in v0.9.1
func (m *QueryDeploymentsRequest) Size() (n int)
func (*QueryDeploymentsRequest) String ¶ added in v0.9.1
func (m *QueryDeploymentsRequest) String() string
func (*QueryDeploymentsRequest) Unmarshal ¶ added in v0.9.1
func (m *QueryDeploymentsRequest) Unmarshal(dAtA []byte) error
func (*QueryDeploymentsRequest) XXX_DiscardUnknown ¶ added in v0.9.1
func (m *QueryDeploymentsRequest) XXX_DiscardUnknown()
func (*QueryDeploymentsRequest) XXX_Marshal ¶ added in v0.9.1
func (m *QueryDeploymentsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryDeploymentsRequest) XXX_Merge ¶ added in v0.9.1
func (m *QueryDeploymentsRequest) XXX_Merge(src proto.Message)
func (*QueryDeploymentsRequest) XXX_Size ¶ added in v0.9.1
func (m *QueryDeploymentsRequest) XXX_Size() int
func (*QueryDeploymentsRequest) XXX_Unmarshal ¶ added in v0.9.1
func (m *QueryDeploymentsRequest) XXX_Unmarshal(b []byte) error
type QueryDeploymentsResponse ¶ added in v0.9.1
type QueryDeploymentsResponse struct { Deployments DeploymentResponses `protobuf:"bytes,1,rep,name=deployments,proto3,castrepeated=DeploymentResponses" json:"deployments"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
QueryDeploymentsResponse is response type for the Query/Deployments RPC method
func (*QueryDeploymentsResponse) Descriptor ¶ added in v0.9.1
func (*QueryDeploymentsResponse) Descriptor() ([]byte, []int)
func (*QueryDeploymentsResponse) GetDeployments ¶ added in v0.9.1
func (m *QueryDeploymentsResponse) GetDeployments() DeploymentResponses
func (*QueryDeploymentsResponse) GetPagination ¶ added in v0.9.1
func (m *QueryDeploymentsResponse) GetPagination() *query.PageResponse
func (*QueryDeploymentsResponse) Marshal ¶ added in v0.9.1
func (m *QueryDeploymentsResponse) Marshal() (dAtA []byte, err error)
func (*QueryDeploymentsResponse) MarshalTo ¶ added in v0.9.1
func (m *QueryDeploymentsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryDeploymentsResponse) MarshalToSizedBuffer ¶ added in v0.9.1
func (m *QueryDeploymentsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryDeploymentsResponse) ProtoMessage ¶ added in v0.9.1
func (*QueryDeploymentsResponse) ProtoMessage()
func (*QueryDeploymentsResponse) Reset ¶ added in v0.9.1
func (m *QueryDeploymentsResponse) Reset()
func (*QueryDeploymentsResponse) Size ¶ added in v0.9.1
func (m *QueryDeploymentsResponse) Size() (n int)
func (*QueryDeploymentsResponse) String ¶ added in v0.9.1
func (m *QueryDeploymentsResponse) String() string
func (*QueryDeploymentsResponse) Unmarshal ¶ added in v0.9.1
func (m *QueryDeploymentsResponse) Unmarshal(dAtA []byte) error
func (*QueryDeploymentsResponse) XXX_DiscardUnknown ¶ added in v0.9.1
func (m *QueryDeploymentsResponse) XXX_DiscardUnknown()
func (*QueryDeploymentsResponse) XXX_Marshal ¶ added in v0.9.1
func (m *QueryDeploymentsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryDeploymentsResponse) XXX_Merge ¶ added in v0.9.1
func (m *QueryDeploymentsResponse) XXX_Merge(src proto.Message)
func (*QueryDeploymentsResponse) XXX_Size ¶ added in v0.9.1
func (m *QueryDeploymentsResponse) XXX_Size() int
func (*QueryDeploymentsResponse) XXX_Unmarshal ¶ added in v0.9.1
func (m *QueryDeploymentsResponse) XXX_Unmarshal(b []byte) error
type QueryGroupRequest ¶ added in v0.9.1
type QueryGroupRequest struct {
ID GroupID `protobuf:"bytes,1,opt,name=id,proto3" json:"id"`
}
QueryGroupRequest is request type for the Query/Group RPC method
func (*QueryGroupRequest) Descriptor ¶ added in v0.9.1
func (*QueryGroupRequest) Descriptor() ([]byte, []int)
func (*QueryGroupRequest) GetID ¶ added in v0.9.1
func (m *QueryGroupRequest) GetID() GroupID
func (*QueryGroupRequest) Marshal ¶ added in v0.9.1
func (m *QueryGroupRequest) Marshal() (dAtA []byte, err error)
func (*QueryGroupRequest) MarshalTo ¶ added in v0.9.1
func (m *QueryGroupRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryGroupRequest) MarshalToSizedBuffer ¶ added in v0.9.1
func (m *QueryGroupRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryGroupRequest) ProtoMessage ¶ added in v0.9.1
func (*QueryGroupRequest) ProtoMessage()
func (*QueryGroupRequest) Reset ¶ added in v0.9.1
func (m *QueryGroupRequest) Reset()
func (*QueryGroupRequest) Size ¶ added in v0.9.1
func (m *QueryGroupRequest) Size() (n int)
func (*QueryGroupRequest) String ¶ added in v0.9.1
func (m *QueryGroupRequest) String() string
func (*QueryGroupRequest) Unmarshal ¶ added in v0.9.1
func (m *QueryGroupRequest) Unmarshal(dAtA []byte) error
func (*QueryGroupRequest) XXX_DiscardUnknown ¶ added in v0.9.1
func (m *QueryGroupRequest) XXX_DiscardUnknown()
func (*QueryGroupRequest) XXX_Marshal ¶ added in v0.9.1
func (m *QueryGroupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryGroupRequest) XXX_Merge ¶ added in v0.9.1
func (m *QueryGroupRequest) XXX_Merge(src proto.Message)
func (*QueryGroupRequest) XXX_Size ¶ added in v0.9.1
func (m *QueryGroupRequest) XXX_Size() int
func (*QueryGroupRequest) XXX_Unmarshal ¶ added in v0.9.1
func (m *QueryGroupRequest) XXX_Unmarshal(b []byte) error
type QueryGroupResponse ¶ added in v0.9.1
type QueryGroupResponse struct {
Group Group `protobuf:"bytes,1,opt,name=group,proto3" json:"group"`
}
QueryGroupResponse is response type for the Query/Group RPC method
func (*QueryGroupResponse) Descriptor ¶ added in v0.9.1
func (*QueryGroupResponse) Descriptor() ([]byte, []int)
func (*QueryGroupResponse) GetGroup ¶ added in v0.9.1
func (m *QueryGroupResponse) GetGroup() Group
func (*QueryGroupResponse) Marshal ¶ added in v0.9.1
func (m *QueryGroupResponse) Marshal() (dAtA []byte, err error)
func (*QueryGroupResponse) MarshalTo ¶ added in v0.9.1
func (m *QueryGroupResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryGroupResponse) MarshalToSizedBuffer ¶ added in v0.9.1
func (m *QueryGroupResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryGroupResponse) ProtoMessage ¶ added in v0.9.1
func (*QueryGroupResponse) ProtoMessage()
func (*QueryGroupResponse) Reset ¶ added in v0.9.1
func (m *QueryGroupResponse) Reset()
func (*QueryGroupResponse) Size ¶ added in v0.9.1
func (m *QueryGroupResponse) Size() (n int)
func (*QueryGroupResponse) String ¶ added in v0.9.1
func (m *QueryGroupResponse) String() string
func (*QueryGroupResponse) Unmarshal ¶ added in v0.9.1
func (m *QueryGroupResponse) Unmarshal(dAtA []byte) error
func (*QueryGroupResponse) XXX_DiscardUnknown ¶ added in v0.9.1
func (m *QueryGroupResponse) XXX_DiscardUnknown()
func (*QueryGroupResponse) XXX_Marshal ¶ added in v0.9.1
func (m *QueryGroupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryGroupResponse) XXX_Merge ¶ added in v0.9.1
func (m *QueryGroupResponse) XXX_Merge(src proto.Message)
func (*QueryGroupResponse) XXX_Size ¶ added in v0.9.1
func (m *QueryGroupResponse) XXX_Size() int
func (*QueryGroupResponse) XXX_Unmarshal ¶ added in v0.9.1
func (m *QueryGroupResponse) XXX_Unmarshal(b []byte) error
type QueryServer ¶ added in v0.9.1
type QueryServer interface { // Deployments queries deployments Deployments(context.Context, *QueryDeploymentsRequest) (*QueryDeploymentsResponse, error) // Deployment queries deployment details Deployment(context.Context, *QueryDeploymentRequest) (*QueryDeploymentResponse, error) // Group queries group details Group(context.Context, *QueryGroupRequest) (*QueryGroupResponse, error) }
QueryServer is the server API for Query service.
type Resource ¶
type Resource struct { Resources types.ResourceUnits `protobuf:"bytes,1,opt,name=resources,proto3" json:"unit" yaml:"unit"` Count uint32 `protobuf:"varint,2,opt,name=count,proto3" json:"count" yaml:"count"` Price types1.Coin `protobuf:"bytes,3,opt,name=price,proto3" json:"price" yaml:"price"` }
Resource stores unit, total count and price of resource
func (*Resource) Descriptor ¶ added in v0.9.1
func (*Resource) GetResources ¶ added in v0.9.1
func (m *Resource) GetResources() types.ResourceUnits
func (*Resource) MarshalToSizedBuffer ¶ added in v0.9.1
func (*Resource) ProtoMessage ¶ added in v0.9.1
func (*Resource) ProtoMessage()
func (*Resource) XXX_DiscardUnknown ¶ added in v0.9.1
func (m *Resource) XXX_DiscardUnknown()
func (*Resource) XXX_Marshal ¶ added in v0.9.1
func (*Resource) XXX_Unmarshal ¶ added in v0.9.1
type UnimplementedQueryServer ¶ added in v0.9.1
type UnimplementedQueryServer struct { }
UnimplementedQueryServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueryServer) Deployment ¶ added in v0.9.1
func (*UnimplementedQueryServer) Deployment(ctx context.Context, req *QueryDeploymentRequest) (*QueryDeploymentResponse, error)
func (*UnimplementedQueryServer) Deployments ¶ added in v0.9.1
func (*UnimplementedQueryServer) Deployments(ctx context.Context, req *QueryDeploymentsRequest) (*QueryDeploymentsResponse, error)
func (*UnimplementedQueryServer) Group ¶ added in v0.9.1
func (*UnimplementedQueryServer) Group(ctx context.Context, req *QueryGroupRequest) (*QueryGroupResponse, error)