circuitv1

package
v0.3.1 Latest Latest
Warning

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

 Go to latest Published: Feb 16, 2023 License: Apache-2.0 Imports: 13 Imported by: 1

Documentation

Overview

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

Index

Constants

This section is empty.

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 (x *CircuitBreakerPermissions) GetLevel() CircuitBreakerPermissions_Level

func (*CircuitBreakerPermissions) GetLimitMsgTypes 

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

func (*CircuitBreakerPermissions) ProtoMessage 

func (*CircuitBreakerPermissions) ProtoMessage()

func (*CircuitBreakerPermissions) ProtoReflect 

func (x *CircuitBreakerPermissions) ProtoReflect() protoreflect.Message

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) Descriptor() protoreflect.EnumDescriptor

func (CircuitBreakerPermissions_Level) Enum 

func (x CircuitBreakerPermissions_Level) Enum() *CircuitBreakerPermissions_Level

func (CircuitBreakerPermissions_Level) EnumDescriptor deprecated 

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

Deprecated: Use CircuitBreakerPermissions_Level.Descriptor instead.

func (CircuitBreakerPermissions_Level) Number 

func (x CircuitBreakerPermissions_Level) Number() protoreflect.EnumNumber

func (CircuitBreakerPermissions_Level) String 

func (x CircuitBreakerPermissions_Level) String() string

func (CircuitBreakerPermissions_Level) Type 

func (CircuitBreakerPermissions_Level) Type() protoreflect.EnumType

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 (x *MsgAuthorizeCircuitBreaker) GetPermissions() *CircuitBreakerPermissions

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 {
	// 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 (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 {
	// 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 (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 {
	// 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 (x *MsgTripCircuitBreakerResponse) ProtoReflect() protoreflect.Message

func (*MsgTripCircuitBreakerResponse) Reset 

func (x *MsgTripCircuitBreakerResponse) Reset()

func (*MsgTripCircuitBreakerResponse) String 

func (x *MsgTripCircuitBreakerResponse) String() string

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 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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.