Documentation ¶
Index ¶
- Variables
- func RegisterMsgServer(s grpc1.Server, srv MsgServer)
- type CircuitBreakerPermissions
- func (*CircuitBreakerPermissions) Descriptor() ([]byte, []int)
- func (m *CircuitBreakerPermissions) GetLevel() CircuitBreakerPermissions_Level
- func (m *CircuitBreakerPermissions) GetLimitTypeUrls() []string
- func (m *CircuitBreakerPermissions) Marshal() (dAtA []byte, err error)
- func (m *CircuitBreakerPermissions) MarshalTo(dAtA []byte) (int, error)
- func (m *CircuitBreakerPermissions) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CircuitBreakerPermissions) ProtoMessage()
- func (m *CircuitBreakerPermissions) Reset()
- func (m *CircuitBreakerPermissions) Size() (n int)
- func (m *CircuitBreakerPermissions) String() string
- func (m *CircuitBreakerPermissions) Unmarshal(dAtA []byte) error
- func (m *CircuitBreakerPermissions) XXX_DiscardUnknown()
- func (m *CircuitBreakerPermissions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CircuitBreakerPermissions) XXX_Merge(src proto.Message)
- func (m *CircuitBreakerPermissions) XXX_Size() int
- func (m *CircuitBreakerPermissions) XXX_Unmarshal(b []byte) error
- type CircuitBreakerPermissions_Level
- type MsgAuthorizeCircuitBreaker
- func (*MsgAuthorizeCircuitBreaker) Descriptor() ([]byte, []int)
- func (m *MsgAuthorizeCircuitBreaker) GetGrantee() string
- func (m *MsgAuthorizeCircuitBreaker) GetGranter() string
- func (m *MsgAuthorizeCircuitBreaker) GetPermissions() *CircuitBreakerPermissions
- func (m *MsgAuthorizeCircuitBreaker) Marshal() (dAtA []byte, err error)
- func (m *MsgAuthorizeCircuitBreaker) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgAuthorizeCircuitBreaker) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgAuthorizeCircuitBreaker) ProtoMessage()
- func (m *MsgAuthorizeCircuitBreaker) Reset()
- func (m *MsgAuthorizeCircuitBreaker) Size() (n int)
- func (m *MsgAuthorizeCircuitBreaker) String() string
- func (m *MsgAuthorizeCircuitBreaker) Unmarshal(dAtA []byte) error
- func (m *MsgAuthorizeCircuitBreaker) XXX_DiscardUnknown()
- func (m *MsgAuthorizeCircuitBreaker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgAuthorizeCircuitBreaker) XXX_Merge(src proto.Message)
- func (m *MsgAuthorizeCircuitBreaker) XXX_Size() int
- func (m *MsgAuthorizeCircuitBreaker) XXX_Unmarshal(b []byte) error
- type MsgAuthorizeCircuitBreakerResponse
- func (*MsgAuthorizeCircuitBreakerResponse) Descriptor() ([]byte, []int)
- func (m *MsgAuthorizeCircuitBreakerResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgAuthorizeCircuitBreakerResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgAuthorizeCircuitBreakerResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgAuthorizeCircuitBreakerResponse) ProtoMessage()
- func (m *MsgAuthorizeCircuitBreakerResponse) Reset()
- func (m *MsgAuthorizeCircuitBreakerResponse) Size() (n int)
- func (m *MsgAuthorizeCircuitBreakerResponse) String() string
- func (m *MsgAuthorizeCircuitBreakerResponse) Unmarshal(dAtA []byte) error
- func (m *MsgAuthorizeCircuitBreakerResponse) XXX_DiscardUnknown()
- func (m *MsgAuthorizeCircuitBreakerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgAuthorizeCircuitBreakerResponse) XXX_Merge(src proto.Message)
- func (m *MsgAuthorizeCircuitBreakerResponse) XXX_Size() int
- func (m *MsgAuthorizeCircuitBreakerResponse) XXX_Unmarshal(b []byte) error
- type MsgClient
- type MsgResetCircuitBreaker
- func (*MsgResetCircuitBreaker) Descriptor() ([]byte, []int)
- func (m *MsgResetCircuitBreaker) GetAuthority() string
- func (m *MsgResetCircuitBreaker) GetMsgTypeUrls() []string
- func (m *MsgResetCircuitBreaker) Marshal() (dAtA []byte, err error)
- func (m *MsgResetCircuitBreaker) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgResetCircuitBreaker) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgResetCircuitBreaker) ProtoMessage()
- func (m *MsgResetCircuitBreaker) Reset()
- func (m *MsgResetCircuitBreaker) Size() (n int)
- func (m *MsgResetCircuitBreaker) String() string
- func (m *MsgResetCircuitBreaker) Unmarshal(dAtA []byte) error
- func (m *MsgResetCircuitBreaker) XXX_DiscardUnknown()
- func (m *MsgResetCircuitBreaker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgResetCircuitBreaker) XXX_Merge(src proto.Message)
- func (m *MsgResetCircuitBreaker) XXX_Size() int
- func (m *MsgResetCircuitBreaker) XXX_Unmarshal(b []byte) error
- type MsgResetCircuitBreakerResponse
- func (*MsgResetCircuitBreakerResponse) Descriptor() ([]byte, []int)
- func (m *MsgResetCircuitBreakerResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgResetCircuitBreakerResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgResetCircuitBreakerResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgResetCircuitBreakerResponse) ProtoMessage()
- func (m *MsgResetCircuitBreakerResponse) Reset()
- func (m *MsgResetCircuitBreakerResponse) Size() (n int)
- func (m *MsgResetCircuitBreakerResponse) String() string
- func (m *MsgResetCircuitBreakerResponse) Unmarshal(dAtA []byte) error
- func (m *MsgResetCircuitBreakerResponse) XXX_DiscardUnknown()
- func (m *MsgResetCircuitBreakerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgResetCircuitBreakerResponse) XXX_Merge(src proto.Message)
- func (m *MsgResetCircuitBreakerResponse) XXX_Size() int
- func (m *MsgResetCircuitBreakerResponse) XXX_Unmarshal(b []byte) error
- type MsgServer
- type MsgTripCircuitBreaker
- func (*MsgTripCircuitBreaker) Descriptor() ([]byte, []int)
- func (m *MsgTripCircuitBreaker) GetAuthority() string
- func (m *MsgTripCircuitBreaker) GetMsgTypeUrls() []string
- func (m *MsgTripCircuitBreaker) Marshal() (dAtA []byte, err error)
- func (m *MsgTripCircuitBreaker) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgTripCircuitBreaker) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgTripCircuitBreaker) ProtoMessage()
- func (m *MsgTripCircuitBreaker) Reset()
- func (m *MsgTripCircuitBreaker) Size() (n int)
- func (m *MsgTripCircuitBreaker) String() string
- func (m *MsgTripCircuitBreaker) Unmarshal(dAtA []byte) error
- func (m *MsgTripCircuitBreaker) XXX_DiscardUnknown()
- func (m *MsgTripCircuitBreaker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgTripCircuitBreaker) XXX_Merge(src proto.Message)
- func (m *MsgTripCircuitBreaker) XXX_Size() int
- func (m *MsgTripCircuitBreaker) XXX_Unmarshal(b []byte) error
- type MsgTripCircuitBreakerResponse
- func (*MsgTripCircuitBreakerResponse) Descriptor() ([]byte, []int)
- func (m *MsgTripCircuitBreakerResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgTripCircuitBreakerResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgTripCircuitBreakerResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgTripCircuitBreakerResponse) ProtoMessage()
- func (m *MsgTripCircuitBreakerResponse) Reset()
- func (m *MsgTripCircuitBreakerResponse) Size() (n int)
- func (m *MsgTripCircuitBreakerResponse) String() string
- func (m *MsgTripCircuitBreakerResponse) Unmarshal(dAtA []byte) error
- func (m *MsgTripCircuitBreakerResponse) XXX_DiscardUnknown()
- func (m *MsgTripCircuitBreakerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgTripCircuitBreakerResponse) XXX_Merge(src proto.Message)
- func (m *MsgTripCircuitBreakerResponse) XXX_Size() int
- func (m *MsgTripCircuitBreakerResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedMsgServer
- func (*UnimplementedMsgServer) AuthorizeCircuitBreaker(ctx context.Context, req *MsgAuthorizeCircuitBreaker) (*MsgAuthorizeCircuitBreakerResponse, error)
- func (*UnimplementedMsgServer) ResetCircuitBreaker(ctx context.Context, req *MsgResetCircuitBreaker) (*MsgResetCircuitBreakerResponse, error)
- func (*UnimplementedMsgServer) TripCircuitBreaker(ctx context.Context, req *MsgTripCircuitBreaker) (*MsgTripCircuitBreakerResponse, error)
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthTx = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTx = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group") )
var CircuitBreakerPermissions_Level_name = map[int32]string{
0: "LEVEL_NONE_UNSPECIFIED",
1: "LEVEL_SOME_MSGS",
2: "LEVEL_ALL_MSGS",
3: "LEVEL_SUPER_ADMIN",
}
var CircuitBreakerPermissions_Level_value = map[string]int32{
"LEVEL_NONE_UNSPECIFIED": 0,
"LEVEL_SOME_MSGS": 1,
"LEVEL_ALL_MSGS": 2,
"LEVEL_SUPER_ADMIN": 3,
}
Functions ¶
func RegisterMsgServer ¶
Types ¶
type CircuitBreakerPermissions ¶
type CircuitBreakerPermissions struct { // level is the level of permissions granted to this account. Level CircuitBreakerPermissions_Level `protobuf:"varint,1,opt,name=level,proto3,enum=cosmos.circuit.v1.CircuitBreakerPermissions_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 pause. 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"` }
CircuitBreakerPermissions are the permissions that an account has to trip or reset the circuit breaker.
func (*CircuitBreakerPermissions) Descriptor ¶
func (*CircuitBreakerPermissions) Descriptor() ([]byte, []int)
func (*CircuitBreakerPermissions) GetLevel ¶
func (m *CircuitBreakerPermissions) GetLevel() CircuitBreakerPermissions_Level
func (*CircuitBreakerPermissions) GetLimitTypeUrls ¶
func (m *CircuitBreakerPermissions) GetLimitTypeUrls() []string
func (*CircuitBreakerPermissions) Marshal ¶
func (m *CircuitBreakerPermissions) Marshal() (dAtA []byte, err error)
func (*CircuitBreakerPermissions) MarshalTo ¶
func (m *CircuitBreakerPermissions) MarshalTo(dAtA []byte) (int, error)
func (*CircuitBreakerPermissions) MarshalToSizedBuffer ¶
func (m *CircuitBreakerPermissions) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CircuitBreakerPermissions) ProtoMessage ¶
func (*CircuitBreakerPermissions) ProtoMessage()
func (*CircuitBreakerPermissions) Reset ¶
func (m *CircuitBreakerPermissions) Reset()
func (*CircuitBreakerPermissions) Size ¶
func (m *CircuitBreakerPermissions) Size() (n int)
func (*CircuitBreakerPermissions) String ¶
func (m *CircuitBreakerPermissions) String() string
func (*CircuitBreakerPermissions) Unmarshal ¶
func (m *CircuitBreakerPermissions) Unmarshal(dAtA []byte) error
func (*CircuitBreakerPermissions) XXX_DiscardUnknown ¶
func (m *CircuitBreakerPermissions) XXX_DiscardUnknown()
func (*CircuitBreakerPermissions) XXX_Marshal ¶
func (m *CircuitBreakerPermissions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CircuitBreakerPermissions) XXX_Merge ¶
func (m *CircuitBreakerPermissions) XXX_Merge(src proto.Message)
func (*CircuitBreakerPermissions) XXX_Size ¶
func (m *CircuitBreakerPermissions) XXX_Size() int
func (*CircuitBreakerPermissions) XXX_Unmarshal ¶
func (m *CircuitBreakerPermissions) XXX_Unmarshal(b []byte) error
type CircuitBreakerPermissions_Level ¶
type CircuitBreakerPermissions_Level int32
Level is the permission level.
const ( // LEVEL_NONE_UNSPECIFIED indicates that the account will have no circuit // breaker permissions. CircuitBreakerPermissions_LEVEL_NONE_UNSPECIFIED CircuitBreakerPermissions_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. CircuitBreakerPermissions_LEVEL_SOME_MSGS CircuitBreakerPermissions_Level = 1 // LEVEL_ALL_MSGS indicates that the account can trip or reset the circuit // breaker for Msg's of all type URLs. CircuitBreakerPermissions_LEVEL_ALL_MSGS CircuitBreakerPermissions_Level = 2 // LEVEL_SUPER_ADMIN indicates that the account can take all circuit breaker // actions and can grant permissions to other accounts. CircuitBreakerPermissions_LEVEL_SUPER_ADMIN CircuitBreakerPermissions_Level = 3 )
func (CircuitBreakerPermissions_Level) EnumDescriptor ¶
func (CircuitBreakerPermissions_Level) EnumDescriptor() ([]byte, []int)
func (CircuitBreakerPermissions_Level) String ¶
func (x CircuitBreakerPermissions_Level) 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 *CircuitBreakerPermissions `protobuf:"bytes,3,opt,name=permissions,proto3" json:"permissions,omitempty"` }
MsgAuthorizeCircuitBreaker defines the Msg/AuthorizeCircuitBreaker request type.
func (*MsgAuthorizeCircuitBreaker) Descriptor ¶
func (*MsgAuthorizeCircuitBreaker) Descriptor() ([]byte, []int)
func (*MsgAuthorizeCircuitBreaker) GetGrantee ¶
func (m *MsgAuthorizeCircuitBreaker) GetGrantee() string
func (*MsgAuthorizeCircuitBreaker) GetGranter ¶
func (m *MsgAuthorizeCircuitBreaker) GetGranter() string
func (*MsgAuthorizeCircuitBreaker) GetPermissions ¶
func (m *MsgAuthorizeCircuitBreaker) GetPermissions() *CircuitBreakerPermissions
func (*MsgAuthorizeCircuitBreaker) Marshal ¶
func (m *MsgAuthorizeCircuitBreaker) Marshal() (dAtA []byte, err error)
func (*MsgAuthorizeCircuitBreaker) MarshalTo ¶
func (m *MsgAuthorizeCircuitBreaker) MarshalTo(dAtA []byte) (int, error)
func (*MsgAuthorizeCircuitBreaker) MarshalToSizedBuffer ¶
func (m *MsgAuthorizeCircuitBreaker) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgAuthorizeCircuitBreaker) ProtoMessage ¶
func (*MsgAuthorizeCircuitBreaker) ProtoMessage()
func (*MsgAuthorizeCircuitBreaker) Reset ¶
func (m *MsgAuthorizeCircuitBreaker) Reset()
func (*MsgAuthorizeCircuitBreaker) Size ¶
func (m *MsgAuthorizeCircuitBreaker) Size() (n int)
func (*MsgAuthorizeCircuitBreaker) String ¶
func (m *MsgAuthorizeCircuitBreaker) String() string
func (*MsgAuthorizeCircuitBreaker) Unmarshal ¶
func (m *MsgAuthorizeCircuitBreaker) Unmarshal(dAtA []byte) error
func (*MsgAuthorizeCircuitBreaker) XXX_DiscardUnknown ¶
func (m *MsgAuthorizeCircuitBreaker) XXX_DiscardUnknown()
func (*MsgAuthorizeCircuitBreaker) XXX_Marshal ¶
func (m *MsgAuthorizeCircuitBreaker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgAuthorizeCircuitBreaker) XXX_Merge ¶
func (m *MsgAuthorizeCircuitBreaker) XXX_Merge(src proto.Message)
func (*MsgAuthorizeCircuitBreaker) XXX_Size ¶
func (m *MsgAuthorizeCircuitBreaker) XXX_Size() int
func (*MsgAuthorizeCircuitBreaker) XXX_Unmarshal ¶
func (m *MsgAuthorizeCircuitBreaker) XXX_Unmarshal(b []byte) error
type MsgAuthorizeCircuitBreakerResponse ¶
type MsgAuthorizeCircuitBreakerResponse struct { }
MsgAuthorizeCircuitBreaker defines the Msg/AuthorizeCircuitBreaker response type.
func (*MsgAuthorizeCircuitBreakerResponse) Descriptor ¶
func (*MsgAuthorizeCircuitBreakerResponse) Descriptor() ([]byte, []int)
func (*MsgAuthorizeCircuitBreakerResponse) Marshal ¶
func (m *MsgAuthorizeCircuitBreakerResponse) Marshal() (dAtA []byte, err error)
func (*MsgAuthorizeCircuitBreakerResponse) MarshalTo ¶
func (m *MsgAuthorizeCircuitBreakerResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgAuthorizeCircuitBreakerResponse) MarshalToSizedBuffer ¶
func (m *MsgAuthorizeCircuitBreakerResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgAuthorizeCircuitBreakerResponse) ProtoMessage ¶
func (*MsgAuthorizeCircuitBreakerResponse) ProtoMessage()
func (*MsgAuthorizeCircuitBreakerResponse) Reset ¶
func (m *MsgAuthorizeCircuitBreakerResponse) Reset()
func (*MsgAuthorizeCircuitBreakerResponse) Size ¶
func (m *MsgAuthorizeCircuitBreakerResponse) Size() (n int)
func (*MsgAuthorizeCircuitBreakerResponse) String ¶
func (m *MsgAuthorizeCircuitBreakerResponse) String() string
func (*MsgAuthorizeCircuitBreakerResponse) Unmarshal ¶
func (m *MsgAuthorizeCircuitBreakerResponse) Unmarshal(dAtA []byte) error
func (*MsgAuthorizeCircuitBreakerResponse) XXX_DiscardUnknown ¶
func (m *MsgAuthorizeCircuitBreakerResponse) XXX_DiscardUnknown()
func (*MsgAuthorizeCircuitBreakerResponse) XXX_Marshal ¶
func (m *MsgAuthorizeCircuitBreakerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgAuthorizeCircuitBreakerResponse) XXX_Merge ¶
func (m *MsgAuthorizeCircuitBreakerResponse) XXX_Merge(src proto.Message)
func (*MsgAuthorizeCircuitBreakerResponse) XXX_Size ¶
func (m *MsgAuthorizeCircuitBreakerResponse) XXX_Size() int
func (*MsgAuthorizeCircuitBreakerResponse) XXX_Unmarshal ¶
func (m *MsgAuthorizeCircuitBreakerResponse) XXX_Unmarshal(b []byte) error
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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMsgClient ¶
func NewMsgClient(cc grpc1.ClientConn) 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"` }
MsgResetCircuitBreaker defines the Msg/ResetCircuitBreaker request type.
func (*MsgResetCircuitBreaker) Descriptor ¶
func (*MsgResetCircuitBreaker) Descriptor() ([]byte, []int)
func (*MsgResetCircuitBreaker) GetAuthority ¶
func (m *MsgResetCircuitBreaker) GetAuthority() string
func (*MsgResetCircuitBreaker) GetMsgTypeUrls ¶
func (m *MsgResetCircuitBreaker) GetMsgTypeUrls() []string
func (*MsgResetCircuitBreaker) Marshal ¶
func (m *MsgResetCircuitBreaker) Marshal() (dAtA []byte, err error)
func (*MsgResetCircuitBreaker) MarshalTo ¶
func (m *MsgResetCircuitBreaker) MarshalTo(dAtA []byte) (int, error)
func (*MsgResetCircuitBreaker) MarshalToSizedBuffer ¶
func (m *MsgResetCircuitBreaker) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgResetCircuitBreaker) ProtoMessage ¶
func (*MsgResetCircuitBreaker) ProtoMessage()
func (*MsgResetCircuitBreaker) Reset ¶
func (m *MsgResetCircuitBreaker) Reset()
func (*MsgResetCircuitBreaker) Size ¶
func (m *MsgResetCircuitBreaker) Size() (n int)
func (*MsgResetCircuitBreaker) String ¶
func (m *MsgResetCircuitBreaker) String() string
func (*MsgResetCircuitBreaker) Unmarshal ¶
func (m *MsgResetCircuitBreaker) Unmarshal(dAtA []byte) error
func (*MsgResetCircuitBreaker) XXX_DiscardUnknown ¶
func (m *MsgResetCircuitBreaker) XXX_DiscardUnknown()
func (*MsgResetCircuitBreaker) XXX_Marshal ¶
func (m *MsgResetCircuitBreaker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgResetCircuitBreaker) XXX_Merge ¶
func (m *MsgResetCircuitBreaker) XXX_Merge(src proto.Message)
func (*MsgResetCircuitBreaker) XXX_Size ¶
func (m *MsgResetCircuitBreaker) XXX_Size() int
func (*MsgResetCircuitBreaker) XXX_Unmarshal ¶
func (m *MsgResetCircuitBreaker) XXX_Unmarshal(b []byte) error
type MsgResetCircuitBreakerResponse ¶
type MsgResetCircuitBreakerResponse struct { }
MsgResetCircuitBreakerResponse defines the Msg/ResetCircuitBreaker response type.
func (*MsgResetCircuitBreakerResponse) Descriptor ¶
func (*MsgResetCircuitBreakerResponse) Descriptor() ([]byte, []int)
func (*MsgResetCircuitBreakerResponse) Marshal ¶
func (m *MsgResetCircuitBreakerResponse) Marshal() (dAtA []byte, err error)
func (*MsgResetCircuitBreakerResponse) MarshalTo ¶
func (m *MsgResetCircuitBreakerResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgResetCircuitBreakerResponse) MarshalToSizedBuffer ¶
func (m *MsgResetCircuitBreakerResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgResetCircuitBreakerResponse) ProtoMessage ¶
func (*MsgResetCircuitBreakerResponse) ProtoMessage()
func (*MsgResetCircuitBreakerResponse) Reset ¶
func (m *MsgResetCircuitBreakerResponse) Reset()
func (*MsgResetCircuitBreakerResponse) Size ¶
func (m *MsgResetCircuitBreakerResponse) Size() (n int)
func (*MsgResetCircuitBreakerResponse) String ¶
func (m *MsgResetCircuitBreakerResponse) String() string
func (*MsgResetCircuitBreakerResponse) Unmarshal ¶
func (m *MsgResetCircuitBreakerResponse) Unmarshal(dAtA []byte) error
func (*MsgResetCircuitBreakerResponse) XXX_DiscardUnknown ¶
func (m *MsgResetCircuitBreakerResponse) XXX_DiscardUnknown()
func (*MsgResetCircuitBreakerResponse) XXX_Marshal ¶
func (m *MsgResetCircuitBreakerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgResetCircuitBreakerResponse) XXX_Merge ¶
func (m *MsgResetCircuitBreakerResponse) XXX_Merge(src proto.Message)
func (*MsgResetCircuitBreakerResponse) XXX_Size ¶
func (m *MsgResetCircuitBreakerResponse) XXX_Size() int
func (*MsgResetCircuitBreakerResponse) XXX_Unmarshal ¶
func (m *MsgResetCircuitBreakerResponse) XXX_Unmarshal(b []byte) error
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) }
MsgServer is the server API for Msg service.
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"` }
MsgTripCircuitBreaker defines the Msg/TripCircuitBreaker request type.
func (*MsgTripCircuitBreaker) Descriptor ¶
func (*MsgTripCircuitBreaker) Descriptor() ([]byte, []int)
func (*MsgTripCircuitBreaker) GetAuthority ¶
func (m *MsgTripCircuitBreaker) GetAuthority() string
func (*MsgTripCircuitBreaker) GetMsgTypeUrls ¶
func (m *MsgTripCircuitBreaker) GetMsgTypeUrls() []string
func (*MsgTripCircuitBreaker) Marshal ¶
func (m *MsgTripCircuitBreaker) Marshal() (dAtA []byte, err error)
func (*MsgTripCircuitBreaker) MarshalTo ¶
func (m *MsgTripCircuitBreaker) MarshalTo(dAtA []byte) (int, error)
func (*MsgTripCircuitBreaker) MarshalToSizedBuffer ¶
func (m *MsgTripCircuitBreaker) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgTripCircuitBreaker) ProtoMessage ¶
func (*MsgTripCircuitBreaker) ProtoMessage()
func (*MsgTripCircuitBreaker) Reset ¶
func (m *MsgTripCircuitBreaker) Reset()
func (*MsgTripCircuitBreaker) Size ¶
func (m *MsgTripCircuitBreaker) Size() (n int)
func (*MsgTripCircuitBreaker) String ¶
func (m *MsgTripCircuitBreaker) String() string
func (*MsgTripCircuitBreaker) Unmarshal ¶
func (m *MsgTripCircuitBreaker) Unmarshal(dAtA []byte) error
func (*MsgTripCircuitBreaker) XXX_DiscardUnknown ¶
func (m *MsgTripCircuitBreaker) XXX_DiscardUnknown()
func (*MsgTripCircuitBreaker) XXX_Marshal ¶
func (m *MsgTripCircuitBreaker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgTripCircuitBreaker) XXX_Merge ¶
func (m *MsgTripCircuitBreaker) XXX_Merge(src proto.Message)
func (*MsgTripCircuitBreaker) XXX_Size ¶
func (m *MsgTripCircuitBreaker) XXX_Size() int
func (*MsgTripCircuitBreaker) XXX_Unmarshal ¶
func (m *MsgTripCircuitBreaker) XXX_Unmarshal(b []byte) error
type MsgTripCircuitBreakerResponse ¶
type MsgTripCircuitBreakerResponse struct { }
MsgTripCircuitBreaker defines the Msg/TripCircuitBreaker response type.
func (*MsgTripCircuitBreakerResponse) Descriptor ¶
func (*MsgTripCircuitBreakerResponse) Descriptor() ([]byte, []int)
func (*MsgTripCircuitBreakerResponse) Marshal ¶
func (m *MsgTripCircuitBreakerResponse) Marshal() (dAtA []byte, err error)
func (*MsgTripCircuitBreakerResponse) MarshalTo ¶
func (m *MsgTripCircuitBreakerResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgTripCircuitBreakerResponse) MarshalToSizedBuffer ¶
func (m *MsgTripCircuitBreakerResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgTripCircuitBreakerResponse) ProtoMessage ¶
func (*MsgTripCircuitBreakerResponse) ProtoMessage()
func (*MsgTripCircuitBreakerResponse) Reset ¶
func (m *MsgTripCircuitBreakerResponse) Reset()
func (*MsgTripCircuitBreakerResponse) Size ¶
func (m *MsgTripCircuitBreakerResponse) Size() (n int)
func (*MsgTripCircuitBreakerResponse) String ¶
func (m *MsgTripCircuitBreakerResponse) String() string
func (*MsgTripCircuitBreakerResponse) Unmarshal ¶
func (m *MsgTripCircuitBreakerResponse) Unmarshal(dAtA []byte) error
func (*MsgTripCircuitBreakerResponse) XXX_DiscardUnknown ¶
func (m *MsgTripCircuitBreakerResponse) XXX_DiscardUnknown()
func (*MsgTripCircuitBreakerResponse) XXX_Marshal ¶
func (m *MsgTripCircuitBreakerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgTripCircuitBreakerResponse) XXX_Merge ¶
func (m *MsgTripCircuitBreakerResponse) XXX_Merge(src proto.Message)
func (*MsgTripCircuitBreakerResponse) XXX_Size ¶
func (m *MsgTripCircuitBreakerResponse) XXX_Size() int
func (*MsgTripCircuitBreakerResponse) XXX_Unmarshal ¶
func (m *MsgTripCircuitBreakerResponse) XXX_Unmarshal(b []byte) error
type UnimplementedMsgServer ¶
type UnimplementedMsgServer struct { }
UnimplementedMsgServer can be embedded to have forward compatible implementations.
func (*UnimplementedMsgServer) AuthorizeCircuitBreaker ¶
func (*UnimplementedMsgServer) AuthorizeCircuitBreaker(ctx context.Context, req *MsgAuthorizeCircuitBreaker) (*MsgAuthorizeCircuitBreakerResponse, error)
func (*UnimplementedMsgServer) ResetCircuitBreaker ¶
func (*UnimplementedMsgServer) ResetCircuitBreaker(ctx context.Context, req *MsgResetCircuitBreaker) (*MsgResetCircuitBreakerResponse, error)
func (*UnimplementedMsgServer) TripCircuitBreaker ¶
func (*UnimplementedMsgServer) TripCircuitBreaker(ctx context.Context, req *MsgTripCircuitBreaker) (*MsgTripCircuitBreakerResponse, error)