authz

package
v0.0.4 Latest Latest
Warning

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

Go to latest
Published: May 24, 2021 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Overview

Package authz is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source
const (
	// ModuleName is the module name constant used in many places
	ModuleName = "authz"

	// RouterKey is the message route for authz
	RouterKey = ModuleName

	// QuerierRoute is the querier route for authz
	QuerierRoute = ModuleName
)

Variables

View Source
var (
	ErrInvalidLengthAuthz        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAuthz          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAuthz = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthEvent        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvent          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvent = 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 (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidExpirationTime = sdkerrors.Register(ModuleName, 3, "expiration time of authorization should be more than current time")
)

x/authz module sentinel errors

Functions

func MsgServiceDesc

func MsgServiceDesc() *grpc.ServiceDesc

MsgServiceDesc return ServiceDesc for Msg server

func RegisterInterfaces

func RegisterInterfaces(registry types.InterfaceRegistry)

RegisterInterfaces registers the interfaces types with the interface registry

func RegisterMsgServer

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler

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

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

func RegisterQueryHandlerClient

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

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

func RegisterQueryHandlerFromEndpoint

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

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

func RegisterQueryHandlerServer

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

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

func RegisterQueryServer

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func ValidateGenesis

func ValidateGenesis(data GenesisState) error

ValidateGenesis check the given genesis state has no integrity issues

Types

type AcceptResponse

type AcceptResponse struct {
	// If Accept=true, the controller can accept and authorization and handle the update.
	Accept bool
	// If Delete=true, the controller must delete the authorization object and release
	// storage resources.
	Delete bool
	// Controller, who is calling Authorization.Accept must check if `Updated != nil`. If yes,
	// it must use the updated version and handle the update on the storage level.
	Updated Authorization
}

AcceptResponse instruments the controller of an authz message if the request is accepted and if it should be updated or deleted.

type AccountKeeper

type AccountKeeper interface {
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
}

AccountKeeper defines the expected account keeper (noalias)

type Authorization

type Authorization interface {
	proto.Message

	// MsgTypeURL returns the fully-qualified Msg service method URL (as described in ADR 031),
	// which will process and accept or reject a request.
	MsgTypeURL() string

	// Accept determines whether this grant permits the provided sdk.Msg to be performed,
	// and if so provides an upgraded authorization instance.
	Accept(ctx sdk.Context, msg sdk.Msg) (AcceptResponse, error)

	// ValidateBasic does a simple validation check that
	// doesn't require access to any other information.
	ValidateBasic() error
}

Authorization represents the interface of various Authorization types implemented by other modules.

type BankKeeper

type BankKeeper interface {
	SpendableCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	IsSendEnabledCoins(ctx sdk.Context, coins ...sdk.Coin) error
}

BankKeeper defines the expected interface needed to retrieve account balances.

type EventGrant

type EventGrant struct {
	// Msg type URL for which an autorization is granted
	MsgTypeUrl string `protobuf:"bytes,2,opt,name=msg_type_url,json=msgTypeUrl,proto3" json:"msg_type_url,omitempty"`
	// Granter account address
	Granter string `protobuf:"bytes,3,opt,name=granter,proto3" json:"granter,omitempty"`
	// Grantee account address
	Grantee string `protobuf:"bytes,4,opt,name=grantee,proto3" json:"grantee,omitempty"`
}

EventGrant is emitted on Msg/Grant

func (*EventGrant) Descriptor

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

func (*EventGrant) GetGrantee

func (m *EventGrant) GetGrantee() string

func (*EventGrant) GetGranter

func (m *EventGrant) GetGranter() string

func (*EventGrant) GetMsgTypeUrl

func (m *EventGrant) GetMsgTypeUrl() string

func (*EventGrant) Marshal

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

func (*EventGrant) MarshalTo

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

func (*EventGrant) MarshalToSizedBuffer

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

func (*EventGrant) ProtoMessage

func (*EventGrant) ProtoMessage()

func (*EventGrant) Reset

func (m *EventGrant) Reset()

func (*EventGrant) Size

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

func (*EventGrant) String

func (m *EventGrant) String() string

func (*EventGrant) Unmarshal

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

func (*EventGrant) XXX_DiscardUnknown

func (m *EventGrant) XXX_DiscardUnknown()

func (*EventGrant) XXX_Marshal

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

func (*EventGrant) XXX_Merge

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

func (*EventGrant) XXX_Size

func (m *EventGrant) XXX_Size() int

func (*EventGrant) XXX_Unmarshal

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

type EventRevoke

type EventRevoke struct {
	// Msg type URL for which an autorization is revoked
	MsgTypeUrl string `protobuf:"bytes,2,opt,name=msg_type_url,json=msgTypeUrl,proto3" json:"msg_type_url,omitempty"`
	// Granter account address
	Granter string `protobuf:"bytes,3,opt,name=granter,proto3" json:"granter,omitempty"`
	// Grantee account address
	Grantee string `protobuf:"bytes,4,opt,name=grantee,proto3" json:"grantee,omitempty"`
}

EventRevoke is emitted on Msg/Revoke

func (*EventRevoke) Descriptor

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

func (*EventRevoke) GetGrantee

func (m *EventRevoke) GetGrantee() string

func (*EventRevoke) GetGranter

func (m *EventRevoke) GetGranter() string

func (*EventRevoke) GetMsgTypeUrl

func (m *EventRevoke) GetMsgTypeUrl() string

func (*EventRevoke) Marshal

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

func (*EventRevoke) MarshalTo

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

func (*EventRevoke) MarshalToSizedBuffer

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

func (*EventRevoke) ProtoMessage

func (*EventRevoke) ProtoMessage()

func (*EventRevoke) Reset

func (m *EventRevoke) Reset()

func (*EventRevoke) Size

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

func (*EventRevoke) String

func (m *EventRevoke) String() string

func (*EventRevoke) Unmarshal

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

func (*EventRevoke) XXX_DiscardUnknown

func (m *EventRevoke) XXX_DiscardUnknown()

func (*EventRevoke) XXX_Marshal

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

func (*EventRevoke) XXX_Merge

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

func (*EventRevoke) XXX_Size

func (m *EventRevoke) XXX_Size() int

func (*EventRevoke) XXX_Unmarshal

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

type GenericAuthorization

type GenericAuthorization struct {
	// Msg, identified by it's type URL, to grant unrestricted permissions to execute
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
}

GenericAuthorization gives the grantee unrestricted permissions to execute the provided method on behalf of the granter's account.

func NewGenericAuthorization

func NewGenericAuthorization(msgTypeURL string) *GenericAuthorization

NewGenericAuthorization creates a new GenericAuthorization object.

func (GenericAuthorization) Accept

func (a GenericAuthorization) Accept(ctx sdk.Context, msg sdk.Msg) (AcceptResponse, error)

Accept implements Authorization.Accept.

func (*GenericAuthorization) Descriptor

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

func (*GenericAuthorization) Marshal

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

func (*GenericAuthorization) MarshalTo

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

func (*GenericAuthorization) MarshalToSizedBuffer

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

func (GenericAuthorization) MsgTypeURL

func (a GenericAuthorization) MsgTypeURL() string

MsgTypeURL implements Authorization.MsgTypeURL.

func (*GenericAuthorization) ProtoMessage

func (*GenericAuthorization) ProtoMessage()

func (*GenericAuthorization) Reset

func (m *GenericAuthorization) Reset()

func (*GenericAuthorization) Size

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

func (*GenericAuthorization) String

func (m *GenericAuthorization) String() string

func (*GenericAuthorization) Unmarshal

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

func (GenericAuthorization) ValidateBasic

func (a GenericAuthorization) ValidateBasic() error

ValidateBasic implements Authorization.ValidateBasic.

func (*GenericAuthorization) XXX_DiscardUnknown

func (m *GenericAuthorization) XXX_DiscardUnknown()

func (*GenericAuthorization) XXX_Marshal

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

func (*GenericAuthorization) XXX_Merge

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

func (*GenericAuthorization) XXX_Size

func (m *GenericAuthorization) XXX_Size() int

func (*GenericAuthorization) XXX_Unmarshal

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

type GenesisState

type GenesisState struct {
	Authorization []GrantAuthorization `protobuf:"bytes,1,rep,name=authorization,proto3" json:"authorization"`
}

GenesisState defines the authz module's genesis state.

func DefaultGenesisState

func DefaultGenesisState() *GenesisState

DefaultGenesisState - Return a default genesis state

func NewGenesisState

func NewGenesisState(entries []GrantAuthorization) *GenesisState

NewGenesisState creates new GenesisState object

func (*GenesisState) Descriptor

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

func (*GenesisState) GetAuthorization

func (m *GenesisState) GetAuthorization() []GrantAuthorization

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

func (data GenesisState) UnpackInterfaces(unpacker cdctypes.AnyUnpacker) error

UnpackInterfaces implements UnpackInterfacesMessage.UnpackInterfaces

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 Grant

type Grant struct {
	Authorization *types.Any `protobuf:"bytes,1,opt,name=authorization,proto3" json:"authorization,omitempty"`
	Expiration    time.Time  `protobuf:"bytes,2,opt,name=expiration,proto3,stdtime" json:"expiration"`
}

Grant gives permissions to execute the provide method with expiration time.

func NewGrant

func NewGrant(a Authorization, expiration time.Time) (Grant, error)

NewGrant returns new Grant

func (*Grant) Descriptor

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

func (Grant) GetAuthorization

func (g Grant) GetAuthorization() Authorization

GetAuthorization returns the cached value from the Grant.Authorization if present.

func (*Grant) Marshal

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

func (*Grant) MarshalTo

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

func (*Grant) MarshalToSizedBuffer

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

func (*Grant) ProtoMessage

func (*Grant) ProtoMessage()

func (*Grant) Reset

func (m *Grant) Reset()

func (*Grant) Size

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

func (*Grant) String

func (m *Grant) String() string

func (*Grant) Unmarshal

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

func (Grant) UnpackInterfaces

func (g Grant) UnpackInterfaces(unpacker cdctypes.AnyUnpacker) error

UnpackInterfaces implements UnpackInterfacesMessage.UnpackInterfaces

func (Grant) ValidateBasic

func (g Grant) ValidateBasic() error

func (*Grant) XXX_DiscardUnknown

func (m *Grant) XXX_DiscardUnknown()

func (*Grant) XXX_Marshal

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

func (*Grant) XXX_Merge

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

func (*Grant) XXX_Size

func (m *Grant) XXX_Size() int

func (*Grant) XXX_Unmarshal

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

type GrantAuthorization

type GrantAuthorization struct {
	Granter       string     `protobuf:"bytes,1,opt,name=granter,proto3" json:"granter,omitempty"`
	Grantee       string     `protobuf:"bytes,2,opt,name=grantee,proto3" json:"grantee,omitempty"`
	Authorization *types.Any `protobuf:"bytes,3,opt,name=authorization,proto3" json:"authorization,omitempty"`
	Expiration    time.Time  `protobuf:"bytes,4,opt,name=expiration,proto3,stdtime" json:"expiration"`
}

GrantAuthorization defines the GenesisState/GrantAuthorization type.

func (*GrantAuthorization) Descriptor

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

func (*GrantAuthorization) GetAuthorization

func (m *GrantAuthorization) GetAuthorization() *types.Any

func (*GrantAuthorization) GetExpiration

func (m *GrantAuthorization) GetExpiration() time.Time

func (*GrantAuthorization) GetGrantee

func (m *GrantAuthorization) GetGrantee() string

func (*GrantAuthorization) GetGranter

func (m *GrantAuthorization) GetGranter() string

func (*GrantAuthorization) Marshal

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

func (*GrantAuthorization) MarshalTo

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

func (*GrantAuthorization) MarshalToSizedBuffer

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

func (*GrantAuthorization) ProtoMessage

func (*GrantAuthorization) ProtoMessage()

func (*GrantAuthorization) Reset

func (m *GrantAuthorization) Reset()

func (*GrantAuthorization) Size

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

func (*GrantAuthorization) String

func (m *GrantAuthorization) String() string

func (*GrantAuthorization) Unmarshal

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

func (GrantAuthorization) UnpackInterfaces

func (msg GrantAuthorization) UnpackInterfaces(unpacker cdctypes.AnyUnpacker) error

UnpackInterfaces implements UnpackInterfacesMessage.UnpackInterfaces

func (*GrantAuthorization) XXX_DiscardUnknown

func (m *GrantAuthorization) XXX_DiscardUnknown()

func (*GrantAuthorization) XXX_Marshal

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

func (*GrantAuthorization) XXX_Merge

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

func (*GrantAuthorization) XXX_Size

func (m *GrantAuthorization) XXX_Size() int

func (*GrantAuthorization) XXX_Unmarshal

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

type MsgClient

type MsgClient interface {
	// Grant grants the provided authorization to the grantee on the granter's
	// account with the provided expiration time.
	Grant(ctx context.Context, in *MsgGrant, opts ...grpc.CallOption) (*MsgGrantResponse, error)
	// Exec attempts to execute the provided messages using
	// authorizations granted to the grantee. Each message should have only
	// one signer corresponding to the granter of the authorization.
	Exec(ctx context.Context, in *MsgExec, opts ...grpc.CallOption) (*MsgExecResponse, error)
	// Revoke revokes any authorization corresponding to the provided method name on the
	// granter's account that has been granted to the grantee.
	Revoke(ctx context.Context, in *MsgRevoke, opts ...grpc.CallOption) (*MsgRevokeResponse, error)
}

MsgClient is the client API for Msg service.

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

func NewMsgClient

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgExec

type MsgExec struct {
	Grantee string `protobuf:"bytes,1,opt,name=grantee,proto3" json:"grantee,omitempty"`
	// Authorization Msg requests to execute. Each msg must implement Authorization interface
	// The x/authz will try to find a grant matching (msg.signers[0], grantee, MsgTypeURL(msg))
	// triple and validate it.
	Msgs []*types1.Any `protobuf:"bytes,2,rep,name=msgs,proto3" json:"msgs,omitempty"`
}

MsgExec attempts to execute the provided messages using authorizations granted to the grantee. Each message should have only one signer corresponding to the granter of the authorization.

func NewMsgExec

func NewMsgExec(grantee sdk.AccAddress, msgs []sdk.Msg) MsgExec

NewMsgExec creates a new MsgExecAuthorized

func (*MsgExec) Descriptor

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

func (MsgExec) GetMessages

func (msg MsgExec) GetMessages() ([]sdk.Msg, error)

GetMessages returns the cache values from the MsgExecAuthorized.Msgs if present.

func (MsgExec) GetSigners

func (msg MsgExec) GetSigners() []sdk.AccAddress

GetSigners implements Msg

func (*MsgExec) Marshal

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

func (*MsgExec) MarshalTo

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

func (*MsgExec) MarshalToSizedBuffer

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

func (*MsgExec) ProtoMessage

func (*MsgExec) ProtoMessage()

func (*MsgExec) Reset

func (m *MsgExec) Reset()

func (*MsgExec) Size

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

func (*MsgExec) String

func (m *MsgExec) String() string

func (*MsgExec) Unmarshal

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

func (MsgExec) UnpackInterfaces

func (msg MsgExec) UnpackInterfaces(unpacker cdctypes.AnyUnpacker) error

UnpackInterfaces implements UnpackInterfacesMessage.UnpackInterfaces

func (MsgExec) ValidateBasic

func (msg MsgExec) ValidateBasic() error

ValidateBasic implements Msg

func (*MsgExec) XXX_DiscardUnknown

func (m *MsgExec) XXX_DiscardUnknown()

func (*MsgExec) XXX_Marshal

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

func (*MsgExec) XXX_Merge

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

func (*MsgExec) XXX_Size

func (m *MsgExec) XXX_Size() int

func (*MsgExec) XXX_Unmarshal

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

type MsgExecResponse

type MsgExecResponse struct {
	Result *types.Result `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
}

MsgExecResponse defines the Msg/MsgExecResponse response type.

func (*MsgExecResponse) Descriptor

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

func (*MsgExecResponse) Marshal

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

func (*MsgExecResponse) MarshalTo

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

func (*MsgExecResponse) MarshalToSizedBuffer

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

func (*MsgExecResponse) ProtoMessage

func (*MsgExecResponse) ProtoMessage()

func (*MsgExecResponse) Reset

func (m *MsgExecResponse) Reset()

func (*MsgExecResponse) Size

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

func (*MsgExecResponse) String

func (m *MsgExecResponse) String() string

func (*MsgExecResponse) Unmarshal

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

func (*MsgExecResponse) XXX_DiscardUnknown

func (m *MsgExecResponse) XXX_DiscardUnknown()

func (*MsgExecResponse) XXX_Marshal

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

func (*MsgExecResponse) XXX_Merge

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

func (*MsgExecResponse) XXX_Size

func (m *MsgExecResponse) XXX_Size() int

func (*MsgExecResponse) XXX_Unmarshal

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

type MsgGrant

type MsgGrant struct {
	Granter string `protobuf:"bytes,1,opt,name=granter,proto3" json:"granter,omitempty"`
	Grantee string `protobuf:"bytes,2,opt,name=grantee,proto3" json:"grantee,omitempty"`
	Grant   Grant  `protobuf:"bytes,3,opt,name=grant,proto3" json:"grant"`
}

MsgGrant grants the provided authorization to the grantee on the granter's account with the provided expiration time.

func NewMsgGrant

func NewMsgGrant(granter sdk.AccAddress, grantee sdk.AccAddress, a Authorization, expiration time.Time) (*MsgGrant, error)

NewMsgGrant creates a new MsgGrant

func (*MsgGrant) Descriptor

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

func (*MsgGrant) GetAuthorization

func (msg *MsgGrant) GetAuthorization() Authorization

GetAuthorization returns the cache value from the MsgGrant.Authorization if present.

func (MsgGrant) GetSigners

func (msg MsgGrant) GetSigners() []sdk.AccAddress

GetSigners implements Msg

func (*MsgGrant) Marshal

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

func (*MsgGrant) MarshalTo

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

func (*MsgGrant) MarshalToSizedBuffer

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

func (*MsgGrant) ProtoMessage

func (*MsgGrant) ProtoMessage()

func (*MsgGrant) Reset

func (m *MsgGrant) Reset()

func (*MsgGrant) SetAuthorization

func (msg *MsgGrant) SetAuthorization(a Authorization) error

SetAuthorization converts Authorization to any and adds it to MsgGrant.Authorization.

func (*MsgGrant) Size

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

func (*MsgGrant) String

func (m *MsgGrant) String() string

func (*MsgGrant) Unmarshal

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

func (MsgGrant) UnpackInterfaces

func (msg MsgGrant) UnpackInterfaces(unpacker cdctypes.AnyUnpacker) error

UnpackInterfaces implements UnpackInterfacesMessage.UnpackInterfaces

func (MsgGrant) ValidateBasic

func (msg MsgGrant) ValidateBasic() error

ValidateBasic implements Msg

func (*MsgGrant) XXX_DiscardUnknown

func (m *MsgGrant) XXX_DiscardUnknown()

func (*MsgGrant) XXX_Marshal

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

func (*MsgGrant) XXX_Merge

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

func (*MsgGrant) XXX_Size

func (m *MsgGrant) XXX_Size() int

func (*MsgGrant) XXX_Unmarshal

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

type MsgGrantResponse

type MsgGrantResponse struct {
}

MsgGrantResponse defines the Msg/MsgGrant response type.

func (*MsgGrantResponse) Descriptor

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

func (*MsgGrantResponse) Marshal

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

func (*MsgGrantResponse) MarshalTo

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

func (*MsgGrantResponse) MarshalToSizedBuffer

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

func (*MsgGrantResponse) ProtoMessage

func (*MsgGrantResponse) ProtoMessage()

func (*MsgGrantResponse) Reset

func (m *MsgGrantResponse) Reset()

func (*MsgGrantResponse) Size

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

func (*MsgGrantResponse) String

func (m *MsgGrantResponse) String() string

func (*MsgGrantResponse) Unmarshal

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

func (*MsgGrantResponse) XXX_DiscardUnknown

func (m *MsgGrantResponse) XXX_DiscardUnknown()

func (*MsgGrantResponse) XXX_Marshal

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

func (*MsgGrantResponse) XXX_Merge

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

func (*MsgGrantResponse) XXX_Size

func (m *MsgGrantResponse) XXX_Size() int

func (*MsgGrantResponse) XXX_Unmarshal

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

type MsgRevoke

type MsgRevoke struct {
	Granter    string `protobuf:"bytes,1,opt,name=granter,proto3" json:"granter,omitempty"`
	Grantee    string `protobuf:"bytes,2,opt,name=grantee,proto3" json:"grantee,omitempty"`
	MsgTypeUrl string `protobuf:"bytes,3,opt,name=msg_type_url,json=msgTypeUrl,proto3" json:"msg_type_url,omitempty"`
}

MsgRevoke revokes any authorization with the provided sdk.Msg type on the granter's account with that has been granted to the grantee.

func NewMsgRevoke

func NewMsgRevoke(granter sdk.AccAddress, grantee sdk.AccAddress, msgTypeURL string) MsgRevoke

NewMsgRevoke creates a new MsgRevoke

func (*MsgRevoke) Descriptor

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

func (MsgRevoke) GetSigners

func (msg MsgRevoke) GetSigners() []sdk.AccAddress

GetSigners implements Msg

func (*MsgRevoke) Marshal

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

func (*MsgRevoke) MarshalTo

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

func (*MsgRevoke) MarshalToSizedBuffer

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

func (*MsgRevoke) ProtoMessage

func (*MsgRevoke) ProtoMessage()

func (*MsgRevoke) Reset

func (m *MsgRevoke) Reset()

func (*MsgRevoke) Size

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

func (*MsgRevoke) String

func (m *MsgRevoke) String() string

func (*MsgRevoke) Unmarshal

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

func (MsgRevoke) ValidateBasic

func (msg MsgRevoke) ValidateBasic() error

ValidateBasic implements MsgRequest.ValidateBasic

func (*MsgRevoke) XXX_DiscardUnknown

func (m *MsgRevoke) XXX_DiscardUnknown()

func (*MsgRevoke) XXX_Marshal

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

func (*MsgRevoke) XXX_Merge

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

func (*MsgRevoke) XXX_Size

func (m *MsgRevoke) XXX_Size() int

func (*MsgRevoke) XXX_Unmarshal

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

type MsgRevokeResponse

type MsgRevokeResponse struct {
}

MsgRevokeResponse defines the Msg/MsgRevokeResponse response type.

func (*MsgRevokeResponse) Descriptor

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

func (*MsgRevokeResponse) Marshal

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

func (*MsgRevokeResponse) MarshalTo

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

func (*MsgRevokeResponse) MarshalToSizedBuffer

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

func (*MsgRevokeResponse) ProtoMessage

func (*MsgRevokeResponse) ProtoMessage()

func (*MsgRevokeResponse) Reset

func (m *MsgRevokeResponse) Reset()

func (*MsgRevokeResponse) Size

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

func (*MsgRevokeResponse) String

func (m *MsgRevokeResponse) String() string

func (*MsgRevokeResponse) Unmarshal

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

func (*MsgRevokeResponse) XXX_DiscardUnknown

func (m *MsgRevokeResponse) XXX_DiscardUnknown()

func (*MsgRevokeResponse) XXX_Marshal

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

func (*MsgRevokeResponse) XXX_Merge

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

func (*MsgRevokeResponse) XXX_Size

func (m *MsgRevokeResponse) XXX_Size() int

func (*MsgRevokeResponse) XXX_Unmarshal

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

type MsgServer

type MsgServer interface {
	// Grant grants the provided authorization to the grantee on the granter's
	// account with the provided expiration time.
	Grant(context.Context, *MsgGrant) (*MsgGrantResponse, error)
	// Exec attempts to execute the provided messages using
	// authorizations granted to the grantee. Each message should have only
	// one signer corresponding to the granter of the authorization.
	Exec(context.Context, *MsgExec) (*MsgExecResponse, error)
	// Revoke revokes any authorization corresponding to the provided method name on the
	// granter's account that has been granted to the grantee.
	Revoke(context.Context, *MsgRevoke) (*MsgRevokeResponse, error)
}

MsgServer is the server API for Msg service.

type QueryClient

type QueryClient interface {
	// Returns list of `Authorization`, granted to the grantee by the granter.
	Grants(ctx context.Context, in *QueryGrantsRequest, opts ...grpc.CallOption) (*QueryGrantsResponse, error)
}

QueryClient is the client API for Query service.

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

func NewQueryClient

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryGrantsRequest

type QueryGrantsRequest struct {
	Granter string `protobuf:"bytes,1,opt,name=granter,proto3" json:"granter,omitempty"`
	Grantee string `protobuf:"bytes,2,opt,name=grantee,proto3" json:"grantee,omitempty"`
	// Optional, msg_type_url, when set, will query only grants matching given msg type.
	MsgTypeUrl string `protobuf:"bytes,3,opt,name=msg_type_url,json=msgTypeUrl,proto3" json:"msg_type_url,omitempty"`
	// pagination defines an pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,4,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryGrantsRequest is the request type for the Query/Grants RPC method.

func (*QueryGrantsRequest) Descriptor

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

func (*QueryGrantsRequest) GetGrantee

func (m *QueryGrantsRequest) GetGrantee() string

func (*QueryGrantsRequest) GetGranter

func (m *QueryGrantsRequest) GetGranter() string

func (*QueryGrantsRequest) GetMsgTypeUrl

func (m *QueryGrantsRequest) GetMsgTypeUrl() string

func (*QueryGrantsRequest) GetPagination

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

func (*QueryGrantsRequest) Marshal

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

func (*QueryGrantsRequest) MarshalTo

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

func (*QueryGrantsRequest) MarshalToSizedBuffer

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

func (*QueryGrantsRequest) ProtoMessage

func (*QueryGrantsRequest) ProtoMessage()

func (*QueryGrantsRequest) Reset

func (m *QueryGrantsRequest) Reset()

func (*QueryGrantsRequest) Size

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

func (*QueryGrantsRequest) String

func (m *QueryGrantsRequest) String() string

func (*QueryGrantsRequest) Unmarshal

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

func (*QueryGrantsRequest) XXX_DiscardUnknown

func (m *QueryGrantsRequest) XXX_DiscardUnknown()

func (*QueryGrantsRequest) XXX_Marshal

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

func (*QueryGrantsRequest) XXX_Merge

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

func (*QueryGrantsRequest) XXX_Size

func (m *QueryGrantsRequest) XXX_Size() int

func (*QueryGrantsRequest) XXX_Unmarshal

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

type QueryGrantsResponse

type QueryGrantsResponse struct {
	// authorizations is a list of grants granted for grantee by granter.
	Grants []*Grant `protobuf:"bytes,1,rep,name=grants,proto3" json:"grants,omitempty"`
	// pagination defines an pagination for the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryGrantsResponse is the response type for the Query/Authorizations RPC method.

func (*QueryGrantsResponse) Descriptor

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

func (*QueryGrantsResponse) GetGrants

func (m *QueryGrantsResponse) GetGrants() []*Grant

func (*QueryGrantsResponse) GetPagination

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

func (*QueryGrantsResponse) Marshal

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

func (*QueryGrantsResponse) MarshalTo

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

func (*QueryGrantsResponse) MarshalToSizedBuffer

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

func (*QueryGrantsResponse) ProtoMessage

func (*QueryGrantsResponse) ProtoMessage()

func (*QueryGrantsResponse) Reset

func (m *QueryGrantsResponse) Reset()

func (*QueryGrantsResponse) Size

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

func (*QueryGrantsResponse) String

func (m *QueryGrantsResponse) String() string

func (*QueryGrantsResponse) Unmarshal

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

func (*QueryGrantsResponse) XXX_DiscardUnknown

func (m *QueryGrantsResponse) XXX_DiscardUnknown()

func (*QueryGrantsResponse) XXX_Marshal

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

func (*QueryGrantsResponse) XXX_Merge

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

func (*QueryGrantsResponse) XXX_Size

func (m *QueryGrantsResponse) XXX_Size() int

func (*QueryGrantsResponse) XXX_Unmarshal

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

type QueryServer

type QueryServer interface {
	// Returns list of `Authorization`, granted to the grantee by the granter.
	Grants(context.Context, *QueryGrantsRequest) (*QueryGrantsResponse, error)
}

QueryServer is the server API for Query service.

type UnimplementedMsgServer

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) Exec

func (*UnimplementedMsgServer) Grant

func (*UnimplementedMsgServer) Revoke

type UnimplementedQueryServer

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Grants

Directories

Path Synopsis
client
cli

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL