types

package
v0.48.86 Latest Latest
Warning

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

Go to latest
Published: Oct 24, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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 CircuitBreakerPermissions_Level_name = map[int32]string{
	0: "LEVEL_NONE_UNSPECIFIED",
	1: "LEVEL_SOME_MSGS",
	2: "LEVEL_ALL_MSGS",
	3: "LEVEL_SUPER_ADMIN",
}
View Source
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

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

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 (*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

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 (*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 (*MsgAuthorizeCircuitBreakerResponse) Size

func (*MsgAuthorizeCircuitBreakerResponse) 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 (*MsgAuthorizeCircuitBreakerResponse) XXX_Size

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 (*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 (*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) ResetCircuitBreaker

func (*UnimplementedMsgServer) TripCircuitBreaker

Jump to

Keyboard shortcuts

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