proxy

package
v0.0.0-...-1334a7b Latest Latest
Warning

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

 Go to latest Published: Dec 21, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ControllerProxy_CreateEventbus_FullMethodName                = "/vanus.core.proxy.ControllerProxy/CreateEventbus"
	ControllerProxy_CreateSystemEventbus_FullMethodName          = "/vanus.core.proxy.ControllerProxy/CreateSystemEventbus"
	ControllerProxy_DeleteEventbus_FullMethodName                = "/vanus.core.proxy.ControllerProxy/DeleteEventbus"
	ControllerProxy_GetEventbus_FullMethodName                   = "/vanus.core.proxy.ControllerProxy/GetEventbus"
	ControllerProxy_ListEventbus_FullMethodName                  = "/vanus.core.proxy.ControllerProxy/ListEventbus"
	ControllerProxy_UpdateEventbus_FullMethodName                = "/vanus.core.proxy.ControllerProxy/UpdateEventbus"
	ControllerProxy_GetEventbusWithHumanFriendly_FullMethodName  = "/vanus.core.proxy.ControllerProxy/GetEventbusWithHumanFriendly"
	ControllerProxy_ListSegment_FullMethodName                   = "/vanus.core.proxy.ControllerProxy/ListSegment"
	ControllerProxy_ValidateEventbus_FullMethodName              = "/vanus.core.proxy.ControllerProxy/ValidateEventbus"
	ControllerProxy_CreateSubscription_FullMethodName            = "/vanus.core.proxy.ControllerProxy/CreateSubscription"
	ControllerProxy_UpdateSubscription_FullMethodName            = "/vanus.core.proxy.ControllerProxy/UpdateSubscription"
	ControllerProxy_DeleteSubscription_FullMethodName            = "/vanus.core.proxy.ControllerProxy/DeleteSubscription"
	ControllerProxy_GetSubscription_FullMethodName               = "/vanus.core.proxy.ControllerProxy/GetSubscription"
	ControllerProxy_ListSubscription_FullMethodName              = "/vanus.core.proxy.ControllerProxy/ListSubscription"
	ControllerProxy_DisableSubscription_FullMethodName           = "/vanus.core.proxy.ControllerProxy/DisableSubscription"
	ControllerProxy_ResumeSubscription_FullMethodName            = "/vanus.core.proxy.ControllerProxy/ResumeSubscription"
	ControllerProxy_ResetOffsetToTimestamp_FullMethodName        = "/vanus.core.proxy.ControllerProxy/ResetOffsetToTimestamp"
	ControllerProxy_ClusterInfo_FullMethodName                   = "/vanus.core.proxy.ControllerProxy/ClusterInfo"
	ControllerProxy_LookupOffset_FullMethodName                  = "/vanus.core.proxy.ControllerProxy/LookupOffset"
	ControllerProxy_GetEvent_FullMethodName                      = "/vanus.core.proxy.ControllerProxy/GetEvent"
	ControllerProxy_ValidateSubscription_FullMethodName          = "/vanus.core.proxy.ControllerProxy/ValidateSubscription"
	ControllerProxy_GetDeadLetterEvent_FullMethodName            = "/vanus.core.proxy.ControllerProxy/GetDeadLetterEvent"
	ControllerProxy_ResendDeadLetterEvent_FullMethodName         = "/vanus.core.proxy.ControllerProxy/ResendDeadLetterEvent"
	ControllerProxy_SetDeadLetterEventOffset_FullMethodName      = "/vanus.core.proxy.ControllerProxy/SetDeadLetterEventOffset"
	ControllerProxy_GetNamespaceWithHumanFriendly_FullMethodName = "/vanus.core.proxy.ControllerProxy/GetNamespaceWithHumanFriendly"
	ControllerProxy_CreateNamespace_FullMethodName               = "/vanus.core.proxy.ControllerProxy/CreateNamespace"
	ControllerProxy_ListNamespace_FullMethodName                 = "/vanus.core.proxy.ControllerProxy/ListNamespace"
	ControllerProxy_GetNamespace_FullMethodName                  = "/vanus.core.proxy.ControllerProxy/GetNamespace"
	ControllerProxy_DeleteNamespace_FullMethodName               = "/vanus.core.proxy.ControllerProxy/DeleteNamespace"
	ControllerProxy_CreateUser_FullMethodName                    = "/vanus.core.proxy.ControllerProxy/CreateUser"
	ControllerProxy_DeleteUser_FullMethodName                    = "/vanus.core.proxy.ControllerProxy/DeleteUser"
	ControllerProxy_GetUser_FullMethodName                       = "/vanus.core.proxy.ControllerProxy/GetUser"
	ControllerProxy_ListUser_FullMethodName                      = "/vanus.core.proxy.ControllerProxy/ListUser"
	ControllerProxy_CreateToken_FullMethodName                   = "/vanus.core.proxy.ControllerProxy/CreateToken"
	ControllerProxy_DeleteToken_FullMethodName                   = "/vanus.core.proxy.ControllerProxy/DeleteToken"
	ControllerProxy_GetUserToken_FullMethodName                  = "/vanus.core.proxy.ControllerProxy/GetUserToken"
	ControllerProxy_ListToken_FullMethodName                     = "/vanus.core.proxy.ControllerProxy/ListToken"
	ControllerProxy_GrantRole_FullMethodName                     = "/vanus.core.proxy.ControllerProxy/GrantRole"
	ControllerProxy_RevokeRole_FullMethodName                    = "/vanus.core.proxy.ControllerProxy/RevokeRole"
	ControllerProxy_GetUserRole_FullMethodName                   = "/vanus.core.proxy.ControllerProxy/GetUserRole"
	ControllerProxy_GetResourceRole_FullMethodName               = "/vanus.core.proxy.ControllerProxy/GetResourceRole"
)
View Source 
const (
	StoreProxy_Publish_FullMethodName   = "/vanus.core.proxy.StoreProxy/Publish"
	StoreProxy_Subscribe_FullMethodName = "/vanus.core.proxy.StoreProxy/Subscribe"
	StoreProxy_Ack_FullMethodName       = "/vanus.core.proxy.StoreProxy/Ack"
)

Variables

View Source 
var ControllerProxy_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vanus.core.proxy.ControllerProxy",
	HandlerType: (*ControllerProxyServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateEventbus",
			Handler:    _ControllerProxy_CreateEventbus_Handler,
		},
		{
			MethodName: "CreateSystemEventbus",
			Handler:    _ControllerProxy_CreateSystemEventbus_Handler,
		},
		{
			MethodName: "DeleteEventbus",
			Handler:    _ControllerProxy_DeleteEventbus_Handler,
		},
		{
			MethodName: "GetEventbus",
			Handler:    _ControllerProxy_GetEventbus_Handler,
		},
		{
			MethodName: "ListEventbus",
			Handler:    _ControllerProxy_ListEventbus_Handler,
		},
		{
			MethodName: "UpdateEventbus",
			Handler:    _ControllerProxy_UpdateEventbus_Handler,
		},
		{
			MethodName: "GetEventbusWithHumanFriendly",
			Handler:    _ControllerProxy_GetEventbusWithHumanFriendly_Handler,
		},
		{
			MethodName: "ListSegment",
			Handler:    _ControllerProxy_ListSegment_Handler,
		},
		{
			MethodName: "ValidateEventbus",
			Handler:    _ControllerProxy_ValidateEventbus_Handler,
		},
		{
			MethodName: "CreateSubscription",
			Handler:    _ControllerProxy_CreateSubscription_Handler,
		},
		{
			MethodName: "UpdateSubscription",
			Handler:    _ControllerProxy_UpdateSubscription_Handler,
		},
		{
			MethodName: "DeleteSubscription",
			Handler:    _ControllerProxy_DeleteSubscription_Handler,
		},
		{
			MethodName: "GetSubscription",
			Handler:    _ControllerProxy_GetSubscription_Handler,
		},
		{
			MethodName: "ListSubscription",
			Handler:    _ControllerProxy_ListSubscription_Handler,
		},
		{
			MethodName: "DisableSubscription",
			Handler:    _ControllerProxy_DisableSubscription_Handler,
		},
		{
			MethodName: "ResumeSubscription",
			Handler:    _ControllerProxy_ResumeSubscription_Handler,
		},
		{
			MethodName: "ResetOffsetToTimestamp",
			Handler:    _ControllerProxy_ResetOffsetToTimestamp_Handler,
		},
		{
			MethodName: "ClusterInfo",
			Handler:    _ControllerProxy_ClusterInfo_Handler,
		},
		{
			MethodName: "LookupOffset",
			Handler:    _ControllerProxy_LookupOffset_Handler,
		},
		{
			MethodName: "GetEvent",
			Handler:    _ControllerProxy_GetEvent_Handler,
		},
		{
			MethodName: "ValidateSubscription",
			Handler:    _ControllerProxy_ValidateSubscription_Handler,
		},
		{
			MethodName: "GetDeadLetterEvent",
			Handler:    _ControllerProxy_GetDeadLetterEvent_Handler,
		},
		{
			MethodName: "ResendDeadLetterEvent",
			Handler:    _ControllerProxy_ResendDeadLetterEvent_Handler,
		},
		{
			MethodName: "SetDeadLetterEventOffset",
			Handler:    _ControllerProxy_SetDeadLetterEventOffset_Handler,
		},
		{
			MethodName: "GetNamespaceWithHumanFriendly",
			Handler:    _ControllerProxy_GetNamespaceWithHumanFriendly_Handler,
		},
		{
			MethodName: "CreateNamespace",
			Handler:    _ControllerProxy_CreateNamespace_Handler,
		},
		{
			MethodName: "ListNamespace",
			Handler:    _ControllerProxy_ListNamespace_Handler,
		},
		{
			MethodName: "GetNamespace",
			Handler:    _ControllerProxy_GetNamespace_Handler,
		},
		{
			MethodName: "DeleteNamespace",
			Handler:    _ControllerProxy_DeleteNamespace_Handler,
		},
		{
			MethodName: "CreateUser",
			Handler:    _ControllerProxy_CreateUser_Handler,
		},
		{
			MethodName: "DeleteUser",
			Handler:    _ControllerProxy_DeleteUser_Handler,
		},
		{
			MethodName: "GetUser",
			Handler:    _ControllerProxy_GetUser_Handler,
		},
		{
			MethodName: "ListUser",
			Handler:    _ControllerProxy_ListUser_Handler,
		},
		{
			MethodName: "CreateToken",
			Handler:    _ControllerProxy_CreateToken_Handler,
		},
		{
			MethodName: "DeleteToken",
			Handler:    _ControllerProxy_DeleteToken_Handler,
		},
		{
			MethodName: "GetUserToken",
			Handler:    _ControllerProxy_GetUserToken_Handler,
		},
		{
			MethodName: "ListToken",
			Handler:    _ControllerProxy_ListToken_Handler,
		},
		{
			MethodName: "GrantRole",
			Handler:    _ControllerProxy_GrantRole_Handler,
		},
		{
			MethodName: "RevokeRole",
			Handler:    _ControllerProxy_RevokeRole_Handler,
		},
		{
			MethodName: "GetUserRole",
			Handler:    _ControllerProxy_GetUserRole_Handler,
		},
		{
			MethodName: "GetResourceRole",
			Handler:    _ControllerProxy_GetResourceRole_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "vanus/core/proxy/proxy.proto",
}

ControllerProxy_ServiceDesc is the grpc.ServiceDesc for ControllerProxy service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_vanus_core_proxy_proxy_proto protoreflect.FileDescriptor
View Source 
var StoreProxy_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vanus.core.proxy.StoreProxy",
	HandlerType: (*StoreProxyServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Publish",
			Handler:    _StoreProxy_Publish_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Subscribe",
			Handler:       _StoreProxy_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Ack",
			Handler:       _StoreProxy_Ack_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "vanus/core/proxy/proxy.proto",
}

StoreProxy_ServiceDesc is the grpc.ServiceDesc for StoreProxy service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterControllerProxyServer 

func RegisterControllerProxyServer(s grpc.ServiceRegistrar, srv ControllerProxyServer)

func RegisterStoreProxyServer 

func RegisterStoreProxyServer(s grpc.ServiceRegistrar, srv StoreProxyServer)

Types

type AckRequest 

type AckRequest struct {
	SequenceId     uint64 `protobuf:"varint,1,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"`
	SubscriptionId string `protobuf:"bytes,2,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	Success        bool   `protobuf:"varint,3,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*AckRequest) Descriptor deprecated 

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

Deprecated: Use AckRequest.ProtoReflect.Descriptor instead.

func (*AckRequest) GetSequenceId 

func (x *AckRequest) GetSequenceId() uint64

func (*AckRequest) GetSubscriptionId 

func (x *AckRequest) GetSubscriptionId() string

func (*AckRequest) GetSuccess 

func (x *AckRequest) GetSuccess() bool

func (*AckRequest) ProtoMessage 

func (*AckRequest) ProtoMessage()

func (*AckRequest) ProtoReflect 

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

func (*AckRequest) Reset 

func (x *AckRequest) Reset()

func (*AckRequest) String 

func (x *AckRequest) String() string

type ClusterInfoResponse 

type ClusterInfoResponse struct {
	CloudeventsPort int64 `protobuf:"varint,1,opt,name=cloudevents_port,json=cloudeventsPort,proto3" json:"cloudevents_port,omitempty"`
	ProxyPort       int64 `protobuf:"varint,2,opt,name=proxy_port,json=proxyPort,proto3" json:"proxy_port,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterInfoResponse) Descriptor deprecated 

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

Deprecated: Use ClusterInfoResponse.ProtoReflect.Descriptor instead.

func (*ClusterInfoResponse) GetCloudeventsPort 

func (x *ClusterInfoResponse) GetCloudeventsPort() int64

func (*ClusterInfoResponse) GetProxyPort 

func (x *ClusterInfoResponse) GetProxyPort() int64

func (*ClusterInfoResponse) ProtoMessage 

func (*ClusterInfoResponse) ProtoMessage()

func (*ClusterInfoResponse) ProtoReflect 

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

func (*ClusterInfoResponse) Reset 

func (x *ClusterInfoResponse) Reset()

func (*ClusterInfoResponse) String 

func (x *ClusterInfoResponse) String() string

type ControllerProxyClient 

type ControllerProxyClient interface {
	// Eventbus
	CreateEventbus(ctx context.Context, in *controller.CreateEventbusRequest, opts ...grpc.CallOption) (*meta.Eventbus, error)
	CreateSystemEventbus(ctx context.Context, in *controller.CreateEventbusRequest, opts ...grpc.CallOption) (*meta.Eventbus, error)
	DeleteEventbus(ctx context.Context, in *wrapperspb.UInt64Value, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetEventbus(ctx context.Context, in *wrapperspb.UInt64Value, opts ...grpc.CallOption) (*meta.Eventbus, error)
	ListEventbus(ctx context.Context, in *controller.ListEventbusRequest, opts ...grpc.CallOption) (*controller.ListEventbusResponse, error)
	UpdateEventbus(ctx context.Context, in *controller.UpdateEventbusRequest, opts ...grpc.CallOption) (*meta.Eventbus, error)
	GetEventbusWithHumanFriendly(ctx context.Context, in *controller.GetEventbusWithHumanFriendlyRequest, opts ...grpc.CallOption) (*meta.Eventbus, error)
	ListSegment(ctx context.Context, in *controller.ListSegmentRequest, opts ...grpc.CallOption) (*controller.ListSegmentResponse, error)
	ValidateEventbus(ctx context.Context, in *ValidateEventbusRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Trigger
	CreateSubscription(ctx context.Context, in *controller.CreateSubscriptionRequest, opts ...grpc.CallOption) (*meta.Subscription, error)
	UpdateSubscription(ctx context.Context, in *controller.UpdateSubscriptionRequest, opts ...grpc.CallOption) (*meta.Subscription, error)
	DeleteSubscription(ctx context.Context, in *controller.DeleteSubscriptionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetSubscription(ctx context.Context, in *controller.GetSubscriptionRequest, opts ...grpc.CallOption) (*meta.Subscription, error)
	ListSubscription(ctx context.Context, in *controller.ListSubscriptionRequest, opts ...grpc.CallOption) (*controller.ListSubscriptionResponse, error)
	DisableSubscription(ctx context.Context, in *controller.DisableSubscriptionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ResumeSubscription(ctx context.Context, in *controller.ResumeSubscriptionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ResetOffsetToTimestamp(ctx context.Context, in *controller.ResetOffsetToTimestampRequest, opts ...grpc.CallOption) (*controller.ResetOffsetToTimestampResponse, error)
	// custom
	ClusterInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ClusterInfoResponse, error)
	LookupOffset(ctx context.Context, in *LookupOffsetRequest, opts ...grpc.CallOption) (*LookupOffsetResponse, error)
	GetEvent(ctx context.Context, in *GetEventRequest, opts ...grpc.CallOption) (*GetEventResponse, error)
	ValidateSubscription(ctx context.Context, in *ValidateSubscriptionRequest, opts ...grpc.CallOption) (*ValidateSubscriptionResponse, error)
	// dead letter
	GetDeadLetterEvent(ctx context.Context, in *GetDeadLetterEventRequest, opts ...grpc.CallOption) (*GetDeadLetterEventResponse, error)
	ResendDeadLetterEvent(ctx context.Context, in *ResendDeadLetterEventRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SetDeadLetterEventOffset(ctx context.Context, in *controller.SetDeadLetterEventOffsetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// multiple tenant
	GetNamespaceWithHumanFriendly(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*meta.Namespace, error)
	CreateNamespace(ctx context.Context, in *controller.CreateNamespaceRequest, opts ...grpc.CallOption) (*meta.Namespace, error)
	ListNamespace(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*controller.ListNamespaceResponse, error)
	GetNamespace(ctx context.Context, in *controller.GetNamespaceRequest, opts ...grpc.CallOption) (*meta.Namespace, error)
	DeleteNamespace(ctx context.Context, in *controller.DeleteNamespaceRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	CreateUser(ctx context.Context, in *controller.CreateUserRequest, opts ...grpc.CallOption) (*meta.User, error)
	DeleteUser(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetUser(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*meta.User, error)
	ListUser(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*controller.ListUserResponse, error)
	CreateToken(ctx context.Context, in *controller.CreateTokenRequest, opts ...grpc.CallOption) (*meta.Token, error)
	DeleteToken(ctx context.Context, in *controller.DeleteTokenRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetUserToken(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*controller.GetTokenResponse, error)
	ListToken(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*controller.ListTokenResponse, error)
	GrantRole(ctx context.Context, in *controller.RoleRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RevokeRole(ctx context.Context, in *controller.RoleRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetUserRole(ctx context.Context, in *controller.GetUserRoleRequest, opts ...grpc.CallOption) (*controller.GetUserRoleResponse, error)
	GetResourceRole(ctx context.Context, in *controller.GetResourceRoleRequest, opts ...grpc.CallOption) (*controller.GetResourceRoleResponse, error)
}

ControllerProxyClient is the client API for ControllerProxy 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 NewControllerProxyClient 

func NewControllerProxyClient(cc grpc.ClientConnInterface) ControllerProxyClient

type ControllerProxyServer 

type ControllerProxyServer interface {
	// Eventbus
	CreateEventbus(context.Context, *controller.CreateEventbusRequest) (*meta.Eventbus, error)
	CreateSystemEventbus(context.Context, *controller.CreateEventbusRequest) (*meta.Eventbus, error)
	DeleteEventbus(context.Context, *wrapperspb.UInt64Value) (*emptypb.Empty, error)
	GetEventbus(context.Context, *wrapperspb.UInt64Value) (*meta.Eventbus, error)
	ListEventbus(context.Context, *controller.ListEventbusRequest) (*controller.ListEventbusResponse, error)
	UpdateEventbus(context.Context, *controller.UpdateEventbusRequest) (*meta.Eventbus, error)
	GetEventbusWithHumanFriendly(context.Context, *controller.GetEventbusWithHumanFriendlyRequest) (*meta.Eventbus, error)
	ListSegment(context.Context, *controller.ListSegmentRequest) (*controller.ListSegmentResponse, error)
	ValidateEventbus(context.Context, *ValidateEventbusRequest) (*emptypb.Empty, error)
	// Trigger
	CreateSubscription(context.Context, *controller.CreateSubscriptionRequest) (*meta.Subscription, error)
	UpdateSubscription(context.Context, *controller.UpdateSubscriptionRequest) (*meta.Subscription, error)
	DeleteSubscription(context.Context, *controller.DeleteSubscriptionRequest) (*emptypb.Empty, error)
	GetSubscription(context.Context, *controller.GetSubscriptionRequest) (*meta.Subscription, error)
	ListSubscription(context.Context, *controller.ListSubscriptionRequest) (*controller.ListSubscriptionResponse, error)
	DisableSubscription(context.Context, *controller.DisableSubscriptionRequest) (*emptypb.Empty, error)
	ResumeSubscription(context.Context, *controller.ResumeSubscriptionRequest) (*emptypb.Empty, error)
	ResetOffsetToTimestamp(context.Context, *controller.ResetOffsetToTimestampRequest) (*controller.ResetOffsetToTimestampResponse, error)
	// custom
	ClusterInfo(context.Context, *emptypb.Empty) (*ClusterInfoResponse, error)
	LookupOffset(context.Context, *LookupOffsetRequest) (*LookupOffsetResponse, error)
	GetEvent(context.Context, *GetEventRequest) (*GetEventResponse, error)
	ValidateSubscription(context.Context, *ValidateSubscriptionRequest) (*ValidateSubscriptionResponse, error)
	// dead letter
	GetDeadLetterEvent(context.Context, *GetDeadLetterEventRequest) (*GetDeadLetterEventResponse, error)
	ResendDeadLetterEvent(context.Context, *ResendDeadLetterEventRequest) (*emptypb.Empty, error)
	SetDeadLetterEventOffset(context.Context, *controller.SetDeadLetterEventOffsetRequest) (*emptypb.Empty, error)
	// multiple tenant
	GetNamespaceWithHumanFriendly(context.Context, *wrapperspb.StringValue) (*meta.Namespace, error)
	CreateNamespace(context.Context, *controller.CreateNamespaceRequest) (*meta.Namespace, error)
	ListNamespace(context.Context, *emptypb.Empty) (*controller.ListNamespaceResponse, error)
	GetNamespace(context.Context, *controller.GetNamespaceRequest) (*meta.Namespace, error)
	DeleteNamespace(context.Context, *controller.DeleteNamespaceRequest) (*emptypb.Empty, error)
	CreateUser(context.Context, *controller.CreateUserRequest) (*meta.User, error)
	DeleteUser(context.Context, *wrapperspb.StringValue) (*emptypb.Empty, error)
	GetUser(context.Context, *wrapperspb.StringValue) (*meta.User, error)
	ListUser(context.Context, *emptypb.Empty) (*controller.ListUserResponse, error)
	CreateToken(context.Context, *controller.CreateTokenRequest) (*meta.Token, error)
	DeleteToken(context.Context, *controller.DeleteTokenRequest) (*emptypb.Empty, error)
	GetUserToken(context.Context, *wrapperspb.StringValue) (*controller.GetTokenResponse, error)
	ListToken(context.Context, *emptypb.Empty) (*controller.ListTokenResponse, error)
	GrantRole(context.Context, *controller.RoleRequest) (*emptypb.Empty, error)
	RevokeRole(context.Context, *controller.RoleRequest) (*emptypb.Empty, error)
	GetUserRole(context.Context, *controller.GetUserRoleRequest) (*controller.GetUserRoleResponse, error)
	GetResourceRole(context.Context, *controller.GetResourceRoleRequest) (*controller.GetResourceRoleResponse, error)
}

ControllerProxyServer is the server API for ControllerProxy service. All implementations should embed UnimplementedControllerProxyServer for forward compatibility

type GetDeadLetterEventRequest 

type GetDeadLetterEventRequest struct {
	SubscriptionId uint64 `protobuf:"varint,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	Offset         uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Number         int32  `protobuf:"varint,3,opt,name=number,proto3" json:"number,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDeadLetterEventRequest) Descriptor deprecated 

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

Deprecated: Use GetDeadLetterEventRequest.ProtoReflect.Descriptor instead.

func (*GetDeadLetterEventRequest) GetNumber 

func (x *GetDeadLetterEventRequest) GetNumber() int32

func (*GetDeadLetterEventRequest) GetOffset 

func (x *GetDeadLetterEventRequest) GetOffset() uint64

func (*GetDeadLetterEventRequest) GetSubscriptionId 

func (x *GetDeadLetterEventRequest) GetSubscriptionId() uint64

func (*GetDeadLetterEventRequest) ProtoMessage 

func (*GetDeadLetterEventRequest) ProtoMessage()

func (*GetDeadLetterEventRequest) ProtoReflect 

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

func (*GetDeadLetterEventRequest) Reset 

func (x *GetDeadLetterEventRequest) Reset()

func (*GetDeadLetterEventRequest) String 

func (x *GetDeadLetterEventRequest) String() string

type GetDeadLetterEventResponse 

type GetDeadLetterEventResponse struct {
	Events []*wrapperspb.BytesValue `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDeadLetterEventResponse) Descriptor deprecated 

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

Deprecated: Use GetDeadLetterEventResponse.ProtoReflect.Descriptor instead.

func (*GetDeadLetterEventResponse) GetEvents 

func (x *GetDeadLetterEventResponse) GetEvents() []*wrapperspb.BytesValue

func (*GetDeadLetterEventResponse) ProtoMessage 

func (*GetDeadLetterEventResponse) ProtoMessage()

func (*GetDeadLetterEventResponse) ProtoReflect 

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

func (*GetDeadLetterEventResponse) Reset 

func (x *GetDeadLetterEventResponse) Reset()

func (*GetDeadLetterEventResponse) String 

func (x *GetDeadLetterEventResponse) String() string

type GetEventRequest 

type GetEventRequest struct {
	EventlogId uint64 `protobuf:"varint,2,opt,name=eventlog_id,json=eventlogId,proto3" json:"eventlog_id,omitempty"`
	Offset     int64  `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	Number     int32  `protobuf:"varint,4,opt,name=number,proto3" json:"number,omitempty"`
	EventId    string `protobuf:"bytes,5,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	EventbusId uint64 `protobuf:"varint,6,opt,name=eventbus_id,json=eventbusId,proto3" json:"eventbus_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEventRequest) Descriptor deprecated 

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

Deprecated: Use GetEventRequest.ProtoReflect.Descriptor instead.

func (*GetEventRequest) GetEventId 

func (x *GetEventRequest) GetEventId() string

func (*GetEventRequest) GetEventbusId 

func (x *GetEventRequest) GetEventbusId() uint64

func (*GetEventRequest) GetEventlogId 

func (x *GetEventRequest) GetEventlogId() uint64

func (*GetEventRequest) GetNumber 

func (x *GetEventRequest) GetNumber() int32

func (*GetEventRequest) GetOffset 

func (x *GetEventRequest) GetOffset() int64

func (*GetEventRequest) ProtoMessage 

func (*GetEventRequest) ProtoMessage()

func (*GetEventRequest) ProtoReflect 

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

func (*GetEventRequest) Reset 

func (x *GetEventRequest) Reset()

func (*GetEventRequest) String 

func (x *GetEventRequest) String() string

type GetEventResponse 

type GetEventResponse struct {
	Events []*wrapperspb.BytesValue `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEventResponse) Descriptor deprecated 

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

Deprecated: Use GetEventResponse.ProtoReflect.Descriptor instead.

func (*GetEventResponse) GetEvents 

func (x *GetEventResponse) GetEvents() []*wrapperspb.BytesValue

func (*GetEventResponse) ProtoMessage 

func (*GetEventResponse) ProtoMessage()

func (*GetEventResponse) ProtoReflect 

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

func (*GetEventResponse) Reset 

func (x *GetEventResponse) Reset()

func (*GetEventResponse) String 

func (x *GetEventResponse) String() string

type LookupOffsetRequest 

type LookupOffsetRequest struct {
	EventlogId uint64 `protobuf:"varint,2,opt,name=eventlog_id,json=eventlogId,proto3" json:"eventlog_id,omitempty"`
	Timestamp  int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	EventbusId uint64 `protobuf:"varint,4,opt,name=eventbus_id,json=eventbusId,proto3" json:"eventbus_id,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupOffsetRequest) Descriptor deprecated 

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

Deprecated: Use LookupOffsetRequest.ProtoReflect.Descriptor instead.

func (*LookupOffsetRequest) GetEventbusId 

func (x *LookupOffsetRequest) GetEventbusId() uint64

func (*LookupOffsetRequest) GetEventlogId 

func (x *LookupOffsetRequest) GetEventlogId() uint64

func (*LookupOffsetRequest) GetTimestamp 

func (x *LookupOffsetRequest) GetTimestamp() int64

func (*LookupOffsetRequest) ProtoMessage 

func (*LookupOffsetRequest) ProtoMessage()

func (*LookupOffsetRequest) ProtoReflect 

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

func (*LookupOffsetRequest) Reset 

func (x *LookupOffsetRequest) Reset()

func (*LookupOffsetRequest) String 

func (x *LookupOffsetRequest) String() string

type LookupOffsetResponse 

type LookupOffsetResponse struct {
	Offsets map[uint64]int64 `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LookupOffsetResponse) Descriptor deprecated 

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

Deprecated: Use LookupOffsetResponse.ProtoReflect.Descriptor instead.

func (*LookupOffsetResponse) GetOffsets 

func (x *LookupOffsetResponse) GetOffsets() map[uint64]int64

func (*LookupOffsetResponse) ProtoMessage 

func (*LookupOffsetResponse) ProtoMessage()

func (*LookupOffsetResponse) ProtoReflect 

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

func (*LookupOffsetResponse) Reset 

func (x *LookupOffsetResponse) Reset()

func (*LookupOffsetResponse) String 

func (x *LookupOffsetResponse) String() string

type MockControllerProxyClient 

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

MockControllerProxyClient is a mock of ControllerProxyClient interface.

func NewMockControllerProxyClient 

func NewMockControllerProxyClient(ctrl *gomock.Controller) *MockControllerProxyClient

NewMockControllerProxyClient creates a new mock instance.

func (*MockControllerProxyClient) ClusterInfo 

func (m *MockControllerProxyClient) ClusterInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ClusterInfoResponse, error)

ClusterInfo mocks base method.

func (*MockControllerProxyClient) CreateEventbus 

func (m *MockControllerProxyClient) CreateEventbus(ctx context.Context, in *controller.CreateEventbusRequest, opts ...grpc.CallOption) (*meta.Eventbus, error)

CreateEventbus mocks base method.

func (*MockControllerProxyClient) CreateNamespace 

func (m *MockControllerProxyClient) CreateNamespace(ctx context.Context, in *controller.CreateNamespaceRequest, opts ...grpc.CallOption) (*meta.Namespace, error)

CreateNamespace mocks base method.

func (*MockControllerProxyClient) CreateSubscription 

func (m *MockControllerProxyClient) CreateSubscription(ctx context.Context, in *controller.CreateSubscriptionRequest, opts ...grpc.CallOption) (*meta.Subscription, error)

CreateSubscription mocks base method.

func (*MockControllerProxyClient) CreateSystemEventbus 

func (m *MockControllerProxyClient) CreateSystemEventbus(ctx context.Context, in *controller.CreateEventbusRequest, opts ...grpc.CallOption) (*meta.Eventbus, error)

CreateSystemEventbus mocks base method.

func (*MockControllerProxyClient) CreateToken 

func (m *MockControllerProxyClient) CreateToken(ctx context.Context, in *controller.CreateTokenRequest, opts ...grpc.CallOption) (*meta.Token, error)

CreateToken mocks base method.

func (*MockControllerProxyClient) CreateUser 

func (m *MockControllerProxyClient) CreateUser(ctx context.Context, in *controller.CreateUserRequest, opts ...grpc.CallOption) (*meta.User, error)

CreateUser mocks base method.

func (*MockControllerProxyClient) DeleteEventbus 

func (m *MockControllerProxyClient) DeleteEventbus(ctx context.Context, in *wrapperspb.UInt64Value, opts ...grpc.CallOption) (*emptypb.Empty, error)

DeleteEventbus mocks base method.

func (*MockControllerProxyClient) DeleteNamespace 

func (m *MockControllerProxyClient) DeleteNamespace(ctx context.Context, in *controller.DeleteNamespaceRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

DeleteNamespace mocks base method.

func (*MockControllerProxyClient) DeleteSubscription 

func (m *MockControllerProxyClient) DeleteSubscription(ctx context.Context, in *controller.DeleteSubscriptionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

DeleteSubscription mocks base method.

func (*MockControllerProxyClient) DeleteToken 

func (m *MockControllerProxyClient) DeleteToken(ctx context.Context, in *controller.DeleteTokenRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

DeleteToken mocks base method.

func (*MockControllerProxyClient) DeleteUser 

func (m *MockControllerProxyClient) DeleteUser(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*emptypb.Empty, error)

DeleteUser mocks base method.

func (*MockControllerProxyClient) DisableSubscription 

func (m *MockControllerProxyClient) DisableSubscription(ctx context.Context, in *controller.DisableSubscriptionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

DisableSubscription mocks base method.

func (*MockControllerProxyClient) EXPECT 

func (m *MockControllerProxyClient) EXPECT() *MockControllerProxyClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockControllerProxyClient) GetDeadLetterEvent 

func (m *MockControllerProxyClient) GetDeadLetterEvent(ctx context.Context, in *GetDeadLetterEventRequest, opts ...grpc.CallOption) (*GetDeadLetterEventResponse, error)

GetDeadLetterEvent mocks base method.

func (*MockControllerProxyClient) GetEvent 

func (m *MockControllerProxyClient) GetEvent(ctx context.Context, in *GetEventRequest, opts ...grpc.CallOption) (*GetEventResponse, error)

GetEvent mocks base method.

func (*MockControllerProxyClient) GetEventbus 

func (m *MockControllerProxyClient) GetEventbus(ctx context.Context, in *wrapperspb.UInt64Value, opts ...grpc.CallOption) (*meta.Eventbus, error)

GetEventbus mocks base method.

func (*MockControllerProxyClient) GetEventbusWithHumanFriendly 

func (m *MockControllerProxyClient) GetEventbusWithHumanFriendly(ctx context.Context, in *controller.GetEventbusWithHumanFriendlyRequest, opts ...grpc.CallOption) (*meta.Eventbus, error)

GetEventbusWithHumanFriendly mocks base method.

func (*MockControllerProxyClient) GetNamespace 

func (m *MockControllerProxyClient) GetNamespace(ctx context.Context, in *controller.GetNamespaceRequest, opts ...grpc.CallOption) (*meta.Namespace, error)

GetNamespace mocks base method.

func (*MockControllerProxyClient) GetNamespaceWithHumanFriendly 

func (m *MockControllerProxyClient) GetNamespaceWithHumanFriendly(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*meta.Namespace, error)

GetNamespaceWithHumanFriendly mocks base method.

func (*MockControllerProxyClient) GetResourceRole 

func (m *MockControllerProxyClient) GetResourceRole(ctx context.Context, in *controller.GetResourceRoleRequest, opts ...grpc.CallOption) (*controller.GetResourceRoleResponse, error)

GetResourceRole mocks base method.

func (*MockControllerProxyClient) GetSubscription 

func (m *MockControllerProxyClient) GetSubscription(ctx context.Context, in *controller.GetSubscriptionRequest, opts ...grpc.CallOption) (*meta.Subscription, error)

GetSubscription mocks base method.

func (*MockControllerProxyClient) GetUser 

func (m *MockControllerProxyClient) GetUser(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*meta.User, error)

GetUser mocks base method.

func (*MockControllerProxyClient) GetUserRole 

func (m *MockControllerProxyClient) GetUserRole(ctx context.Context, in *controller.GetUserRoleRequest, opts ...grpc.CallOption) (*controller.GetUserRoleResponse, error)

GetUserRole mocks base method.

func (*MockControllerProxyClient) GetUserToken 

func (m *MockControllerProxyClient) GetUserToken(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*controller.GetTokenResponse, error)

GetUserToken mocks base method.

func (*MockControllerProxyClient) GrantRole 

func (m *MockControllerProxyClient) GrantRole(ctx context.Context, in *controller.RoleRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

GrantRole mocks base method.

func (*MockControllerProxyClient) ListEventbus 

func (m *MockControllerProxyClient) ListEventbus(ctx context.Context, in *controller.ListEventbusRequest, opts ...grpc.CallOption) (*controller.ListEventbusResponse, error)

ListEventbus mocks base method.

func (*MockControllerProxyClient) ListNamespace 

func (m *MockControllerProxyClient) ListNamespace(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*controller.ListNamespaceResponse, error)

ListNamespace mocks base method.

func (*MockControllerProxyClient) ListSegment 

func (m *MockControllerProxyClient) ListSegment(ctx context.Context, in *controller.ListSegmentRequest, opts ...grpc.CallOption) (*controller.ListSegmentResponse, error)

ListSegment mocks base method.

func (*MockControllerProxyClient) ListSubscription 

func (m *MockControllerProxyClient) ListSubscription(ctx context.Context, in *controller.ListSubscriptionRequest, opts ...grpc.CallOption) (*controller.ListSubscriptionResponse, error)

ListSubscription mocks base method.

func (*MockControllerProxyClient) ListToken 

func (m *MockControllerProxyClient) ListToken(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*controller.ListTokenResponse, error)

ListToken mocks base method.

func (*MockControllerProxyClient) ListUser 

func (m *MockControllerProxyClient) ListUser(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*controller.ListUserResponse, error)

ListUser mocks base method.

func (*MockControllerProxyClient) LookupOffset 

func (m *MockControllerProxyClient) LookupOffset(ctx context.Context, in *LookupOffsetRequest, opts ...grpc.CallOption) (*LookupOffsetResponse, error)

LookupOffset mocks base method.

func (*MockControllerProxyClient) ResendDeadLetterEvent 

func (m *MockControllerProxyClient) ResendDeadLetterEvent(ctx context.Context, in *ResendDeadLetterEventRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

ResendDeadLetterEvent mocks base method.

func (*MockControllerProxyClient) ResetOffsetToTimestamp 

func (m *MockControllerProxyClient) ResetOffsetToTimestamp(ctx context.Context, in *controller.ResetOffsetToTimestampRequest, opts ...grpc.CallOption) (*controller.ResetOffsetToTimestampResponse, error)

ResetOffsetToTimestamp mocks base method.

func (*MockControllerProxyClient) ResumeSubscription 

func (m *MockControllerProxyClient) ResumeSubscription(ctx context.Context, in *controller.ResumeSubscriptionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

ResumeSubscription mocks base method.

func (*MockControllerProxyClient) RevokeRole 

func (m *MockControllerProxyClient) RevokeRole(ctx context.Context, in *controller.RoleRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

RevokeRole mocks base method.

func (*MockControllerProxyClient) SetDeadLetterEventOffset 

func (m *MockControllerProxyClient) SetDeadLetterEventOffset(ctx context.Context, in *controller.SetDeadLetterEventOffsetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

SetDeadLetterEventOffset mocks base method.

func (*MockControllerProxyClient) UpdateEventbus 

func (m *MockControllerProxyClient) UpdateEventbus(ctx context.Context, in *controller.UpdateEventbusRequest, opts ...grpc.CallOption) (*meta.Eventbus, error)

UpdateEventbus mocks base method.

func (*MockControllerProxyClient) UpdateSubscription 

func (m *MockControllerProxyClient) UpdateSubscription(ctx context.Context, in *controller.UpdateSubscriptionRequest, opts ...grpc.CallOption) (*meta.Subscription, error)

UpdateSubscription mocks base method.

func (*MockControllerProxyClient) ValidateEventbus 

func (m *MockControllerProxyClient) ValidateEventbus(ctx context.Context, in *ValidateEventbusRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

ValidateEventbus mocks base method.

func (*MockControllerProxyClient) ValidateSubscription 

func (m *MockControllerProxyClient) ValidateSubscription(ctx context.Context, in *ValidateSubscriptionRequest, opts ...grpc.CallOption) (*ValidateSubscriptionResponse, error)

ValidateSubscription mocks base method.

type MockControllerProxyClientMockRecorder 

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

MockControllerProxyClientMockRecorder is the mock recorder for MockControllerProxyClient.

func (*MockControllerProxyClientMockRecorder) ClusterInfo 

func (mr *MockControllerProxyClientMockRecorder) ClusterInfo(ctx, in interface{}, opts ...interface{}) *gomock.Call

ClusterInfo indicates an expected call of ClusterInfo.

func (*MockControllerProxyClientMockRecorder) CreateEventbus 

func (mr *MockControllerProxyClientMockRecorder) CreateEventbus(ctx, in interface{}, opts ...interface{}) *gomock.Call

CreateEventbus indicates an expected call of CreateEventbus.

func (*MockControllerProxyClientMockRecorder) CreateNamespace 

func (mr *MockControllerProxyClientMockRecorder) CreateNamespace(ctx, in interface{}, opts ...interface{}) *gomock.Call

CreateNamespace indicates an expected call of CreateNamespace.

func (*MockControllerProxyClientMockRecorder) CreateSubscription 

func (mr *MockControllerProxyClientMockRecorder) CreateSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

CreateSubscription indicates an expected call of CreateSubscription.

func (*MockControllerProxyClientMockRecorder) CreateSystemEventbus 

func (mr *MockControllerProxyClientMockRecorder) CreateSystemEventbus(ctx, in interface{}, opts ...interface{}) *gomock.Call

CreateSystemEventbus indicates an expected call of CreateSystemEventbus.

func (*MockControllerProxyClientMockRecorder) CreateToken 

func (mr *MockControllerProxyClientMockRecorder) CreateToken(ctx, in interface{}, opts ...interface{}) *gomock.Call

CreateToken indicates an expected call of CreateToken.

func (*MockControllerProxyClientMockRecorder) CreateUser 

func (mr *MockControllerProxyClientMockRecorder) CreateUser(ctx, in interface{}, opts ...interface{}) *gomock.Call

CreateUser indicates an expected call of CreateUser.

func (*MockControllerProxyClientMockRecorder) DeleteEventbus 

func (mr *MockControllerProxyClientMockRecorder) DeleteEventbus(ctx, in interface{}, opts ...interface{}) *gomock.Call

DeleteEventbus indicates an expected call of DeleteEventbus.

func (*MockControllerProxyClientMockRecorder) DeleteNamespace 

func (mr *MockControllerProxyClientMockRecorder) DeleteNamespace(ctx, in interface{}, opts ...interface{}) *gomock.Call

DeleteNamespace indicates an expected call of DeleteNamespace.

func (*MockControllerProxyClientMockRecorder) DeleteSubscription 

func (mr *MockControllerProxyClientMockRecorder) DeleteSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

DeleteSubscription indicates an expected call of DeleteSubscription.

func (*MockControllerProxyClientMockRecorder) DeleteToken 

func (mr *MockControllerProxyClientMockRecorder) DeleteToken(ctx, in interface{}, opts ...interface{}) *gomock.Call

DeleteToken indicates an expected call of DeleteToken.

func (*MockControllerProxyClientMockRecorder) DeleteUser 

func (mr *MockControllerProxyClientMockRecorder) DeleteUser(ctx, in interface{}, opts ...interface{}) *gomock.Call

DeleteUser indicates an expected call of DeleteUser.

func (*MockControllerProxyClientMockRecorder) DisableSubscription 

func (mr *MockControllerProxyClientMockRecorder) DisableSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

DisableSubscription indicates an expected call of DisableSubscription.

func (*MockControllerProxyClientMockRecorder) GetDeadLetterEvent 

func (mr *MockControllerProxyClientMockRecorder) GetDeadLetterEvent(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetDeadLetterEvent indicates an expected call of GetDeadLetterEvent.

func (*MockControllerProxyClientMockRecorder) GetEvent 

func (mr *MockControllerProxyClientMockRecorder) GetEvent(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetEvent indicates an expected call of GetEvent.

func (*MockControllerProxyClientMockRecorder) GetEventbus 

func (mr *MockControllerProxyClientMockRecorder) GetEventbus(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetEventbus indicates an expected call of GetEventbus.

func (*MockControllerProxyClientMockRecorder) GetEventbusWithHumanFriendly 

func (mr *MockControllerProxyClientMockRecorder) GetEventbusWithHumanFriendly(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetEventbusWithHumanFriendly indicates an expected call of GetEventbusWithHumanFriendly.

func (*MockControllerProxyClientMockRecorder) GetNamespace 

func (mr *MockControllerProxyClientMockRecorder) GetNamespace(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetNamespace indicates an expected call of GetNamespace.

func (*MockControllerProxyClientMockRecorder) GetNamespaceWithHumanFriendly 

func (mr *MockControllerProxyClientMockRecorder) GetNamespaceWithHumanFriendly(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetNamespaceWithHumanFriendly indicates an expected call of GetNamespaceWithHumanFriendly.

func (*MockControllerProxyClientMockRecorder) GetResourceRole 

func (mr *MockControllerProxyClientMockRecorder) GetResourceRole(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetResourceRole indicates an expected call of GetResourceRole.

func (*MockControllerProxyClientMockRecorder) GetSubscription 

func (mr *MockControllerProxyClientMockRecorder) GetSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetSubscription indicates an expected call of GetSubscription.

func (*MockControllerProxyClientMockRecorder) GetUser 

func (mr *MockControllerProxyClientMockRecorder) GetUser(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetUser indicates an expected call of GetUser.

func (*MockControllerProxyClientMockRecorder) GetUserRole 

func (mr *MockControllerProxyClientMockRecorder) GetUserRole(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetUserRole indicates an expected call of GetUserRole.

func (*MockControllerProxyClientMockRecorder) GetUserToken 

func (mr *MockControllerProxyClientMockRecorder) GetUserToken(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetUserToken indicates an expected call of GetUserToken.

func (*MockControllerProxyClientMockRecorder) GrantRole 

func (mr *MockControllerProxyClientMockRecorder) GrantRole(ctx, in interface{}, opts ...interface{}) *gomock.Call

GrantRole indicates an expected call of GrantRole.

func (*MockControllerProxyClientMockRecorder) ListEventbus 

func (mr *MockControllerProxyClientMockRecorder) ListEventbus(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListEventbus indicates an expected call of ListEventbus.

func (*MockControllerProxyClientMockRecorder) ListNamespace 

func (mr *MockControllerProxyClientMockRecorder) ListNamespace(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListNamespace indicates an expected call of ListNamespace.

func (*MockControllerProxyClientMockRecorder) ListSegment 

func (mr *MockControllerProxyClientMockRecorder) ListSegment(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListSegment indicates an expected call of ListSegment.

func (*MockControllerProxyClientMockRecorder) ListSubscription 

func (mr *MockControllerProxyClientMockRecorder) ListSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListSubscription indicates an expected call of ListSubscription.

func (*MockControllerProxyClientMockRecorder) ListToken 

func (mr *MockControllerProxyClientMockRecorder) ListToken(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListToken indicates an expected call of ListToken.

func (*MockControllerProxyClientMockRecorder) ListUser 

func (mr *MockControllerProxyClientMockRecorder) ListUser(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListUser indicates an expected call of ListUser.

func (*MockControllerProxyClientMockRecorder) LookupOffset 

func (mr *MockControllerProxyClientMockRecorder) LookupOffset(ctx, in interface{}, opts ...interface{}) *gomock.Call

LookupOffset indicates an expected call of LookupOffset.

func (*MockControllerProxyClientMockRecorder) ResendDeadLetterEvent 

func (mr *MockControllerProxyClientMockRecorder) ResendDeadLetterEvent(ctx, in interface{}, opts ...interface{}) *gomock.Call

ResendDeadLetterEvent indicates an expected call of ResendDeadLetterEvent.

func (*MockControllerProxyClientMockRecorder) ResetOffsetToTimestamp 

func (mr *MockControllerProxyClientMockRecorder) ResetOffsetToTimestamp(ctx, in interface{}, opts ...interface{}) *gomock.Call

ResetOffsetToTimestamp indicates an expected call of ResetOffsetToTimestamp.

func (*MockControllerProxyClientMockRecorder) ResumeSubscription 

func (mr *MockControllerProxyClientMockRecorder) ResumeSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

ResumeSubscription indicates an expected call of ResumeSubscription.

func (*MockControllerProxyClientMockRecorder) RevokeRole 

func (mr *MockControllerProxyClientMockRecorder) RevokeRole(ctx, in interface{}, opts ...interface{}) *gomock.Call

RevokeRole indicates an expected call of RevokeRole.

func (*MockControllerProxyClientMockRecorder) SetDeadLetterEventOffset 

func (mr *MockControllerProxyClientMockRecorder) SetDeadLetterEventOffset(ctx, in interface{}, opts ...interface{}) *gomock.Call

SetDeadLetterEventOffset indicates an expected call of SetDeadLetterEventOffset.

func (*MockControllerProxyClientMockRecorder) UpdateEventbus 

func (mr *MockControllerProxyClientMockRecorder) UpdateEventbus(ctx, in interface{}, opts ...interface{}) *gomock.Call

UpdateEventbus indicates an expected call of UpdateEventbus.

func (*MockControllerProxyClientMockRecorder) UpdateSubscription 

func (mr *MockControllerProxyClientMockRecorder) UpdateSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

UpdateSubscription indicates an expected call of UpdateSubscription.

func (*MockControllerProxyClientMockRecorder) ValidateEventbus 

func (mr *MockControllerProxyClientMockRecorder) ValidateEventbus(ctx, in interface{}, opts ...interface{}) *gomock.Call

ValidateEventbus indicates an expected call of ValidateEventbus.

func (*MockControllerProxyClientMockRecorder) ValidateSubscription 

func (mr *MockControllerProxyClientMockRecorder) ValidateSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

ValidateSubscription indicates an expected call of ValidateSubscription.

type MockControllerProxyServer 

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

MockControllerProxyServer is a mock of ControllerProxyServer interface.

func NewMockControllerProxyServer 

func NewMockControllerProxyServer(ctrl *gomock.Controller) *MockControllerProxyServer

NewMockControllerProxyServer creates a new mock instance.

func (*MockControllerProxyServer) ClusterInfo 

func (m *MockControllerProxyServer) ClusterInfo(ctx context.Context, in *emptypb.Empty) (*ClusterInfoResponse, error)

ClusterInfo mocks base method.

func (*MockControllerProxyServer) CreateEventbus 

func (m *MockControllerProxyServer) CreateEventbus(ctx context.Context, in *controller.CreateEventbusRequest) (*meta.Eventbus, error)

CreateEventbus mocks base method.

func (*MockControllerProxyServer) CreateNamespace 

func (m *MockControllerProxyServer) CreateNamespace(ctx context.Context, in *controller.CreateNamespaceRequest) (*meta.Namespace, error)

CreateNamespace mocks base method.

func (*MockControllerProxyServer) CreateSubscription 

func (m *MockControllerProxyServer) CreateSubscription(ctx context.Context, in *controller.CreateSubscriptionRequest) (*meta.Subscription, error)

CreateSubscription mocks base method.

func (*MockControllerProxyServer) CreateSystemEventbus 

func (m *MockControllerProxyServer) CreateSystemEventbus(ctx context.Context, in *controller.CreateEventbusRequest) (*meta.Eventbus, error)

CreateSystemEventbus mocks base method.

func (*MockControllerProxyServer) CreateToken 

func (m *MockControllerProxyServer) CreateToken(ctx context.Context, in *controller.CreateTokenRequest) (*meta.Token, error)

CreateToken mocks base method.

func (*MockControllerProxyServer) CreateUser 

func (m *MockControllerProxyServer) CreateUser(ctx context.Context, in *controller.CreateUserRequest) (*meta.User, error)

CreateUser mocks base method.

func (*MockControllerProxyServer) DeleteEventbus 

func (m *MockControllerProxyServer) DeleteEventbus(ctx context.Context, in *wrapperspb.UInt64Value) (*emptypb.Empty, error)

DeleteEventbus mocks base method.

func (*MockControllerProxyServer) DeleteNamespace 

func (m *MockControllerProxyServer) DeleteNamespace(ctx context.Context, in *controller.DeleteNamespaceRequest) (*emptypb.Empty, error)

DeleteNamespace mocks base method.

func (*MockControllerProxyServer) DeleteSubscription 

func (m *MockControllerProxyServer) DeleteSubscription(ctx context.Context, in *controller.DeleteSubscriptionRequest) (*emptypb.Empty, error)

DeleteSubscription mocks base method.

func (*MockControllerProxyServer) DeleteToken 

func (m *MockControllerProxyServer) DeleteToken(ctx context.Context, in *controller.DeleteTokenRequest) (*emptypb.Empty, error)

DeleteToken mocks base method.

func (*MockControllerProxyServer) DeleteUser 

func (m *MockControllerProxyServer) DeleteUser(ctx context.Context, in *wrapperspb.StringValue) (*emptypb.Empty, error)

DeleteUser mocks base method.

func (*MockControllerProxyServer) DisableSubscription 

func (m *MockControllerProxyServer) DisableSubscription(ctx context.Context, in *controller.DisableSubscriptionRequest) (*emptypb.Empty, error)

DisableSubscription mocks base method.

func (*MockControllerProxyServer) EXPECT 

func (m *MockControllerProxyServer) EXPECT() *MockControllerProxyServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockControllerProxyServer) GetDeadLetterEvent 

func (m *MockControllerProxyServer) GetDeadLetterEvent(ctx context.Context, in *GetDeadLetterEventRequest) (*GetDeadLetterEventResponse, error)

GetDeadLetterEvent mocks base method.

func (*MockControllerProxyServer) GetEvent 

func (m *MockControllerProxyServer) GetEvent(ctx context.Context, in *GetEventRequest) (*GetEventResponse, error)

GetEvent mocks base method.

func (*MockControllerProxyServer) GetEventbus 

func (m *MockControllerProxyServer) GetEventbus(ctx context.Context, in *wrapperspb.UInt64Value) (*meta.Eventbus, error)

GetEventbus mocks base method.

func (*MockControllerProxyServer) GetEventbusWithHumanFriendly 

func (m *MockControllerProxyServer) GetEventbusWithHumanFriendly(ctx context.Context, in *controller.GetEventbusWithHumanFriendlyRequest) (*meta.Eventbus, error)

GetEventbusWithHumanFriendly mocks base method.

func (*MockControllerProxyServer) GetNamespace 

func (m *MockControllerProxyServer) GetNamespace(ctx context.Context, in *controller.GetNamespaceRequest) (*meta.Namespace, error)

GetNamespace mocks base method.

func (*MockControllerProxyServer) GetNamespaceWithHumanFriendly 

func (m *MockControllerProxyServer) GetNamespaceWithHumanFriendly(ctx context.Context, in *wrapperspb.StringValue) (*meta.Namespace, error)

GetNamespaceWithHumanFriendly mocks base method.

func (*MockControllerProxyServer) GetResourceRole 

func (m *MockControllerProxyServer) GetResourceRole(ctx context.Context, in *controller.GetResourceRoleRequest) (*controller.GetResourceRoleResponse, error)

GetResourceRole mocks base method.

func (*MockControllerProxyServer) GetSubscription 

func (m *MockControllerProxyServer) GetSubscription(ctx context.Context, in *controller.GetSubscriptionRequest) (*meta.Subscription, error)

GetSubscription mocks base method.

func (*MockControllerProxyServer) GetUser 

func (m *MockControllerProxyServer) GetUser(ctx context.Context, in *wrapperspb.StringValue) (*meta.User, error)

GetUser mocks base method.

func (*MockControllerProxyServer) GetUserRole 

func (m *MockControllerProxyServer) GetUserRole(ctx context.Context, in *controller.GetUserRoleRequest) (*controller.GetUserRoleResponse, error)

GetUserRole mocks base method.

func (*MockControllerProxyServer) GetUserToken 

func (m *MockControllerProxyServer) GetUserToken(ctx context.Context, in *wrapperspb.StringValue) (*controller.GetTokenResponse, error)

GetUserToken mocks base method.

func (*MockControllerProxyServer) GrantRole 

func (m *MockControllerProxyServer) GrantRole(ctx context.Context, in *controller.RoleRequest) (*emptypb.Empty, error)

GrantRole mocks base method.

func (*MockControllerProxyServer) ListEventbus 

func (m *MockControllerProxyServer) ListEventbus(ctx context.Context, in *controller.ListEventbusRequest) (*controller.ListEventbusResponse, error)

ListEventbus mocks base method.

func (*MockControllerProxyServer) ListNamespace 

func (m *MockControllerProxyServer) ListNamespace(ctx context.Context, in *emptypb.Empty) (*controller.ListNamespaceResponse, error)

ListNamespace mocks base method.

func (*MockControllerProxyServer) ListSegment 

func (m *MockControllerProxyServer) ListSegment(ctx context.Context, in *controller.ListSegmentRequest) (*controller.ListSegmentResponse, error)

ListSegment mocks base method.

func (*MockControllerProxyServer) ListSubscription 

func (m *MockControllerProxyServer) ListSubscription(ctx context.Context, in *controller.ListSubscriptionRequest) (*controller.ListSubscriptionResponse, error)

ListSubscription mocks base method.

func (*MockControllerProxyServer) ListToken 

func (m *MockControllerProxyServer) ListToken(ctx context.Context, in *emptypb.Empty) (*controller.ListTokenResponse, error)

ListToken mocks base method.

func (*MockControllerProxyServer) ListUser 

func (m *MockControllerProxyServer) ListUser(ctx context.Context, in *emptypb.Empty) (*controller.ListUserResponse, error)

ListUser mocks base method.

func (*MockControllerProxyServer) LookupOffset 

func (m *MockControllerProxyServer) LookupOffset(ctx context.Context, in *LookupOffsetRequest) (*LookupOffsetResponse, error)

LookupOffset mocks base method.

func (*MockControllerProxyServer) ResendDeadLetterEvent 

func (m *MockControllerProxyServer) ResendDeadLetterEvent(ctx context.Context, in *ResendDeadLetterEventRequest) (*emptypb.Empty, error)

ResendDeadLetterEvent mocks base method.

func (*MockControllerProxyServer) ResetOffsetToTimestamp 

func (m *MockControllerProxyServer) ResetOffsetToTimestamp(ctx context.Context, in *controller.ResetOffsetToTimestampRequest) (*controller.ResetOffsetToTimestampResponse, error)

ResetOffsetToTimestamp mocks base method.

func (*MockControllerProxyServer) ResumeSubscription 

func (m *MockControllerProxyServer) ResumeSubscription(ctx context.Context, in *controller.ResumeSubscriptionRequest) (*emptypb.Empty, error)

ResumeSubscription mocks base method.

func (*MockControllerProxyServer) RevokeRole 

func (m *MockControllerProxyServer) RevokeRole(ctx context.Context, in *controller.RoleRequest) (*emptypb.Empty, error)

RevokeRole mocks base method.

func (*MockControllerProxyServer) SetDeadLetterEventOffset 

func (m *MockControllerProxyServer) SetDeadLetterEventOffset(ctx context.Context, in *controller.SetDeadLetterEventOffsetRequest) (*emptypb.Empty, error)

SetDeadLetterEventOffset mocks base method.

func (*MockControllerProxyServer) UpdateEventbus 

func (m *MockControllerProxyServer) UpdateEventbus(ctx context.Context, in *controller.UpdateEventbusRequest) (*meta.Eventbus, error)

UpdateEventbus mocks base method.

func (*MockControllerProxyServer) UpdateSubscription 

func (m *MockControllerProxyServer) UpdateSubscription(ctx context.Context, in *controller.UpdateSubscriptionRequest) (*meta.Subscription, error)

UpdateSubscription mocks base method.

func (*MockControllerProxyServer) ValidateEventbus 

func (m *MockControllerProxyServer) ValidateEventbus(ctx context.Context, in *ValidateEventbusRequest) (*emptypb.Empty, error)

ValidateEventbus mocks base method.

func (*MockControllerProxyServer) ValidateSubscription 

func (m *MockControllerProxyServer) ValidateSubscription(ctx context.Context, in *ValidateSubscriptionRequest) (*ValidateSubscriptionResponse, error)

ValidateSubscription mocks base method.

type MockControllerProxyServerMockRecorder 

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

MockControllerProxyServerMockRecorder is the mock recorder for MockControllerProxyServer.

func (*MockControllerProxyServerMockRecorder) ClusterInfo 

func (mr *MockControllerProxyServerMockRecorder) ClusterInfo(ctx, in interface{}) *gomock.Call

ClusterInfo indicates an expected call of ClusterInfo.

func (*MockControllerProxyServerMockRecorder) CreateEventbus 

func (mr *MockControllerProxyServerMockRecorder) CreateEventbus(ctx, in interface{}) *gomock.Call

CreateEventbus indicates an expected call of CreateEventbus.

func (*MockControllerProxyServerMockRecorder) CreateNamespace 

func (mr *MockControllerProxyServerMockRecorder) CreateNamespace(ctx, in interface{}) *gomock.Call

CreateNamespace indicates an expected call of CreateNamespace.

func (*MockControllerProxyServerMockRecorder) CreateSubscription 

func (mr *MockControllerProxyServerMockRecorder) CreateSubscription(ctx, in interface{}) *gomock.Call

CreateSubscription indicates an expected call of CreateSubscription.

func (*MockControllerProxyServerMockRecorder) CreateSystemEventbus 

func (mr *MockControllerProxyServerMockRecorder) CreateSystemEventbus(ctx, in interface{}) *gomock.Call

CreateSystemEventbus indicates an expected call of CreateSystemEventbus.

func (*MockControllerProxyServerMockRecorder) CreateToken 

func (mr *MockControllerProxyServerMockRecorder) CreateToken(ctx, in interface{}) *gomock.Call

CreateToken indicates an expected call of CreateToken.

func (*MockControllerProxyServerMockRecorder) CreateUser 

func (mr *MockControllerProxyServerMockRecorder) CreateUser(ctx, in interface{}) *gomock.Call

CreateUser indicates an expected call of CreateUser.

func (*MockControllerProxyServerMockRecorder) DeleteEventbus 

func (mr *MockControllerProxyServerMockRecorder) DeleteEventbus(ctx, in interface{}) *gomock.Call

DeleteEventbus indicates an expected call of DeleteEventbus.

func (*MockControllerProxyServerMockRecorder) DeleteNamespace 

func (mr *MockControllerProxyServerMockRecorder) DeleteNamespace(ctx, in interface{}) *gomock.Call

DeleteNamespace indicates an expected call of DeleteNamespace.

func (*MockControllerProxyServerMockRecorder) DeleteSubscription 

func (mr *MockControllerProxyServerMockRecorder) DeleteSubscription(ctx, in interface{}) *gomock.Call

DeleteSubscription indicates an expected call of DeleteSubscription.

func (*MockControllerProxyServerMockRecorder) DeleteToken 

func (mr *MockControllerProxyServerMockRecorder) DeleteToken(ctx, in interface{}) *gomock.Call

DeleteToken indicates an expected call of DeleteToken.

func (*MockControllerProxyServerMockRecorder) DeleteUser 

func (mr *MockControllerProxyServerMockRecorder) DeleteUser(ctx, in interface{}) *gomock.Call

DeleteUser indicates an expected call of DeleteUser.

func (*MockControllerProxyServerMockRecorder) DisableSubscription 

func (mr *MockControllerProxyServerMockRecorder) DisableSubscription(ctx, in interface{}) *gomock.Call

DisableSubscription indicates an expected call of DisableSubscription.

func (*MockControllerProxyServerMockRecorder) GetDeadLetterEvent 

func (mr *MockControllerProxyServerMockRecorder) GetDeadLetterEvent(ctx, in interface{}) *gomock.Call

GetDeadLetterEvent indicates an expected call of GetDeadLetterEvent.

func (*MockControllerProxyServerMockRecorder) GetEvent 

func (mr *MockControllerProxyServerMockRecorder) GetEvent(ctx, in interface{}) *gomock.Call

GetEvent indicates an expected call of GetEvent.

func (*MockControllerProxyServerMockRecorder) GetEventbus 

func (mr *MockControllerProxyServerMockRecorder) GetEventbus(ctx, in interface{}) *gomock.Call

GetEventbus indicates an expected call of GetEventbus.

func (*MockControllerProxyServerMockRecorder) GetEventbusWithHumanFriendly 

func (mr *MockControllerProxyServerMockRecorder) GetEventbusWithHumanFriendly(ctx, in interface{}) *gomock.Call

GetEventbusWithHumanFriendly indicates an expected call of GetEventbusWithHumanFriendly.

func (*MockControllerProxyServerMockRecorder) GetNamespace 

func (mr *MockControllerProxyServerMockRecorder) GetNamespace(ctx, in interface{}) *gomock.Call

GetNamespace indicates an expected call of GetNamespace.

func (*MockControllerProxyServerMockRecorder) GetNamespaceWithHumanFriendly 

func (mr *MockControllerProxyServerMockRecorder) GetNamespaceWithHumanFriendly(ctx, in interface{}) *gomock.Call

GetNamespaceWithHumanFriendly indicates an expected call of GetNamespaceWithHumanFriendly.

func (*MockControllerProxyServerMockRecorder) GetResourceRole 

func (mr *MockControllerProxyServerMockRecorder) GetResourceRole(ctx, in interface{}) *gomock.Call

GetResourceRole indicates an expected call of GetResourceRole.

func (*MockControllerProxyServerMockRecorder) GetSubscription 

func (mr *MockControllerProxyServerMockRecorder) GetSubscription(ctx, in interface{}) *gomock.Call

GetSubscription indicates an expected call of GetSubscription.

func (*MockControllerProxyServerMockRecorder) GetUser 

func (mr *MockControllerProxyServerMockRecorder) GetUser(ctx, in interface{}) *gomock.Call

GetUser indicates an expected call of GetUser.

func (*MockControllerProxyServerMockRecorder) GetUserRole 

func (mr *MockControllerProxyServerMockRecorder) GetUserRole(ctx, in interface{}) *gomock.Call

GetUserRole indicates an expected call of GetUserRole.

func (*MockControllerProxyServerMockRecorder) GetUserToken 

func (mr *MockControllerProxyServerMockRecorder) GetUserToken(ctx, in interface{}) *gomock.Call

GetUserToken indicates an expected call of GetUserToken.

func (*MockControllerProxyServerMockRecorder) GrantRole 

func (mr *MockControllerProxyServerMockRecorder) GrantRole(ctx, in interface{}) *gomock.Call

GrantRole indicates an expected call of GrantRole.

func (*MockControllerProxyServerMockRecorder) ListEventbus 

func (mr *MockControllerProxyServerMockRecorder) ListEventbus(ctx, in interface{}) *gomock.Call

ListEventbus indicates an expected call of ListEventbus.

func (*MockControllerProxyServerMockRecorder) ListNamespace 

func (mr *MockControllerProxyServerMockRecorder) ListNamespace(ctx, in interface{}) *gomock.Call

ListNamespace indicates an expected call of ListNamespace.

func (*MockControllerProxyServerMockRecorder) ListSegment 

func (mr *MockControllerProxyServerMockRecorder) ListSegment(ctx, in interface{}) *gomock.Call

ListSegment indicates an expected call of ListSegment.

func (*MockControllerProxyServerMockRecorder) ListSubscription 

func (mr *MockControllerProxyServerMockRecorder) ListSubscription(ctx, in interface{}) *gomock.Call

ListSubscription indicates an expected call of ListSubscription.

func (*MockControllerProxyServerMockRecorder) ListToken 

func (mr *MockControllerProxyServerMockRecorder) ListToken(ctx, in interface{}) *gomock.Call

ListToken indicates an expected call of ListToken.

func (*MockControllerProxyServerMockRecorder) ListUser 

func (mr *MockControllerProxyServerMockRecorder) ListUser(ctx, in interface{}) *gomock.Call

ListUser indicates an expected call of ListUser.

func (*MockControllerProxyServerMockRecorder) LookupOffset 

func (mr *MockControllerProxyServerMockRecorder) LookupOffset(ctx, in interface{}) *gomock.Call

LookupOffset indicates an expected call of LookupOffset.

func (*MockControllerProxyServerMockRecorder) ResendDeadLetterEvent 

func (mr *MockControllerProxyServerMockRecorder) ResendDeadLetterEvent(ctx, in interface{}) *gomock.Call

ResendDeadLetterEvent indicates an expected call of ResendDeadLetterEvent.

func (*MockControllerProxyServerMockRecorder) ResetOffsetToTimestamp 

func (mr *MockControllerProxyServerMockRecorder) ResetOffsetToTimestamp(ctx, in interface{}) *gomock.Call

ResetOffsetToTimestamp indicates an expected call of ResetOffsetToTimestamp.

func (*MockControllerProxyServerMockRecorder) ResumeSubscription 

func (mr *MockControllerProxyServerMockRecorder) ResumeSubscription(ctx, in interface{}) *gomock.Call

ResumeSubscription indicates an expected call of ResumeSubscription.

func (*MockControllerProxyServerMockRecorder) RevokeRole 

func (mr *MockControllerProxyServerMockRecorder) RevokeRole(ctx, in interface{}) *gomock.Call

RevokeRole indicates an expected call of RevokeRole.

func (*MockControllerProxyServerMockRecorder) SetDeadLetterEventOffset 

func (mr *MockControllerProxyServerMockRecorder) SetDeadLetterEventOffset(ctx, in interface{}) *gomock.Call

SetDeadLetterEventOffset indicates an expected call of SetDeadLetterEventOffset.

func (*MockControllerProxyServerMockRecorder) UpdateEventbus 

func (mr *MockControllerProxyServerMockRecorder) UpdateEventbus(ctx, in interface{}) *gomock.Call

UpdateEventbus indicates an expected call of UpdateEventbus.

func (*MockControllerProxyServerMockRecorder) UpdateSubscription 

func (mr *MockControllerProxyServerMockRecorder) UpdateSubscription(ctx, in interface{}) *gomock.Call

UpdateSubscription indicates an expected call of UpdateSubscription.

func (*MockControllerProxyServerMockRecorder) ValidateEventbus 

func (mr *MockControllerProxyServerMockRecorder) ValidateEventbus(ctx, in interface{}) *gomock.Call

ValidateEventbus indicates an expected call of ValidateEventbus.

func (*MockControllerProxyServerMockRecorder) ValidateSubscription 

func (mr *MockControllerProxyServerMockRecorder) ValidateSubscription(ctx, in interface{}) *gomock.Call

ValidateSubscription indicates an expected call of ValidateSubscription.

type MockStoreProxyClient 

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

MockStoreProxyClient is a mock of StoreProxyClient interface.

func NewMockStoreProxyClient 

func NewMockStoreProxyClient(ctrl *gomock.Controller) *MockStoreProxyClient

NewMockStoreProxyClient creates a new mock instance.

func (*MockStoreProxyClient) Ack 

func (m *MockStoreProxyClient) Ack(ctx context.Context, opts ...grpc.CallOption) (StoreProxy_AckClient, error)

Ack mocks base method.

func (*MockStoreProxyClient) EXPECT 

func (m *MockStoreProxyClient) EXPECT() *MockStoreProxyClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStoreProxyClient) Publish 

func (m *MockStoreProxyClient) Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

Publish mocks base method.

func (*MockStoreProxyClient) Subscribe 

func (m *MockStoreProxyClient) Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (StoreProxy_SubscribeClient, error)

Subscribe mocks base method.

type MockStoreProxyClientMockRecorder 

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

MockStoreProxyClientMockRecorder is the mock recorder for MockStoreProxyClient.

func (*MockStoreProxyClientMockRecorder) Ack 

func (mr *MockStoreProxyClientMockRecorder) Ack(ctx interface{}, opts ...interface{}) *gomock.Call

Ack indicates an expected call of Ack.

func (*MockStoreProxyClientMockRecorder) Publish 

func (mr *MockStoreProxyClientMockRecorder) Publish(ctx, in interface{}, opts ...interface{}) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockStoreProxyClientMockRecorder) Subscribe 

func (mr *MockStoreProxyClientMockRecorder) Subscribe(ctx, in interface{}, opts ...interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe.

type MockStoreProxyServer 

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

MockStoreProxyServer is a mock of StoreProxyServer interface.

func NewMockStoreProxyServer 

func NewMockStoreProxyServer(ctrl *gomock.Controller) *MockStoreProxyServer

NewMockStoreProxyServer creates a new mock instance.

func (*MockStoreProxyServer) Ack 

func (m *MockStoreProxyServer) Ack(server StoreProxy_AckServer) error

Ack mocks base method.

func (*MockStoreProxyServer) EXPECT 

func (m *MockStoreProxyServer) EXPECT() *MockStoreProxyServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStoreProxyServer) Publish 

func (m *MockStoreProxyServer) Publish(ctx context.Context, in *PublishRequest) (*emptypb.Empty, error)

Publish mocks base method.

func (*MockStoreProxyServer) Subscribe 

func (m *MockStoreProxyServer) Subscribe(blob *SubscribeRequest, server StoreProxy_SubscribeServer) error

Subscribe mocks base method.

type MockStoreProxyServerMockRecorder 

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

MockStoreProxyServerMockRecorder is the mock recorder for MockStoreProxyServer.

func (*MockStoreProxyServerMockRecorder) Ack 

func (mr *MockStoreProxyServerMockRecorder) Ack(server interface{}) *gomock.Call

Ack indicates an expected call of Ack.

func (*MockStoreProxyServerMockRecorder) Publish 

func (mr *MockStoreProxyServerMockRecorder) Publish(ctx, in interface{}) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockStoreProxyServerMockRecorder) Subscribe 

func (mr *MockStoreProxyServerMockRecorder) Subscribe(blob, server interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe.

type MockStoreProxy_AckClient 

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

MockStoreProxy_AckClient is a mock of StoreProxy_AckClient interface.

func NewMockStoreProxy_AckClient 

func NewMockStoreProxy_AckClient(ctrl *gomock.Controller) *MockStoreProxy_AckClient

NewMockStoreProxy_AckClient creates a new mock instance.

func (*MockStoreProxy_AckClient) CloseAndRecv 

func (m *MockStoreProxy_AckClient) CloseAndRecv() (*emptypb.Empty, error)

CloseAndRecv mocks base method.

func (*MockStoreProxy_AckClient) CloseSend 

func (m *MockStoreProxy_AckClient) CloseSend() error

CloseSend mocks base method.

func (*MockStoreProxy_AckClient) Context 

func (m *MockStoreProxy_AckClient) Context() context.Context

Context mocks base method.

func (*MockStoreProxy_AckClient) EXPECT 

func (m *MockStoreProxy_AckClient) EXPECT() *MockStoreProxy_AckClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStoreProxy_AckClient) Header 

func (m *MockStoreProxy_AckClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockStoreProxy_AckClient) RecvMsg 

func (m *MockStoreProxy_AckClient) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method.

func (*MockStoreProxy_AckClient) Send 

func (m *MockStoreProxy_AckClient) Send(arg0 *AckRequest) error

Send mocks base method.

func (*MockStoreProxy_AckClient) SendMsg 

func (m *MockStoreProxy_AckClient) SendMsg(arg0 interface{}) error

SendMsg mocks base method.

func (*MockStoreProxy_AckClient) Trailer 

func (m *MockStoreProxy_AckClient) Trailer() metadata.MD

Trailer mocks base method.

type MockStoreProxy_AckClientMockRecorder 

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

MockStoreProxy_AckClientMockRecorder is the mock recorder for MockStoreProxy_AckClient.

func (*MockStoreProxy_AckClientMockRecorder) CloseAndRecv 

func (mr *MockStoreProxy_AckClientMockRecorder) CloseAndRecv() *gomock.Call

CloseAndRecv indicates an expected call of CloseAndRecv.

func (*MockStoreProxy_AckClientMockRecorder) CloseSend 

func (mr *MockStoreProxy_AckClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockStoreProxy_AckClientMockRecorder) Context 

func (mr *MockStoreProxy_AckClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockStoreProxy_AckClientMockRecorder) Header 

func (mr *MockStoreProxy_AckClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockStoreProxy_AckClientMockRecorder) RecvMsg 

func (mr *MockStoreProxy_AckClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockStoreProxy_AckClientMockRecorder) Send 

func (mr *MockStoreProxy_AckClientMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockStoreProxy_AckClientMockRecorder) SendMsg 

func (mr *MockStoreProxy_AckClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockStoreProxy_AckClientMockRecorder) Trailer 

func (mr *MockStoreProxy_AckClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockStoreProxy_AckServer 

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

MockStoreProxy_AckServer is a mock of StoreProxy_AckServer interface.

func NewMockStoreProxy_AckServer 

func NewMockStoreProxy_AckServer(ctrl *gomock.Controller) *MockStoreProxy_AckServer

NewMockStoreProxy_AckServer creates a new mock instance.

func (*MockStoreProxy_AckServer) Context 

func (m *MockStoreProxy_AckServer) Context() context.Context

Context mocks base method.

func (*MockStoreProxy_AckServer) EXPECT 

func (m *MockStoreProxy_AckServer) EXPECT() *MockStoreProxy_AckServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStoreProxy_AckServer) Recv 

func (m *MockStoreProxy_AckServer) Recv() (*emptypb.Empty, error)

Recv mocks base method.

func (*MockStoreProxy_AckServer) RecvMsg 

func (m *MockStoreProxy_AckServer) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method.

func (*MockStoreProxy_AckServer) SendAndClose 

func (m *MockStoreProxy_AckServer) SendAndClose(arg0 *AckRequest) error

SendAndClose mocks base method.

func (*MockStoreProxy_AckServer) SendHeader 

func (m *MockStoreProxy_AckServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method.

func (*MockStoreProxy_AckServer) SendMsg 

func (m *MockStoreProxy_AckServer) SendMsg(arg0 interface{}) error

SendMsg mocks base method.

func (*MockStoreProxy_AckServer) SetHeader 

func (m *MockStoreProxy_AckServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method.

func (*MockStoreProxy_AckServer) SetTrailer 

func (m *MockStoreProxy_AckServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method.

type MockStoreProxy_AckServerMockRecorder 

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

MockStoreProxy_AckServerMockRecorder is the mock recorder for MockStoreProxy_AckServer.

func (*MockStoreProxy_AckServerMockRecorder) Context 

func (mr *MockStoreProxy_AckServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockStoreProxy_AckServerMockRecorder) Recv 

func (mr *MockStoreProxy_AckServerMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockStoreProxy_AckServerMockRecorder) RecvMsg 

func (mr *MockStoreProxy_AckServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockStoreProxy_AckServerMockRecorder) SendAndClose 

func (mr *MockStoreProxy_AckServerMockRecorder) SendAndClose(arg0 interface{}) *gomock.Call

SendAndClose indicates an expected call of SendAndClose.

func (*MockStoreProxy_AckServerMockRecorder) SendHeader 

func (mr *MockStoreProxy_AckServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockStoreProxy_AckServerMockRecorder) SendMsg 

func (mr *MockStoreProxy_AckServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockStoreProxy_AckServerMockRecorder) SetHeader 

func (mr *MockStoreProxy_AckServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockStoreProxy_AckServerMockRecorder) SetTrailer 

func (mr *MockStoreProxy_AckServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

type MockStoreProxy_SubscribeClient 

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

MockStoreProxy_SubscribeClient is a mock of StoreProxy_SubscribeClient interface.

func NewMockStoreProxy_SubscribeClient 

func NewMockStoreProxy_SubscribeClient(ctrl *gomock.Controller) *MockStoreProxy_SubscribeClient

NewMockStoreProxy_SubscribeClient creates a new mock instance.

func (*MockStoreProxy_SubscribeClient) CloseSend 

func (m *MockStoreProxy_SubscribeClient) CloseSend() error

CloseSend mocks base method.

func (*MockStoreProxy_SubscribeClient) Context 

func (m *MockStoreProxy_SubscribeClient) Context() context.Context

Context mocks base method.

func (*MockStoreProxy_SubscribeClient) EXPECT 

func (m *MockStoreProxy_SubscribeClient) EXPECT() *MockStoreProxy_SubscribeClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStoreProxy_SubscribeClient) Header 

func (m *MockStoreProxy_SubscribeClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockStoreProxy_SubscribeClient) Recv 

func (m *MockStoreProxy_SubscribeClient) Recv() (*SubscribeResponse, error)

Recv mocks base method.

func (*MockStoreProxy_SubscribeClient) RecvMsg 

func (m *MockStoreProxy_SubscribeClient) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method.

func (*MockStoreProxy_SubscribeClient) SendMsg 

func (m *MockStoreProxy_SubscribeClient) SendMsg(arg0 interface{}) error

SendMsg mocks base method.

func (*MockStoreProxy_SubscribeClient) Trailer 

func (m *MockStoreProxy_SubscribeClient) Trailer() metadata.MD

Trailer mocks base method.

type MockStoreProxy_SubscribeClientMockRecorder 

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

MockStoreProxy_SubscribeClientMockRecorder is the mock recorder for MockStoreProxy_SubscribeClient.

func (*MockStoreProxy_SubscribeClientMockRecorder) CloseSend 

func (mr *MockStoreProxy_SubscribeClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockStoreProxy_SubscribeClientMockRecorder) Context 

func (mr *MockStoreProxy_SubscribeClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockStoreProxy_SubscribeClientMockRecorder) Header 

func (mr *MockStoreProxy_SubscribeClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockStoreProxy_SubscribeClientMockRecorder) Recv 

func (mr *MockStoreProxy_SubscribeClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockStoreProxy_SubscribeClientMockRecorder) RecvMsg 

func (mr *MockStoreProxy_SubscribeClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockStoreProxy_SubscribeClientMockRecorder) SendMsg 

func (mr *MockStoreProxy_SubscribeClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockStoreProxy_SubscribeClientMockRecorder) Trailer 

func (mr *MockStoreProxy_SubscribeClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockStoreProxy_SubscribeServer 

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

MockStoreProxy_SubscribeServer is a mock of StoreProxy_SubscribeServer interface.

func NewMockStoreProxy_SubscribeServer 

func NewMockStoreProxy_SubscribeServer(ctrl *gomock.Controller) *MockStoreProxy_SubscribeServer

NewMockStoreProxy_SubscribeServer creates a new mock instance.

func (*MockStoreProxy_SubscribeServer) Context 

func (m *MockStoreProxy_SubscribeServer) Context() context.Context

Context mocks base method.

func (*MockStoreProxy_SubscribeServer) EXPECT 

func (m *MockStoreProxy_SubscribeServer) EXPECT() *MockStoreProxy_SubscribeServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStoreProxy_SubscribeServer) RecvMsg 

func (m *MockStoreProxy_SubscribeServer) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method.

func (*MockStoreProxy_SubscribeServer) Send 

func (m *MockStoreProxy_SubscribeServer) Send(arg0 *SubscribeResponse) error

Send mocks base method.

func (*MockStoreProxy_SubscribeServer) SendHeader 

func (m *MockStoreProxy_SubscribeServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method.

func (*MockStoreProxy_SubscribeServer) SendMsg 

func (m *MockStoreProxy_SubscribeServer) SendMsg(arg0 interface{}) error

SendMsg mocks base method.

func (*MockStoreProxy_SubscribeServer) SetHeader 

func (m *MockStoreProxy_SubscribeServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method.

func (*MockStoreProxy_SubscribeServer) SetTrailer 

func (m *MockStoreProxy_SubscribeServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method.

type MockStoreProxy_SubscribeServerMockRecorder 

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

MockStoreProxy_SubscribeServerMockRecorder is the mock recorder for MockStoreProxy_SubscribeServer.

func (*MockStoreProxy_SubscribeServerMockRecorder) Context 

func (mr *MockStoreProxy_SubscribeServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockStoreProxy_SubscribeServerMockRecorder) RecvMsg 

func (mr *MockStoreProxy_SubscribeServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockStoreProxy_SubscribeServerMockRecorder) Send 

func (mr *MockStoreProxy_SubscribeServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockStoreProxy_SubscribeServerMockRecorder) SendHeader 

func (mr *MockStoreProxy_SubscribeServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockStoreProxy_SubscribeServerMockRecorder) SendMsg 

func (mr *MockStoreProxy_SubscribeServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockStoreProxy_SubscribeServerMockRecorder) SetHeader 

func (mr *MockStoreProxy_SubscribeServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockStoreProxy_SubscribeServerMockRecorder) SetTrailer 

func (mr *MockStoreProxy_SubscribeServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

type PublishRequest 

type PublishRequest struct {
	Events     *cloudevents.CloudEventBatch `protobuf:"bytes,2,opt,name=events,proto3" json:"events,omitempty"`
	EventbusId uint64                       `protobuf:"varint,3,opt,name=eventbus_id,json=eventbusId,proto3" json:"eventbus_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishRequest) Descriptor deprecated 

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

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

func (*PublishRequest) GetEventbusId 

func (x *PublishRequest) GetEventbusId() uint64

func (*PublishRequest) GetEvents 

func (x *PublishRequest) GetEvents() *cloudevents.CloudEventBatch

func (*PublishRequest) ProtoMessage 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect 

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

func (*PublishRequest) Reset 

func (x *PublishRequest) Reset()

func (*PublishRequest) String 

func (x *PublishRequest) String() string

type ResendDeadLetterEventRequest 

type ResendDeadLetterEventRequest struct {
	SubscriptionId uint64 `protobuf:"varint,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	StartOffset    uint64 `protobuf:"varint,2,opt,name=start_offset,json=startOffset,proto3" json:"start_offset,omitempty"`
	EndOffset      uint64 `protobuf:"varint,3,opt,name=end_offset,json=endOffset,proto3" json:"end_offset,omitempty"`
	// contains filtered or unexported fields
}

func (*ResendDeadLetterEventRequest) Descriptor deprecated 

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

Deprecated: Use ResendDeadLetterEventRequest.ProtoReflect.Descriptor instead.

func (*ResendDeadLetterEventRequest) GetEndOffset 

func (x *ResendDeadLetterEventRequest) GetEndOffset() uint64

func (*ResendDeadLetterEventRequest) GetStartOffset 

func (x *ResendDeadLetterEventRequest) GetStartOffset() uint64

func (*ResendDeadLetterEventRequest) GetSubscriptionId 

func (x *ResendDeadLetterEventRequest) GetSubscriptionId() uint64

func (*ResendDeadLetterEventRequest) ProtoMessage 

func (*ResendDeadLetterEventRequest) ProtoMessage()

func (*ResendDeadLetterEventRequest) ProtoReflect 

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

func (*ResendDeadLetterEventRequest) Reset 

func (x *ResendDeadLetterEventRequest) Reset()

func (*ResendDeadLetterEventRequest) String 

func (x *ResendDeadLetterEventRequest) String() string

type StoreProxyClient 

type StoreProxyClient interface {
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (StoreProxy_SubscribeClient, error)
	Ack(ctx context.Context, opts ...grpc.CallOption) (StoreProxy_AckClient, error)
}

StoreProxyClient is the client API for StoreProxy 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 NewStoreProxyClient 

func NewStoreProxyClient(cc grpc.ClientConnInterface) StoreProxyClient

type StoreProxyServer 

type StoreProxyServer interface {
	Publish(context.Context, *PublishRequest) (*emptypb.Empty, error)
	Subscribe(*SubscribeRequest, StoreProxy_SubscribeServer) error
	Ack(StoreProxy_AckServer) error
}

StoreProxyServer is the server API for StoreProxy service. All implementations should embed UnimplementedStoreProxyServer for forward compatibility

type StoreProxy_AckClient 

type StoreProxy_AckClient interface {
	Send(*AckRequest) error
	CloseAndRecv() (*emptypb.Empty, error)
	grpc.ClientStream
}

type StoreProxy_AckServer 

type StoreProxy_AckServer interface {
	SendAndClose(*emptypb.Empty) error
	Recv() (*AckRequest, error)
	grpc.ServerStream
}

type StoreProxy_SubscribeClient 

type StoreProxy_SubscribeClient interface {
	Recv() (*SubscribeResponse, error)
	grpc.ClientStream
}

type StoreProxy_SubscribeServer 

type StoreProxy_SubscribeServer interface {
	Send(*SubscribeResponse) error
	grpc.ServerStream
}

type SubscribeRequest 

type SubscribeRequest struct {
	SubscriptionId string `protobuf:"bytes,2,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	EventbusId     uint64 `protobuf:"varint,3,opt,name=eventbus_id,json=eventbusId,proto3" json:"eventbus_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetEventbusId 

func (x *SubscribeRequest) GetEventbusId() uint64

func (*SubscribeRequest) GetSubscriptionId 

func (x *SubscribeRequest) GetSubscriptionId() string

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect 

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

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (x *SubscribeRequest) String() string

type SubscribeResponse 

type SubscribeResponse struct {
	SequenceId uint64                       `protobuf:"varint,1,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"`
	Events     *cloudevents.CloudEventBatch `protobuf:"bytes,2,opt,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.

func (*SubscribeResponse) GetEvents 

func (x *SubscribeResponse) GetEvents() *cloudevents.CloudEventBatch

func (*SubscribeResponse) GetSequenceId 

func (x *SubscribeResponse) GetSequenceId() uint64

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) ProtoReflect 

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

func (*SubscribeResponse) Reset 

func (x *SubscribeResponse) Reset()

func (*SubscribeResponse) String 

func (x *SubscribeResponse) String() string

type UnimplementedControllerProxyServer 

type UnimplementedControllerProxyServer struct {
}

UnimplementedControllerProxyServer should be embedded to have forward compatible implementations.

func (UnimplementedControllerProxyServer) ClusterInfo 

func (UnimplementedControllerProxyServer) ClusterInfo(context.Context, *emptypb.Empty) (*ClusterInfoResponse, error)

func (UnimplementedControllerProxyServer) CreateEventbus 

func (UnimplementedControllerProxyServer) CreateEventbus(context.Context, *controller.CreateEventbusRequest) (*meta.Eventbus, error)

func (UnimplementedControllerProxyServer) CreateNamespace 

func (UnimplementedControllerProxyServer) CreateNamespace(context.Context, *controller.CreateNamespaceRequest) (*meta.Namespace, error)

func (UnimplementedControllerProxyServer) CreateSubscription 

func (UnimplementedControllerProxyServer) CreateSubscription(context.Context, *controller.CreateSubscriptionRequest) (*meta.Subscription, error)

func (UnimplementedControllerProxyServer) CreateSystemEventbus 

func (UnimplementedControllerProxyServer) CreateSystemEventbus(context.Context, *controller.CreateEventbusRequest) (*meta.Eventbus, error)

func (UnimplementedControllerProxyServer) CreateToken 

func (UnimplementedControllerProxyServer) CreateToken(context.Context, *controller.CreateTokenRequest) (*meta.Token, error)

func (UnimplementedControllerProxyServer) CreateUser 

func (UnimplementedControllerProxyServer) CreateUser(context.Context, *controller.CreateUserRequest) (*meta.User, error)

func (UnimplementedControllerProxyServer) DeleteEventbus 

func (UnimplementedControllerProxyServer) DeleteEventbus(context.Context, *wrapperspb.UInt64Value) (*emptypb.Empty, error)

func (UnimplementedControllerProxyServer) DeleteNamespace 

func (UnimplementedControllerProxyServer) DeleteNamespace(context.Context, *controller.DeleteNamespaceRequest) (*emptypb.Empty, error)

func (UnimplementedControllerProxyServer) DeleteSubscription 

func (UnimplementedControllerProxyServer) DeleteSubscription(context.Context, *controller.DeleteSubscriptionRequest) (*emptypb.Empty, error)

func (UnimplementedControllerProxyServer) DeleteToken 

func (UnimplementedControllerProxyServer) DeleteToken(context.Context, *controller.DeleteTokenRequest) (*emptypb.Empty, error)

func (UnimplementedControllerProxyServer) DeleteUser 

func (UnimplementedControllerProxyServer) DeleteUser(context.Context, *wrapperspb.StringValue) (*emptypb.Empty, error)

func (UnimplementedControllerProxyServer) DisableSubscription 

func (UnimplementedControllerProxyServer) DisableSubscription(context.Context, *controller.DisableSubscriptionRequest) (*emptypb.Empty, error)

func (UnimplementedControllerProxyServer) GetDeadLetterEvent 

func (UnimplementedControllerProxyServer) GetDeadLetterEvent(context.Context, *GetDeadLetterEventRequest) (*GetDeadLetterEventResponse, error)

func (UnimplementedControllerProxyServer) GetEvent 

func (UnimplementedControllerProxyServer) GetEvent(context.Context, *GetEventRequest) (*GetEventResponse, error)

func (UnimplementedControllerProxyServer) GetEventbus 

func (UnimplementedControllerProxyServer) GetEventbus(context.Context, *wrapperspb.UInt64Value) (*meta.Eventbus, error)

func (UnimplementedControllerProxyServer) GetEventbusWithHumanFriendly 

func (UnimplementedControllerProxyServer) GetEventbusWithHumanFriendly(context.Context, *controller.GetEventbusWithHumanFriendlyRequest) (*meta.Eventbus, error)

func (UnimplementedControllerProxyServer) GetNamespace 

func (UnimplementedControllerProxyServer) GetNamespace(context.Context, *controller.GetNamespaceRequest) (*meta.Namespace, error)

func (UnimplementedControllerProxyServer) GetNamespaceWithHumanFriendly 

func (UnimplementedControllerProxyServer) GetNamespaceWithHumanFriendly(context.Context, *wrapperspb.StringValue) (*meta.Namespace, error)

func (UnimplementedControllerProxyServer) GetResourceRole 

func (UnimplementedControllerProxyServer) GetResourceRole(context.Context, *controller.GetResourceRoleRequest) (*controller.GetResourceRoleResponse, error)

func (UnimplementedControllerProxyServer) GetSubscription 

func (UnimplementedControllerProxyServer) GetSubscription(context.Context, *controller.GetSubscriptionRequest) (*meta.Subscription, error)

func (UnimplementedControllerProxyServer) GetUser 

func (UnimplementedControllerProxyServer) GetUser(context.Context, *wrapperspb.StringValue) (*meta.User, error)

func (UnimplementedControllerProxyServer) GetUserRole 

func (UnimplementedControllerProxyServer) GetUserRole(context.Context, *controller.GetUserRoleRequest) (*controller.GetUserRoleResponse, error)

func (UnimplementedControllerProxyServer) GetUserToken 

func (UnimplementedControllerProxyServer) GetUserToken(context.Context, *wrapperspb.StringValue) (*controller.GetTokenResponse, error)

func (UnimplementedControllerProxyServer) GrantRole 

func (UnimplementedControllerProxyServer) GrantRole(context.Context, *controller.RoleRequest) (*emptypb.Empty, error)

func (UnimplementedControllerProxyServer) ListEventbus 

func (UnimplementedControllerProxyServer) ListEventbus(context.Context, *controller.ListEventbusRequest) (*controller.ListEventbusResponse, error)

func (UnimplementedControllerProxyServer) ListNamespace 

func (UnimplementedControllerProxyServer) ListNamespace(context.Context, *emptypb.Empty) (*controller.ListNamespaceResponse, error)

func (UnimplementedControllerProxyServer) ListSegment 

func (UnimplementedControllerProxyServer) ListSegment(context.Context, *controller.ListSegmentRequest) (*controller.ListSegmentResponse, error)

func (UnimplementedControllerProxyServer) ListSubscription 

func (UnimplementedControllerProxyServer) ListSubscription(context.Context, *controller.ListSubscriptionRequest) (*controller.ListSubscriptionResponse, error)

func (UnimplementedControllerProxyServer) ListToken 

func (UnimplementedControllerProxyServer) ListToken(context.Context, *emptypb.Empty) (*controller.ListTokenResponse, error)

func (UnimplementedControllerProxyServer) ListUser 

func (UnimplementedControllerProxyServer) ListUser(context.Context, *emptypb.Empty) (*controller.ListUserResponse, error)

func (UnimplementedControllerProxyServer) LookupOffset 

func (UnimplementedControllerProxyServer) LookupOffset(context.Context, *LookupOffsetRequest) (*LookupOffsetResponse, error)

func (UnimplementedControllerProxyServer) ResendDeadLetterEvent 

func (UnimplementedControllerProxyServer) ResendDeadLetterEvent(context.Context, *ResendDeadLetterEventRequest) (*emptypb.Empty, error)

func (UnimplementedControllerProxyServer) ResetOffsetToTimestamp 

func (UnimplementedControllerProxyServer) ResetOffsetToTimestamp(context.Context, *controller.ResetOffsetToTimestampRequest) (*controller.ResetOffsetToTimestampResponse, error)

func (UnimplementedControllerProxyServer) ResumeSubscription 

func (UnimplementedControllerProxyServer) ResumeSubscription(context.Context, *controller.ResumeSubscriptionRequest) (*emptypb.Empty, error)

func (UnimplementedControllerProxyServer) RevokeRole 

func (UnimplementedControllerProxyServer) RevokeRole(context.Context, *controller.RoleRequest) (*emptypb.Empty, error)

func (UnimplementedControllerProxyServer) SetDeadLetterEventOffset 

func (UnimplementedControllerProxyServer) SetDeadLetterEventOffset(context.Context, *controller.SetDeadLetterEventOffsetRequest) (*emptypb.Empty, error)

func (UnimplementedControllerProxyServer) UpdateEventbus 

func (UnimplementedControllerProxyServer) UpdateEventbus(context.Context, *controller.UpdateEventbusRequest) (*meta.Eventbus, error)

func (UnimplementedControllerProxyServer) UpdateSubscription 

func (UnimplementedControllerProxyServer) UpdateSubscription(context.Context, *controller.UpdateSubscriptionRequest) (*meta.Subscription, error)

func (UnimplementedControllerProxyServer) ValidateEventbus 

func (UnimplementedControllerProxyServer) ValidateEventbus(context.Context, *ValidateEventbusRequest) (*emptypb.Empty, error)

func (UnimplementedControllerProxyServer) ValidateSubscription 

func (UnimplementedControllerProxyServer) ValidateSubscription(context.Context, *ValidateSubscriptionRequest) (*ValidateSubscriptionResponse, error)

type UnimplementedStoreProxyServer 

type UnimplementedStoreProxyServer struct {
}

UnimplementedStoreProxyServer should be embedded to have forward compatible implementations.

func (UnimplementedStoreProxyServer) Ack 

func (UnimplementedStoreProxyServer) Ack(StoreProxy_AckServer) error

func (UnimplementedStoreProxyServer) Publish 

func (UnimplementedStoreProxyServer) Publish(context.Context, *PublishRequest) (*emptypb.Empty, error)

func (UnimplementedStoreProxyServer) Subscribe 

func (UnimplementedStoreProxyServer) Subscribe(*SubscribeRequest, StoreProxy_SubscribeServer) error

type UnsafeControllerProxyServer 

type UnsafeControllerProxyServer interface {
	// contains filtered or unexported methods
}

UnsafeControllerProxyServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ControllerProxyServer will result in compilation errors.

type UnsafeStoreProxyServer 

type UnsafeStoreProxyServer interface {
	// contains filtered or unexported methods
}

UnsafeStoreProxyServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StoreProxyServer will result in compilation errors.

type ValidateEventbusRequest 

type ValidateEventbusRequest struct {
	EventbusId uint64 `protobuf:"varint,1,opt,name=eventbus_id,json=eventbusId,proto3" json:"eventbus_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateEventbusRequest) Descriptor deprecated 

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

Deprecated: Use ValidateEventbusRequest.ProtoReflect.Descriptor instead.

func (*ValidateEventbusRequest) GetEventbusId 

func (x *ValidateEventbusRequest) GetEventbusId() uint64

func (*ValidateEventbusRequest) ProtoMessage 

func (*ValidateEventbusRequest) ProtoMessage()

func (*ValidateEventbusRequest) ProtoReflect 

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

func (*ValidateEventbusRequest) Reset 

func (x *ValidateEventbusRequest) Reset()

func (*ValidateEventbusRequest) String 

func (x *ValidateEventbusRequest) String() string

type ValidateSubscriptionRequest 

type ValidateSubscriptionRequest struct {
	Eventlog       uint64                          `protobuf:"varint,2,opt,name=eventlog,proto3" json:"eventlog,omitempty"`
	Offset         int64                           `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	SubscriptionId uint64                          `protobuf:"varint,4,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	EventbusId     uint64                          `protobuf:"varint,5,opt,name=eventbus_id,json=eventbusId,proto3" json:"eventbus_id,omitempty"`
	Event          []byte                          `protobuf:"bytes,100,opt,name=event,proto3" json:"event,omitempty"`
	Subscription   *controller.SubscriptionRequest `protobuf:"bytes,101,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use ValidateSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*ValidateSubscriptionRequest) GetEvent 

func (x *ValidateSubscriptionRequest) GetEvent() []byte

func (*ValidateSubscriptionRequest) GetEventbusId 

func (x *ValidateSubscriptionRequest) GetEventbusId() uint64

func (*ValidateSubscriptionRequest) GetEventlog 

func (x *ValidateSubscriptionRequest) GetEventlog() uint64

func (*ValidateSubscriptionRequest) GetOffset 

func (x *ValidateSubscriptionRequest) GetOffset() int64

func (*ValidateSubscriptionRequest) GetSubscription 

func (x *ValidateSubscriptionRequest) GetSubscription() *controller.SubscriptionRequest

func (*ValidateSubscriptionRequest) GetSubscriptionId 

func (x *ValidateSubscriptionRequest) GetSubscriptionId() uint64

func (*ValidateSubscriptionRequest) ProtoMessage 

func (*ValidateSubscriptionRequest) ProtoMessage()

func (*ValidateSubscriptionRequest) ProtoReflect 

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

func (*ValidateSubscriptionRequest) Reset 

func (x *ValidateSubscriptionRequest) Reset()

func (*ValidateSubscriptionRequest) String 

func (x *ValidateSubscriptionRequest) String() string

type ValidateSubscriptionResponse 

type ValidateSubscriptionResponse struct {
	FilterResult      bool   `protobuf:"varint,1,opt,name=filter_result,json=filterResult,proto3" json:"filter_result,omitempty"`
	TransformerResult []byte `protobuf:"bytes,2,opt,name=transformer_result,json=transformerResult,proto3" json:"transformer_result,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateSubscriptionResponse) Descriptor deprecated 

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

Deprecated: Use ValidateSubscriptionResponse.ProtoReflect.Descriptor instead.

func (*ValidateSubscriptionResponse) GetFilterResult 

func (x *ValidateSubscriptionResponse) GetFilterResult() bool

func (*ValidateSubscriptionResponse) GetTransformerResult 

func (x *ValidateSubscriptionResponse) GetTransformerResult() []byte

func (*ValidateSubscriptionResponse) ProtoMessage 

func (*ValidateSubscriptionResponse) ProtoMessage()

func (*ValidateSubscriptionResponse) ProtoReflect 

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

func (*ValidateSubscriptionResponse) Reset 

func (x *ValidateSubscriptionResponse) Reset()

func (*ValidateSubscriptionResponse) String 

func (x *ValidateSubscriptionResponse) String() string

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.