circuitv1

package
v0.0.0-...-095f669 Latest Latest
Warning

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

Go to latest
Published: Mar 7, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Overview

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Index

Constants

View Source
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

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",
	}
	CircuitBreakerPermissions_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 CircuitBreakerPermissions_Level.

View Source
var File_cosmos_circuit_v1_tx_proto protoreflect.FileDescriptor
View Source
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)

Functions

func RegisterMsgServer

func RegisterMsgServer(s grpc.ServiceRegistrar, 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_msg_types is used with LEVEL_SOME_MSGS to limit the lists of Msg type
	// name that the account can pause. It is an error to use limit_msg_types with
	// a level other than LEVEL_SOME_MSGS.
	LimitMsgTypes []string `protobuf:"bytes,2,rep,name=limit_msg_types,json=limitMsgTypes,proto3" json:"limit_msg_types,omitempty"`
	// contains filtered or unexported fields
}

CircuitBreakerPermissions are the permissions that an account has to trip or reset the circuit breaker.

func (*CircuitBreakerPermissions) Descriptor deprecated

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

Deprecated: Use CircuitBreakerPermissions.ProtoReflect.Descriptor instead.

func (*CircuitBreakerPermissions) GetLevel

func (*CircuitBreakerPermissions) GetLimitMsgTypes

func (x *CircuitBreakerPermissions) GetLimitMsgTypes() []string

func (*CircuitBreakerPermissions) ProtoMessage

func (*CircuitBreakerPermissions) ProtoMessage()

func (*CircuitBreakerPermissions) ProtoReflect

func (*CircuitBreakerPermissions) Reset

func (x *CircuitBreakerPermissions) Reset()

func (*CircuitBreakerPermissions) String

func (x *CircuitBreakerPermissions) String() string

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

func (CircuitBreakerPermissions_Level) Enum

func (CircuitBreakerPermissions_Level) EnumDescriptor deprecated

func (CircuitBreakerPermissions_Level) EnumDescriptor() ([]byte, []int)

Deprecated: Use CircuitBreakerPermissions_Level.Descriptor instead.

func (CircuitBreakerPermissions_Level) Number

func (CircuitBreakerPermissions_Level) String

func (CircuitBreakerPermissions_Level) Type

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"`
	// 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 (*MsgAuthorizeCircuitBreaker) ProtoMessage

func (*MsgAuthorizeCircuitBreaker) ProtoMessage()

func (*MsgAuthorizeCircuitBreaker) ProtoReflect

func (*MsgAuthorizeCircuitBreaker) Reset

func (x *MsgAuthorizeCircuitBreaker) Reset()

func (*MsgAuthorizeCircuitBreaker) String

func (x *MsgAuthorizeCircuitBreaker) String() string

type MsgAuthorizeCircuitBreakerResponse

type MsgAuthorizeCircuitBreakerResponse struct {
	// contains filtered or unexported fields
}

MsgAuthorizeCircuitBreaker defines the Msg/AuthorizeCircuitBreaker response type.

func (*MsgAuthorizeCircuitBreakerResponse) Descriptor deprecated

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

Deprecated: Use MsgAuthorizeCircuitBreakerResponse.ProtoReflect.Descriptor instead.

func (*MsgAuthorizeCircuitBreakerResponse) ProtoMessage

func (*MsgAuthorizeCircuitBreakerResponse) ProtoMessage()

func (*MsgAuthorizeCircuitBreakerResponse) ProtoReflect

func (*MsgAuthorizeCircuitBreakerResponse) Reset

func (*MsgAuthorizeCircuitBreakerResponse) 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 {
	// 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) ProtoMessage

func (*MsgResetCircuitBreakerResponse) ProtoMessage()

func (*MsgResetCircuitBreakerResponse) ProtoReflect

func (*MsgResetCircuitBreakerResponse) Reset

func (x *MsgResetCircuitBreakerResponse) Reset()

func (*MsgResetCircuitBreakerResponse) 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 {
	// contains filtered or unexported fields
}

MsgTripCircuitBreaker defines the Msg/TripCircuitBreaker response type.

func (*MsgTripCircuitBreakerResponse) Descriptor deprecated

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

Deprecated: Use MsgTripCircuitBreakerResponse.ProtoReflect.Descriptor instead.

func (*MsgTripCircuitBreakerResponse) ProtoMessage

func (*MsgTripCircuitBreakerResponse) ProtoMessage()

func (*MsgTripCircuitBreakerResponse) ProtoReflect

func (*MsgTripCircuitBreakerResponse) Reset

func (x *MsgTripCircuitBreakerResponse) Reset()

func (*MsgTripCircuitBreakerResponse) String

type UnimplementedMsgServer

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer must be embedded to have forward compatible implementations.

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.

Jump to

Keyboard shortcuts

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