proxy

package
v0.9.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	ControllerProxy_CreateEventbus_FullMethodName                = "/vanus.core.proxy.ControllerProxy/CreateEventbus"
	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_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: "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: "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: "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_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: "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)
	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)
	// 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)
	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)
	// 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 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 added in v0.8.0 

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) CreateToken added in v0.8.0 

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

func (UnimplementedControllerProxyServer) CreateUser added in v0.8.0 

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 added in v0.8.0 

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 added in v0.8.0 

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

func (UnimplementedControllerProxyServer) DeleteUser added in v0.8.0 

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 added in v0.8.0 

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 added in v0.8.0 

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 added in v0.8.0 

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

func (UnimplementedControllerProxyServer) GetUserRole added in v0.8.0 

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

func (UnimplementedControllerProxyServer) GetUserToken added in v0.8.0 

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

func (UnimplementedControllerProxyServer) GrantRole added in v0.8.0 

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 added in v0.8.0 

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 added in v0.8.0 

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

func (UnimplementedControllerProxyServer) ListUser added in v0.8.0 

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 added in v0.8.0 

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