Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

proxy

package

Go to main page

Versions in this module

v0

v0.9.0

Sep 7, 2023

v0.8.0

Apr 17, 2023

Changes in this version

+ const ContentTypeProtobuf

+ func ToProto(e *v2.Event) (*cloudevents.CloudEvent, error)

+ type Config struct

+ AuthCfg auth.Config

+ CloudEventReceiverPort int

+ Credentials credentials.TransportCredentials

+ Endpoints []string

+ GRPCReflectionEnable bool

+ ProxyPort int

+ SinkPort int

+ type ControllerProxy struct

+ func NewControllerProxy(cfg Config) *ControllerProxy

+ func (cp *ControllerProxy) Ack(stream proxypb.StoreProxy_AckServer) error

+ func (cp *ControllerProxy) ClusterInfo(_ context.Context, _ *emptypb.Empty) (*proxypb.ClusterInfoResponse, error)

+ func (cp *ControllerProxy) CreateEventbus(ctx context.Context, req *ctrlpb.CreateEventbusRequest) (*metapb.Eventbus, error)

+ func (cp *ControllerProxy) CreateNamespace(ctx context.Context, request *ctrlpb.CreateNamespaceRequest) (*metapb.Namespace, error)

+ func (cp *ControllerProxy) CreateSubscription(ctx context.Context, req *ctrlpb.CreateSubscriptionRequest) (*metapb.Subscription, error)

+ func (cp *ControllerProxy) CreateToken(ctx context.Context, request *ctrlpb.CreateTokenRequest) (*metapb.Token, error)

+ func (cp *ControllerProxy) CreateUser(ctx context.Context, request *ctrlpb.CreateUserRequest) (*metapb.User, error)

+ func (cp *ControllerProxy) DeleteEventbus(ctx context.Context, id *wrapperspb.UInt64Value) (*emptypb.Empty, error)

+ func (cp *ControllerProxy) DeleteNamespace(ctx context.Context, request *ctrlpb.DeleteNamespaceRequest) (*emptypb.Empty, error)

+ func (cp *ControllerProxy) DeleteSubscription(ctx context.Context, req *ctrlpb.DeleteSubscriptionRequest) (*emptypb.Empty, error)

+ func (cp *ControllerProxy) DeleteToken(ctx context.Context, request *ctrlpb.DeleteTokenRequest) (*emptypb.Empty, error)

+ func (cp *ControllerProxy) DeleteUser(ctx context.Context, value *wrapperspb.StringValue) (*emptypb.Empty, error)

+ func (cp *ControllerProxy) DisableSubscription(ctx context.Context, req *ctrlpb.DisableSubscriptionRequest) (*emptypb.Empty, error)

+ func (cp *ControllerProxy) GetDeadLetterEvent(ctx context.Context, req *proxypb.GetDeadLetterEventRequest) (*proxypb.GetDeadLetterEventResponse, error)

+ func (cp *ControllerProxy) GetEvent(ctx context.Context, req *proxypb.GetEventRequest) (*proxypb.GetEventResponse, error)

+ func (cp *ControllerProxy) GetEventbus(ctx context.Context, id *wrapperspb.UInt64Value) (*metapb.Eventbus, error)

+ func (cp *ControllerProxy) GetEventbusWithHumanFriendly(ctx context.Context, request *ctrlpb.GetEventbusWithHumanFriendlyRequest) (*metapb.Eventbus, error)

+ func (cp *ControllerProxy) GetNamespace(ctx context.Context, request *ctrlpb.GetNamespaceRequest) (*metapb.Namespace, error)

+ func (cp *ControllerProxy) GetNamespaceWithHumanFriendly(ctx context.Context, value *wrapperspb.StringValue) (*metapb.Namespace, error)

+ func (cp *ControllerProxy) GetResourceRole(ctx context.Context, request *ctrlpb.GetResourceRoleRequest) (*ctrlpb.GetResourceRoleResponse, error)

+ func (cp *ControllerProxy) GetSubscription(ctx context.Context, req *ctrlpb.GetSubscriptionRequest) (*metapb.Subscription, error)

+ func (cp *ControllerProxy) GetUser(ctx context.Context, value *wrapperspb.StringValue) (*metapb.User, error)

+ func (cp *ControllerProxy) GetUserRole(ctx context.Context, request *ctrlpb.GetUserRoleRequest) (*ctrlpb.GetUserRoleResponse, error)

+ func (cp *ControllerProxy) GetUserToken(ctx context.Context, request *wrapperspb.StringValue) (*ctrlpb.GetTokenResponse, error)

+ func (cp *ControllerProxy) GrantRole(ctx context.Context, request *ctrlpb.RoleRequest) (*emptypb.Empty, error)

+ func (cp *ControllerProxy) ListEventbus(ctx context.Context, req *ctrlpb.ListEventbusRequest) (*ctrlpb.ListEventbusResponse, error)

+ func (cp *ControllerProxy) ListNamespace(ctx context.Context, empty *emptypb.Empty) (*ctrlpb.ListNamespaceResponse, error)

+ func (cp *ControllerProxy) ListSegment(ctx context.Context, req *ctrlpb.ListSegmentRequest) (*ctrlpb.ListSegmentResponse, error)

+ func (cp *ControllerProxy) ListSubscription(ctx context.Context, req *ctrlpb.ListSubscriptionRequest) (*ctrlpb.ListSubscriptionResponse, error)

+ func (cp *ControllerProxy) ListToken(ctx context.Context, empty *emptypb.Empty) (*ctrlpb.ListTokenResponse, error)

+ func (cp *ControllerProxy) ListUser(ctx context.Context, empty *emptypb.Empty) (*ctrlpb.ListUserResponse, error)

+ func (cp *ControllerProxy) LookupOffset(ctx context.Context, req *proxypb.LookupOffsetRequest) (*proxypb.LookupOffsetResponse, error)

+ func (cp *ControllerProxy) Publish(ctx context.Context, req *proxypb.PublishRequest) (*emptypb.Empty, error)

+ func (cp *ControllerProxy) ResendDeadLetterEvent(ctx context.Context, req *proxypb.ResendDeadLetterEventRequest) (*emptypb.Empty, error)

+ func (cp *ControllerProxy) ResetOffsetToTimestamp(ctx context.Context, req *ctrlpb.ResetOffsetToTimestampRequest) (*ctrlpb.ResetOffsetToTimestampResponse, error)

+ func (cp *ControllerProxy) ResumeSubscription(ctx context.Context, req *ctrlpb.ResumeSubscriptionRequest) (*emptypb.Empty, error)

+ func (cp *ControllerProxy) RevokeRole(ctx context.Context, request *ctrlpb.RoleRequest) (*emptypb.Empty, error)

+ func (cp *ControllerProxy) SetClient(client eb.Client)

+ func (cp *ControllerProxy) SetDeadLetterEventOffset(ctx context.Context, req *ctrlpb.SetDeadLetterEventOffsetRequest) (*emptypb.Empty, error)

+ func (cp *ControllerProxy) Start() error

+ func (cp *ControllerProxy) Stop()

+ func (cp *ControllerProxy) Subscribe(req *proxypb.SubscribeRequest, stream proxypb.StoreProxy_SubscribeServer) error

+ func (cp *ControllerProxy) UpdateEventbus(_ context.Context, _ *ctrlpb.UpdateEventbusRequest) (*metapb.Eventbus, error)

+ func (cp *ControllerProxy) UpdateSubscription(ctx context.Context, req *ctrlpb.UpdateSubscriptionRequest) (*metapb.Subscription, error)

+ func (cp *ControllerProxy) ValidateSubscription(ctx context.Context, req *proxypb.ValidateSubscriptionRequest) (*proxypb.ValidateSubscriptionResponse, error)