Documentation ¶
Overview ¶
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Index ¶
- Constants
- Variables
- func RegisterMsgServer(s grpc.ServiceRegistrar, srv MsgServer)
- func RegisterQueryServer(s grpc.ServiceRegistrar, srv QueryServer)
- type AccountResponse
- type AccountsResponse
- func (*AccountsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AccountsResponse) GetAccounts() []*GenesisAccountPermissions
- func (x *AccountsResponse) GetPagination() *v1beta1.PageResponse
- func (*AccountsResponse) ProtoMessage()
- func (x *AccountsResponse) ProtoReflect() protoreflect.Message
- func (x *AccountsResponse) Reset()
- func (x *AccountsResponse) String() string
- type DisabledListResponse
- func (*DisabledListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DisabledListResponse) GetDisabledList() []string
- func (*DisabledListResponse) ProtoMessage()
- func (x *DisabledListResponse) ProtoReflect() protoreflect.Message
- func (x *DisabledListResponse) Reset()
- func (x *DisabledListResponse) String() string
- type GenesisAccountPermissions
- func (*GenesisAccountPermissions) Descriptor() ([]byte, []int)deprecated
- func (x *GenesisAccountPermissions) GetAddress() string
- func (x *GenesisAccountPermissions) GetPermissions() *Permissions
- func (*GenesisAccountPermissions) ProtoMessage()
- func (x *GenesisAccountPermissions) ProtoReflect() protoreflect.Message
- func (x *GenesisAccountPermissions) Reset()
- func (x *GenesisAccountPermissions) String() string
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)deprecated
- func (x *GenesisState) GetAccountPermissions() []*GenesisAccountPermissions
- func (x *GenesisState) GetDisabledTypeUrls() []string
- func (*GenesisState) ProtoMessage()
- func (x *GenesisState) ProtoReflect() protoreflect.Message
- func (x *GenesisState) Reset()
- func (x *GenesisState) String() string
- type MsgAuthorizeCircuitBreaker
- func (*MsgAuthorizeCircuitBreaker) Descriptor() ([]byte, []int)deprecated
- func (x *MsgAuthorizeCircuitBreaker) GetGrantee() string
- func (x *MsgAuthorizeCircuitBreaker) GetGranter() string
- func (x *MsgAuthorizeCircuitBreaker) GetPermissions() *Permissions
- func (*MsgAuthorizeCircuitBreaker) ProtoMessage()
- func (x *MsgAuthorizeCircuitBreaker) ProtoReflect() protoreflect.Message
- func (x *MsgAuthorizeCircuitBreaker) Reset()
- func (x *MsgAuthorizeCircuitBreaker) String() string
- type MsgAuthorizeCircuitBreakerResponse
- func (*MsgAuthorizeCircuitBreakerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MsgAuthorizeCircuitBreakerResponse) GetSuccess() bool
- func (*MsgAuthorizeCircuitBreakerResponse) ProtoMessage()
- func (x *MsgAuthorizeCircuitBreakerResponse) ProtoReflect() protoreflect.Message
- func (x *MsgAuthorizeCircuitBreakerResponse) Reset()
- func (x *MsgAuthorizeCircuitBreakerResponse) String() string
- type MsgClient
- type MsgResetCircuitBreaker
- func (*MsgResetCircuitBreaker) Descriptor() ([]byte, []int)deprecated
- func (x *MsgResetCircuitBreaker) GetAuthority() string
- func (x *MsgResetCircuitBreaker) GetMsgTypeUrls() []string
- func (*MsgResetCircuitBreaker) ProtoMessage()
- func (x *MsgResetCircuitBreaker) ProtoReflect() protoreflect.Message
- func (x *MsgResetCircuitBreaker) Reset()
- func (x *MsgResetCircuitBreaker) String() string
- type MsgResetCircuitBreakerResponse
- func (*MsgResetCircuitBreakerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MsgResetCircuitBreakerResponse) GetSuccess() bool
- func (*MsgResetCircuitBreakerResponse) ProtoMessage()
- func (x *MsgResetCircuitBreakerResponse) ProtoReflect() protoreflect.Message
- func (x *MsgResetCircuitBreakerResponse) Reset()
- func (x *MsgResetCircuitBreakerResponse) String() string
- type MsgServer
- type MsgTripCircuitBreaker
- func (*MsgTripCircuitBreaker) Descriptor() ([]byte, []int)deprecated
- func (x *MsgTripCircuitBreaker) GetAuthority() string
- func (x *MsgTripCircuitBreaker) GetMsgTypeUrls() []string
- func (*MsgTripCircuitBreaker) ProtoMessage()
- func (x *MsgTripCircuitBreaker) ProtoReflect() protoreflect.Message
- func (x *MsgTripCircuitBreaker) Reset()
- func (x *MsgTripCircuitBreaker) String() string
- type MsgTripCircuitBreakerResponse
- func (*MsgTripCircuitBreakerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MsgTripCircuitBreakerResponse) GetSuccess() bool
- func (*MsgTripCircuitBreakerResponse) ProtoMessage()
- func (x *MsgTripCircuitBreakerResponse) ProtoReflect() protoreflect.Message
- func (x *MsgTripCircuitBreakerResponse) Reset()
- func (x *MsgTripCircuitBreakerResponse) String() string
- type Permissions
- func (*Permissions) Descriptor() ([]byte, []int)deprecated
- func (x *Permissions) GetLevel() Permissions_Level
- func (x *Permissions) GetLimitTypeUrls() []string
- func (*Permissions) ProtoMessage()
- func (x *Permissions) ProtoReflect() protoreflect.Message
- func (x *Permissions) Reset()
- func (x *Permissions) String() string
- type Permissions_Level
- func (Permissions_Level) Descriptor() protoreflect.EnumDescriptor
- func (x Permissions_Level) Enum() *Permissions_Level
- func (Permissions_Level) EnumDescriptor() ([]byte, []int)deprecated
- func (x Permissions_Level) Number() protoreflect.EnumNumber
- func (x Permissions_Level) String() string
- func (Permissions_Level) Type() protoreflect.EnumType
- type QueryAccountRequest
- func (*QueryAccountRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryAccountRequest) GetAddress() string
- func (*QueryAccountRequest) ProtoMessage()
- func (x *QueryAccountRequest) ProtoReflect() protoreflect.Message
- func (x *QueryAccountRequest) Reset()
- func (x *QueryAccountRequest) String() string
- type QueryAccountsRequest
- func (*QueryAccountsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryAccountsRequest) GetPagination() *v1beta1.PageRequest
- func (*QueryAccountsRequest) ProtoMessage()
- func (x *QueryAccountsRequest) ProtoReflect() protoreflect.Message
- func (x *QueryAccountsRequest) Reset()
- func (x *QueryAccountsRequest) String() string
- type QueryClient
- type QueryDisabledListRequest
- type QueryServer
- type UnimplementedMsgServer
- func (UnimplementedMsgServer) AuthorizeCircuitBreaker(context.Context, *MsgAuthorizeCircuitBreaker) (*MsgAuthorizeCircuitBreakerResponse, error)
- func (UnimplementedMsgServer) ResetCircuitBreaker(context.Context, *MsgResetCircuitBreaker) (*MsgResetCircuitBreakerResponse, error)
- func (UnimplementedMsgServer) TripCircuitBreaker(context.Context, *MsgTripCircuitBreaker) (*MsgTripCircuitBreakerResponse, error)
- type UnimplementedQueryServer
- func (UnimplementedQueryServer) Account(context.Context, *QueryAccountRequest) (*AccountResponse, error)
- func (UnimplementedQueryServer) Accounts(context.Context, *QueryAccountsRequest) (*AccountsResponse, error)
- func (UnimplementedQueryServer) DisabledList(context.Context, *QueryDisabledListRequest) (*DisabledListResponse, error)
- type UnsafeMsgServer
- type UnsafeQueryServer
Constants ¶
const ( Query_Account_FullMethodName = "/cosmos.circuit.v1.Query/Account" Query_Accounts_FullMethodName = "/cosmos.circuit.v1.Query/Accounts" Query_DisabledList_FullMethodName = "/cosmos.circuit.v1.Query/DisabledList" )
const ( Msg_AuthorizeCircuitBreaker_FullMethodName = "/cosmos.circuit.v1.Msg/AuthorizeCircuitBreaker" Msg_TripCircuitBreaker_FullMethodName = "/cosmos.circuit.v1.Msg/TripCircuitBreaker" Msg_ResetCircuitBreaker_FullMethodName = "/cosmos.circuit.v1.Msg/ResetCircuitBreaker" )
Variables ¶
var ( Permissions_Level_name = map[int32]string{ 0: "LEVEL_NONE_UNSPECIFIED", 1: "LEVEL_SOME_MSGS", 2: "LEVEL_ALL_MSGS", 3: "LEVEL_SUPER_ADMIN", } Permissions_Level_value = map[string]int32{ "LEVEL_NONE_UNSPECIFIED": 0, "LEVEL_SOME_MSGS": 1, "LEVEL_ALL_MSGS": 2, "LEVEL_SUPER_ADMIN": 3, } )
Enum value maps for Permissions_Level.
var File_cosmos_circuit_v1_query_proto protoreflect.FileDescriptor
var File_cosmos_circuit_v1_tx_proto protoreflect.FileDescriptor
var File_cosmos_circuit_v1_types_proto protoreflect.FileDescriptor
var Msg_ServiceDesc = grpc.ServiceDesc{ ServiceName: "cosmos.circuit.v1.Msg", HandlerType: (*MsgServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "AuthorizeCircuitBreaker", Handler: _Msg_AuthorizeCircuitBreaker_Handler, }, { MethodName: "TripCircuitBreaker", Handler: _Msg_TripCircuitBreaker_Handler, }, { MethodName: "ResetCircuitBreaker", Handler: _Msg_ResetCircuitBreaker_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "cosmos/circuit/v1/tx.proto", }
Msg_ServiceDesc is the grpc.ServiceDesc for Msg service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Query_ServiceDesc = grpc.ServiceDesc{ ServiceName: "cosmos.circuit.v1.Query", HandlerType: (*QueryServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Account", Handler: _Query_Account_Handler, }, { MethodName: "Accounts", Handler: _Query_Accounts_Handler, }, { MethodName: "DisabledList", Handler: _Query_DisabledList_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "cosmos/circuit/v1/query.proto", }
Query_ServiceDesc is the grpc.ServiceDesc for Query service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterMsgServer ¶
func RegisterMsgServer(s grpc.ServiceRegistrar, srv MsgServer)
func RegisterQueryServer ¶ added in v0.4.0
func RegisterQueryServer(s grpc.ServiceRegistrar, srv QueryServer)
Types ¶
type AccountResponse ¶ added in v0.4.0
type AccountResponse struct { Permission *Permissions `protobuf:"bytes,1,opt,name=permission,proto3" json:"permission,omitempty"` // contains filtered or unexported fields }
AccountResponse is the response type for the Query/Account RPC method.
func (*AccountResponse) Descriptor
deprecated
added in
v0.4.0
func (*AccountResponse) Descriptor() ([]byte, []int)
Deprecated: Use AccountResponse.ProtoReflect.Descriptor instead.
func (*AccountResponse) GetPermission ¶ added in v0.4.0
func (x *AccountResponse) GetPermission() *Permissions
func (*AccountResponse) ProtoMessage ¶ added in v0.4.0
func (*AccountResponse) ProtoMessage()
func (*AccountResponse) ProtoReflect ¶ added in v0.4.0
func (x *AccountResponse) ProtoReflect() protoreflect.Message
func (*AccountResponse) Reset ¶ added in v0.4.0
func (x *AccountResponse) Reset()
func (*AccountResponse) String ¶ added in v0.4.0
func (x *AccountResponse) String() string
type AccountsResponse ¶ added in v0.4.0
type AccountsResponse struct { Accounts []*GenesisAccountPermissions `protobuf:"bytes,1,rep,name=accounts,proto3" json:"accounts,omitempty"` // pagination defines the pagination in the response. Pagination *v1beta1.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` // contains filtered or unexported fields }
AccountsResponse is the response type for the Query/Accounts RPC method.
func (*AccountsResponse) Descriptor
deprecated
added in
v0.4.0
func (*AccountsResponse) Descriptor() ([]byte, []int)
Deprecated: Use AccountsResponse.ProtoReflect.Descriptor instead.
func (*AccountsResponse) GetAccounts ¶ added in v0.4.0
func (x *AccountsResponse) GetAccounts() []*GenesisAccountPermissions
func (*AccountsResponse) GetPagination ¶ added in v0.4.0
func (x *AccountsResponse) GetPagination() *v1beta1.PageResponse
func (*AccountsResponse) ProtoMessage ¶ added in v0.4.0
func (*AccountsResponse) ProtoMessage()
func (*AccountsResponse) ProtoReflect ¶ added in v0.4.0
func (x *AccountsResponse) ProtoReflect() protoreflect.Message
func (*AccountsResponse) Reset ¶ added in v0.4.0
func (x *AccountsResponse) Reset()
func (*AccountsResponse) String ¶ added in v0.4.0
func (x *AccountsResponse) String() string
type DisabledListResponse ¶ added in v0.4.0
type DisabledListResponse struct { DisabledList []string `protobuf:"bytes,1,rep,name=disabled_list,json=disabledList,proto3" json:"disabled_list,omitempty"` // contains filtered or unexported fields }
DisabledListResponse is the response type for the Query/DisabledList RPC method.
func (*DisabledListResponse) Descriptor
deprecated
added in
v0.4.0
func (*DisabledListResponse) Descriptor() ([]byte, []int)
Deprecated: Use DisabledListResponse.ProtoReflect.Descriptor instead.
func (*DisabledListResponse) GetDisabledList ¶ added in v0.4.0
func (x *DisabledListResponse) GetDisabledList() []string
func (*DisabledListResponse) ProtoMessage ¶ added in v0.4.0
func (*DisabledListResponse) ProtoMessage()
func (*DisabledListResponse) ProtoReflect ¶ added in v0.4.0
func (x *DisabledListResponse) ProtoReflect() protoreflect.Message
func (*DisabledListResponse) Reset ¶ added in v0.4.0
func (x *DisabledListResponse) Reset()
func (*DisabledListResponse) String ¶ added in v0.4.0
func (x *DisabledListResponse) String() string
type GenesisAccountPermissions ¶ added in v0.4.0
type GenesisAccountPermissions struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` Permissions *Permissions `protobuf:"bytes,2,opt,name=permissions,proto3" json:"permissions,omitempty"` // contains filtered or unexported fields }
GenesisAccountPermissions is the account permissions for the circuit breaker in genesis
func (*GenesisAccountPermissions) Descriptor
deprecated
added in
v0.4.0
func (*GenesisAccountPermissions) Descriptor() ([]byte, []int)
Deprecated: Use GenesisAccountPermissions.ProtoReflect.Descriptor instead.
func (*GenesisAccountPermissions) GetAddress ¶ added in v0.4.0
func (x *GenesisAccountPermissions) GetAddress() string
func (*GenesisAccountPermissions) GetPermissions ¶ added in v0.4.0
func (x *GenesisAccountPermissions) GetPermissions() *Permissions
func (*GenesisAccountPermissions) ProtoMessage ¶ added in v0.4.0
func (*GenesisAccountPermissions) ProtoMessage()
func (*GenesisAccountPermissions) ProtoReflect ¶ added in v0.4.0
func (x *GenesisAccountPermissions) ProtoReflect() protoreflect.Message
func (*GenesisAccountPermissions) Reset ¶ added in v0.4.0
func (x *GenesisAccountPermissions) Reset()
func (*GenesisAccountPermissions) String ¶ added in v0.4.0
func (x *GenesisAccountPermissions) String() string
type GenesisState ¶ added in v0.4.0
type GenesisState struct { AccountPermissions []*GenesisAccountPermissions `protobuf:"bytes,1,rep,name=account_permissions,json=accountPermissions,proto3" json:"account_permissions,omitempty"` DisabledTypeUrls []string `protobuf:"bytes,2,rep,name=disabled_type_urls,json=disabledTypeUrls,proto3" json:"disabled_type_urls,omitempty"` // contains filtered or unexported fields }
GenesisState is the state that must be provided at genesis.
func (*GenesisState) Descriptor
deprecated
added in
v0.4.0
func (*GenesisState) Descriptor() ([]byte, []int)
Deprecated: Use GenesisState.ProtoReflect.Descriptor instead.
func (*GenesisState) GetAccountPermissions ¶ added in v0.4.0
func (x *GenesisState) GetAccountPermissions() []*GenesisAccountPermissions
func (*GenesisState) GetDisabledTypeUrls ¶ added in v0.4.0
func (x *GenesisState) GetDisabledTypeUrls() []string
func (*GenesisState) ProtoMessage ¶ added in v0.4.0
func (*GenesisState) ProtoMessage()
func (*GenesisState) ProtoReflect ¶ added in v0.4.0
func (x *GenesisState) ProtoReflect() protoreflect.Message
func (*GenesisState) Reset ¶ added in v0.4.0
func (x *GenesisState) Reset()
func (*GenesisState) String ¶ added in v0.4.0
func (x *GenesisState) String() string
type MsgAuthorizeCircuitBreaker ¶
type MsgAuthorizeCircuitBreaker struct { // granter is the granter of the circuit breaker permissions and must have // LEVEL_SUPER_ADMIN. Granter string `protobuf:"bytes,1,opt,name=granter,proto3" json:"granter,omitempty"` // grantee is the account authorized with the provided permissions. Grantee string `protobuf:"bytes,2,opt,name=grantee,proto3" json:"grantee,omitempty"` // permissions are the circuit breaker permissions that the grantee receives. // These will overwrite any existing permissions. LEVEL_NONE_UNSPECIFIED can // be specified to revoke all permissions. Permissions *Permissions `protobuf:"bytes,3,opt,name=permissions,proto3" json:"permissions,omitempty"` // contains filtered or unexported fields }
MsgAuthorizeCircuitBreaker defines the Msg/AuthorizeCircuitBreaker request type.
func (*MsgAuthorizeCircuitBreaker) Descriptor
deprecated
func (*MsgAuthorizeCircuitBreaker) Descriptor() ([]byte, []int)
Deprecated: Use MsgAuthorizeCircuitBreaker.ProtoReflect.Descriptor instead.
func (*MsgAuthorizeCircuitBreaker) GetGrantee ¶
func (x *MsgAuthorizeCircuitBreaker) GetGrantee() string
func (*MsgAuthorizeCircuitBreaker) GetGranter ¶
func (x *MsgAuthorizeCircuitBreaker) GetGranter() string
func (*MsgAuthorizeCircuitBreaker) GetPermissions ¶
func (x *MsgAuthorizeCircuitBreaker) GetPermissions() *Permissions
func (*MsgAuthorizeCircuitBreaker) ProtoMessage ¶
func (*MsgAuthorizeCircuitBreaker) ProtoMessage()
func (*MsgAuthorizeCircuitBreaker) ProtoReflect ¶
func (x *MsgAuthorizeCircuitBreaker) ProtoReflect() protoreflect.Message
func (*MsgAuthorizeCircuitBreaker) Reset ¶
func (x *MsgAuthorizeCircuitBreaker) Reset()
func (*MsgAuthorizeCircuitBreaker) String ¶
func (x *MsgAuthorizeCircuitBreaker) String() string
type MsgAuthorizeCircuitBreakerResponse ¶
type MsgAuthorizeCircuitBreakerResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // contains filtered or unexported fields }
MsgAuthorizeCircuitBreakerResponse defines the Msg/AuthorizeCircuitBreaker response type.
func (*MsgAuthorizeCircuitBreakerResponse) Descriptor
deprecated
func (*MsgAuthorizeCircuitBreakerResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgAuthorizeCircuitBreakerResponse.ProtoReflect.Descriptor instead.
func (*MsgAuthorizeCircuitBreakerResponse) GetSuccess ¶ added in v0.4.0
func (x *MsgAuthorizeCircuitBreakerResponse) GetSuccess() bool
func (*MsgAuthorizeCircuitBreakerResponse) ProtoMessage ¶
func (*MsgAuthorizeCircuitBreakerResponse) ProtoMessage()
func (*MsgAuthorizeCircuitBreakerResponse) ProtoReflect ¶
func (x *MsgAuthorizeCircuitBreakerResponse) ProtoReflect() protoreflect.Message
func (*MsgAuthorizeCircuitBreakerResponse) Reset ¶
func (x *MsgAuthorizeCircuitBreakerResponse) Reset()
func (*MsgAuthorizeCircuitBreakerResponse) String ¶
func (x *MsgAuthorizeCircuitBreakerResponse) String() string
type MsgClient ¶
type MsgClient interface { // AuthorizeCircuitBreaker allows a super-admin to grant (or revoke) another // account's circuit breaker permissions. AuthorizeCircuitBreaker(ctx context.Context, in *MsgAuthorizeCircuitBreaker, opts ...grpc.CallOption) (*MsgAuthorizeCircuitBreakerResponse, error) // TripCircuitBreaker pauses processing of Msg's in the state machine. TripCircuitBreaker(ctx context.Context, in *MsgTripCircuitBreaker, opts ...grpc.CallOption) (*MsgTripCircuitBreakerResponse, error) // ResetCircuitBreaker resumes processing of Msg's in the state machine that // have been been paused using TripCircuitBreaker. ResetCircuitBreaker(ctx context.Context, in *MsgResetCircuitBreaker, opts ...grpc.CallOption) (*MsgResetCircuitBreakerResponse, error) }
MsgClient is the client API for Msg service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewMsgClient ¶
func NewMsgClient(cc grpc.ClientConnInterface) MsgClient
type MsgResetCircuitBreaker ¶
type MsgResetCircuitBreaker struct { // authority is the account authorized to trip or reset the circuit breaker. Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"` // msg_type_urls specifies a list of Msg type URLs to resume processing. If // it is left empty all Msg processing for type URLs that the account is // authorized to trip will resume. MsgTypeUrls []string `protobuf:"bytes,3,rep,name=msg_type_urls,json=msgTypeUrls,proto3" json:"msg_type_urls,omitempty"` // contains filtered or unexported fields }
MsgResetCircuitBreaker defines the Msg/ResetCircuitBreaker request type.
func (*MsgResetCircuitBreaker) Descriptor
deprecated
func (*MsgResetCircuitBreaker) Descriptor() ([]byte, []int)
Deprecated: Use MsgResetCircuitBreaker.ProtoReflect.Descriptor instead.
func (*MsgResetCircuitBreaker) GetAuthority ¶
func (x *MsgResetCircuitBreaker) GetAuthority() string
func (*MsgResetCircuitBreaker) GetMsgTypeUrls ¶
func (x *MsgResetCircuitBreaker) GetMsgTypeUrls() []string
func (*MsgResetCircuitBreaker) ProtoMessage ¶
func (*MsgResetCircuitBreaker) ProtoMessage()
func (*MsgResetCircuitBreaker) ProtoReflect ¶
func (x *MsgResetCircuitBreaker) ProtoReflect() protoreflect.Message
func (*MsgResetCircuitBreaker) Reset ¶
func (x *MsgResetCircuitBreaker) Reset()
func (*MsgResetCircuitBreaker) String ¶
func (x *MsgResetCircuitBreaker) String() string
type MsgResetCircuitBreakerResponse ¶
type MsgResetCircuitBreakerResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // contains filtered or unexported fields }
MsgResetCircuitBreakerResponse defines the Msg/ResetCircuitBreaker response type.
func (*MsgResetCircuitBreakerResponse) Descriptor
deprecated
func (*MsgResetCircuitBreakerResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgResetCircuitBreakerResponse.ProtoReflect.Descriptor instead.
func (*MsgResetCircuitBreakerResponse) GetSuccess ¶ added in v0.4.0
func (x *MsgResetCircuitBreakerResponse) GetSuccess() bool
func (*MsgResetCircuitBreakerResponse) ProtoMessage ¶
func (*MsgResetCircuitBreakerResponse) ProtoMessage()
func (*MsgResetCircuitBreakerResponse) ProtoReflect ¶
func (x *MsgResetCircuitBreakerResponse) ProtoReflect() protoreflect.Message
func (*MsgResetCircuitBreakerResponse) Reset ¶
func (x *MsgResetCircuitBreakerResponse) Reset()
func (*MsgResetCircuitBreakerResponse) String ¶
func (x *MsgResetCircuitBreakerResponse) String() string
type MsgServer ¶
type MsgServer interface { // AuthorizeCircuitBreaker allows a super-admin to grant (or revoke) another // account's circuit breaker permissions. AuthorizeCircuitBreaker(context.Context, *MsgAuthorizeCircuitBreaker) (*MsgAuthorizeCircuitBreakerResponse, error) // TripCircuitBreaker pauses processing of Msg's in the state machine. TripCircuitBreaker(context.Context, *MsgTripCircuitBreaker) (*MsgTripCircuitBreakerResponse, error) // ResetCircuitBreaker resumes processing of Msg's in the state machine that // have been been paused using TripCircuitBreaker. ResetCircuitBreaker(context.Context, *MsgResetCircuitBreaker) (*MsgResetCircuitBreakerResponse, error) // contains filtered or unexported methods }
MsgServer is the server API for Msg service. All implementations must embed UnimplementedMsgServer for forward compatibility
type MsgTripCircuitBreaker ¶
type MsgTripCircuitBreaker struct { // authority is the account authorized to trip the circuit breaker. Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"` // msg_type_urls specifies a list of type URLs to immediately stop processing. // IF IT IS LEFT EMPTY, ALL MSG PROCESSING WILL STOP IMMEDIATELY. // This value is validated against the authority's permissions and if the // authority does not have permissions to trip the specified msg type URLs // (or all URLs), the operation will fail. MsgTypeUrls []string `protobuf:"bytes,2,rep,name=msg_type_urls,json=msgTypeUrls,proto3" json:"msg_type_urls,omitempty"` // contains filtered or unexported fields }
MsgTripCircuitBreaker defines the Msg/TripCircuitBreaker request type.
func (*MsgTripCircuitBreaker) Descriptor
deprecated
func (*MsgTripCircuitBreaker) Descriptor() ([]byte, []int)
Deprecated: Use MsgTripCircuitBreaker.ProtoReflect.Descriptor instead.
func (*MsgTripCircuitBreaker) GetAuthority ¶
func (x *MsgTripCircuitBreaker) GetAuthority() string
func (*MsgTripCircuitBreaker) GetMsgTypeUrls ¶
func (x *MsgTripCircuitBreaker) GetMsgTypeUrls() []string
func (*MsgTripCircuitBreaker) ProtoMessage ¶
func (*MsgTripCircuitBreaker) ProtoMessage()
func (*MsgTripCircuitBreaker) ProtoReflect ¶
func (x *MsgTripCircuitBreaker) ProtoReflect() protoreflect.Message
func (*MsgTripCircuitBreaker) Reset ¶
func (x *MsgTripCircuitBreaker) Reset()
func (*MsgTripCircuitBreaker) String ¶
func (x *MsgTripCircuitBreaker) String() string
type MsgTripCircuitBreakerResponse ¶
type MsgTripCircuitBreakerResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // contains filtered or unexported fields }
MsgTripCircuitBreakerResponse defines the Msg/TripCircuitBreaker response type.
func (*MsgTripCircuitBreakerResponse) Descriptor
deprecated
func (*MsgTripCircuitBreakerResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgTripCircuitBreakerResponse.ProtoReflect.Descriptor instead.
func (*MsgTripCircuitBreakerResponse) GetSuccess ¶ added in v0.4.0
func (x *MsgTripCircuitBreakerResponse) GetSuccess() bool
func (*MsgTripCircuitBreakerResponse) ProtoMessage ¶
func (*MsgTripCircuitBreakerResponse) ProtoMessage()
func (*MsgTripCircuitBreakerResponse) ProtoReflect ¶
func (x *MsgTripCircuitBreakerResponse) ProtoReflect() protoreflect.Message
func (*MsgTripCircuitBreakerResponse) Reset ¶
func (x *MsgTripCircuitBreakerResponse) Reset()
func (*MsgTripCircuitBreakerResponse) String ¶
func (x *MsgTripCircuitBreakerResponse) String() string
type Permissions ¶ added in v0.4.0
type Permissions struct { // level is the level of permissions granted to this account. Level Permissions_Level `protobuf:"varint,1,opt,name=level,proto3,enum=cosmos.circuit.v1.Permissions_Level" json:"level,omitempty"` // limit_type_urls is used with LEVEL_SOME_MSGS to limit the lists of Msg type // URLs that the account can trip. It is an error to use limit_type_urls with // a level other than LEVEL_SOME_MSGS. LimitTypeUrls []string `protobuf:"bytes,2,rep,name=limit_type_urls,json=limitTypeUrls,proto3" json:"limit_type_urls,omitempty"` // contains filtered or unexported fields }
Permissions are the permissions that an account has to trip or reset the circuit breaker.
func (*Permissions) Descriptor
deprecated
added in
v0.4.0
func (*Permissions) Descriptor() ([]byte, []int)
Deprecated: Use Permissions.ProtoReflect.Descriptor instead.
func (*Permissions) GetLevel ¶ added in v0.4.0
func (x *Permissions) GetLevel() Permissions_Level
func (*Permissions) GetLimitTypeUrls ¶ added in v0.4.0
func (x *Permissions) GetLimitTypeUrls() []string
func (*Permissions) ProtoMessage ¶ added in v0.4.0
func (*Permissions) ProtoMessage()
func (*Permissions) ProtoReflect ¶ added in v0.4.0
func (x *Permissions) ProtoReflect() protoreflect.Message
func (*Permissions) Reset ¶ added in v0.4.0
func (x *Permissions) Reset()
func (*Permissions) String ¶ added in v0.4.0
func (x *Permissions) String() string
type Permissions_Level ¶ added in v0.4.0
type Permissions_Level int32
Level is the permission level.
const ( // LEVEL_NONE_UNSPECIFIED indicates that the account will have no circuit // breaker permissions. Permissions_LEVEL_NONE_UNSPECIFIED Permissions_Level = 0 // LEVEL_SOME_MSGS indicates that the account will have permission to // trip or reset the circuit breaker for some Msg type URLs. If this level // is chosen, a non-empty list of Msg type URLs must be provided in // limit_type_urls. Permissions_LEVEL_SOME_MSGS Permissions_Level = 1 // LEVEL_ALL_MSGS indicates that the account can trip or reset the circuit // breaker for Msg's of all type URLs. Permissions_LEVEL_ALL_MSGS Permissions_Level = 2 // LEVEL_SUPER_ADMIN indicates that the account can take all circuit breaker // actions and can grant permissions to other accounts. Permissions_LEVEL_SUPER_ADMIN Permissions_Level = 3 )
func (Permissions_Level) Descriptor ¶ added in v0.4.0
func (Permissions_Level) Descriptor() protoreflect.EnumDescriptor
func (Permissions_Level) Enum ¶ added in v0.4.0
func (x Permissions_Level) Enum() *Permissions_Level
func (Permissions_Level) EnumDescriptor
deprecated
added in
v0.4.0
func (Permissions_Level) EnumDescriptor() ([]byte, []int)
Deprecated: Use Permissions_Level.Descriptor instead.
func (Permissions_Level) Number ¶ added in v0.4.0
func (x Permissions_Level) Number() protoreflect.EnumNumber
func (Permissions_Level) String ¶ added in v0.4.0
func (x Permissions_Level) String() string
func (Permissions_Level) Type ¶ added in v0.4.0
func (Permissions_Level) Type() protoreflect.EnumType
type QueryAccountRequest ¶ added in v0.4.0
type QueryAccountRequest struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` // contains filtered or unexported fields }
QueryAccountRequest is the request type for the Query/Account RPC method.
func (*QueryAccountRequest) Descriptor
deprecated
added in
v0.4.0
func (*QueryAccountRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryAccountRequest.ProtoReflect.Descriptor instead.
func (*QueryAccountRequest) GetAddress ¶ added in v0.4.0
func (x *QueryAccountRequest) GetAddress() string
func (*QueryAccountRequest) ProtoMessage ¶ added in v0.4.0
func (*QueryAccountRequest) ProtoMessage()
func (*QueryAccountRequest) ProtoReflect ¶ added in v0.4.0
func (x *QueryAccountRequest) ProtoReflect() protoreflect.Message
func (*QueryAccountRequest) Reset ¶ added in v0.4.0
func (x *QueryAccountRequest) Reset()
func (*QueryAccountRequest) String ¶ added in v0.4.0
func (x *QueryAccountRequest) String() string
type QueryAccountsRequest ¶ added in v0.4.0
type QueryAccountsRequest struct { // pagination defines an optional pagination for the request. Pagination *v1beta1.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"` // contains filtered or unexported fields }
QueryAccountsRequest is the request type for the Query/Accounts RPC method.
func (*QueryAccountsRequest) Descriptor
deprecated
added in
v0.4.0
func (*QueryAccountsRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryAccountsRequest.ProtoReflect.Descriptor instead.
func (*QueryAccountsRequest) GetPagination ¶ added in v0.4.0
func (x *QueryAccountsRequest) GetPagination() *v1beta1.PageRequest
func (*QueryAccountsRequest) ProtoMessage ¶ added in v0.4.0
func (*QueryAccountsRequest) ProtoMessage()
func (*QueryAccountsRequest) ProtoReflect ¶ added in v0.4.0
func (x *QueryAccountsRequest) ProtoReflect() protoreflect.Message
func (*QueryAccountsRequest) Reset ¶ added in v0.4.0
func (x *QueryAccountsRequest) Reset()
func (*QueryAccountsRequest) String ¶ added in v0.4.0
func (x *QueryAccountsRequest) String() string
type QueryClient ¶ added in v0.4.0
type QueryClient interface { // Account returns account permissions. Account(ctx context.Context, in *QueryAccountRequest, opts ...grpc.CallOption) (*AccountResponse, error) // Account returns account permissions. Accounts(ctx context.Context, in *QueryAccountsRequest, opts ...grpc.CallOption) (*AccountsResponse, error) // DisabledList returns a list of disabled message urls DisabledList(ctx context.Context, in *QueryDisabledListRequest, opts ...grpc.CallOption) (*DisabledListResponse, error) }
QueryClient is the client API for Query service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewQueryClient ¶ added in v0.4.0
func NewQueryClient(cc grpc.ClientConnInterface) QueryClient
type QueryDisabledListRequest ¶ added in v0.4.0
type QueryDisabledListRequest struct {
// contains filtered or unexported fields
}
QueryDisableListRequest is the request type for the Query/DisabledList RPC method.
func (*QueryDisabledListRequest) Descriptor
deprecated
added in
v0.4.0
func (*QueryDisabledListRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryDisabledListRequest.ProtoReflect.Descriptor instead.
func (*QueryDisabledListRequest) ProtoMessage ¶ added in v0.4.0
func (*QueryDisabledListRequest) ProtoMessage()
func (*QueryDisabledListRequest) ProtoReflect ¶ added in v0.4.0
func (x *QueryDisabledListRequest) ProtoReflect() protoreflect.Message
func (*QueryDisabledListRequest) Reset ¶ added in v0.4.0
func (x *QueryDisabledListRequest) Reset()
func (*QueryDisabledListRequest) String ¶ added in v0.4.0
func (x *QueryDisabledListRequest) String() string
type QueryServer ¶ added in v0.4.0
type QueryServer interface { // Account returns account permissions. Account(context.Context, *QueryAccountRequest) (*AccountResponse, error) // Account returns account permissions. Accounts(context.Context, *QueryAccountsRequest) (*AccountsResponse, error) // DisabledList returns a list of disabled message urls DisabledList(context.Context, *QueryDisabledListRequest) (*DisabledListResponse, error) // contains filtered or unexported methods }
QueryServer is the server API for Query service. All implementations must embed UnimplementedQueryServer for forward compatibility
type UnimplementedMsgServer ¶
type UnimplementedMsgServer struct { }
UnimplementedMsgServer must be embedded to have forward compatible implementations.
func (UnimplementedMsgServer) AuthorizeCircuitBreaker ¶
func (UnimplementedMsgServer) AuthorizeCircuitBreaker(context.Context, *MsgAuthorizeCircuitBreaker) (*MsgAuthorizeCircuitBreakerResponse, error)
func (UnimplementedMsgServer) ResetCircuitBreaker ¶
func (UnimplementedMsgServer) ResetCircuitBreaker(context.Context, *MsgResetCircuitBreaker) (*MsgResetCircuitBreakerResponse, error)
func (UnimplementedMsgServer) TripCircuitBreaker ¶
func (UnimplementedMsgServer) TripCircuitBreaker(context.Context, *MsgTripCircuitBreaker) (*MsgTripCircuitBreakerResponse, error)
type UnimplementedQueryServer ¶ added in v0.4.0
type UnimplementedQueryServer struct { }
UnimplementedQueryServer must be embedded to have forward compatible implementations.
func (UnimplementedQueryServer) Account ¶ added in v0.4.0
func (UnimplementedQueryServer) Account(context.Context, *QueryAccountRequest) (*AccountResponse, error)
func (UnimplementedQueryServer) Accounts ¶ added in v0.4.0
func (UnimplementedQueryServer) Accounts(context.Context, *QueryAccountsRequest) (*AccountsResponse, error)
func (UnimplementedQueryServer) DisabledList ¶ added in v0.4.0
func (UnimplementedQueryServer) DisabledList(context.Context, *QueryDisabledListRequest) (*DisabledListResponse, error)
type UnsafeMsgServer ¶
type UnsafeMsgServer interface {
// contains filtered or unexported methods
}
UnsafeMsgServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MsgServer will result in compilation errors.
type UnsafeQueryServer ¶ added in v0.4.0
type UnsafeQueryServer interface {
// contains filtered or unexported methods
}
UnsafeQueryServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QueryServer will result in compilation errors.