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

eventv2

package

Go to main page

Versions in this module

v0

v0.0.7

Dec 4, 2024

v0.0.6

Sep 19, 2024

v0.0.4

Aug 27, 2024

v0.0.3

Aug 27, 2024

v0.0.2

Aug 27, 2024

Changes in this version

+ const HistoryService_GetEvents_FullMethodName

+ const WebhookService_CreateWebhookSubscription_FullMethodName

+ const WebhookService_DeleteWebhookSubscription_FullMethodName

+ const WebhookService_ListWebhookSubscriptions_FullMethodName

+ var GetEventsQuery_PaginationOrder_name = map[int32]string

+ var GetEventsQuery_PaginationOrder_value = map[string]int32

+ var HistoryService_ServiceDesc = grpc.ServiceDesc

+ var WebhookService_ServiceDesc = grpc.ServiceDesc

+ func RegisterHistoryServiceServer(s grpc.ServiceRegistrar, srv HistoryServiceServer)

+ func RegisterWebhookServiceServer(s grpc.ServiceRegistrar, srv WebhookServiceServer)

+ type CreateWebhookSubscriptionRequest struct

+ Events []string

+ Target *ServiceEventTarget

+ TimeoutMs *uint32

+ Url string

+ func (*CreateWebhookSubscriptionRequest) Descriptor() ([]byte, []int)

+ func (*CreateWebhookSubscriptionRequest) ProtoMessage()

+ func (x *CreateWebhookSubscriptionRequest) GetEvents() []string

+ func (x *CreateWebhookSubscriptionRequest) GetTarget() *ServiceEventTarget

+ func (x *CreateWebhookSubscriptionRequest) GetTimeoutMs() uint32

+ func (x *CreateWebhookSubscriptionRequest) GetUrl() string

+ func (x *CreateWebhookSubscriptionRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateWebhookSubscriptionRequest) Reset()

+ func (x *CreateWebhookSubscriptionRequest) String() string

+ type CreateWebhookSubscriptionResponse struct

+ Subscription *WebhookSubscription

+ func (*CreateWebhookSubscriptionResponse) Descriptor() ([]byte, []int)

+ func (*CreateWebhookSubscriptionResponse) ProtoMessage()

+ func (x *CreateWebhookSubscriptionResponse) GetSubscription() *WebhookSubscription

+ func (x *CreateWebhookSubscriptionResponse) ProtoReflect() protoreflect.Message

+ func (x *CreateWebhookSubscriptionResponse) Reset()

+ func (x *CreateWebhookSubscriptionResponse) String() string

+ type DeleteWebhookSubscriptionRequest struct

+ WebhookId string

+ func (*DeleteWebhookSubscriptionRequest) Descriptor() ([]byte, []int)

+ func (*DeleteWebhookSubscriptionRequest) ProtoMessage()

+ func (x *DeleteWebhookSubscriptionRequest) GetWebhookId() string

+ func (x *DeleteWebhookSubscriptionRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteWebhookSubscriptionRequest) Reset()

+ func (x *DeleteWebhookSubscriptionRequest) String() string

+ type DeleteWebhookSubscriptionResponse struct

+ func (*DeleteWebhookSubscriptionResponse) Descriptor() ([]byte, []int)

+ func (*DeleteWebhookSubscriptionResponse) ProtoMessage()

+ func (x *DeleteWebhookSubscriptionResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteWebhookSubscriptionResponse) Reset()

+ func (x *DeleteWebhookSubscriptionResponse) String() string

+ type Event struct

+ Id string

+ Name string

+ Payload *structpb.Struct

+ PublishedAt *timestamppb.Timestamp

+ RequestMetadata *structpb.Value

+ Target *ServiceEventTarget

+ func (*Event) Descriptor() ([]byte, []int)

+ func (*Event) ProtoMessage()

+ func (x *Event) GetId() string

+ func (x *Event) GetName() string

+ func (x *Event) GetPayload() *structpb.Struct

+ func (x *Event) GetPublishedAt() *timestamppb.Timestamp

+ func (x *Event) GetRequestMetadata() *structpb.Value

+ func (x *Event) GetTarget() *ServiceEventTarget

+ func (x *Event) ProtoReflect() protoreflect.Message

+ func (x *Event) Reset()

+ func (x *Event) String() string

+ type GetEventsQuery struct

+ AfterTimestamp *timestamppb.Timestamp

+ BeforeTimestamp *timestamppb.Timestamp

+ Events []string

+ Limit int32

+ Order GetEventsQuery_PaginationOrder

+ Target *GetEventsQuery_Target

+ func (*GetEventsQuery) Descriptor() ([]byte, []int)

+ func (*GetEventsQuery) ProtoMessage()

+ func (x *GetEventsQuery) GetAfterTimestamp() *timestamppb.Timestamp

+ func (x *GetEventsQuery) GetBeforeTimestamp() *timestamppb.Timestamp

+ func (x *GetEventsQuery) GetEvents() []string

+ func (x *GetEventsQuery) GetLimit() int32

+ func (x *GetEventsQuery) GetOrder() GetEventsQuery_PaginationOrder

+ func (x *GetEventsQuery) GetTarget() *GetEventsQuery_Target

+ func (x *GetEventsQuery) ProtoReflect() protoreflect.Message

+ func (x *GetEventsQuery) Reset()

+ func (x *GetEventsQuery) String() string

+ type GetEventsQuery_PaginationOrder int32

+ const GetEventsQuery_PAGINATION_ORDER_CREATED_AT_ASC

+ const GetEventsQuery_PAGINATION_ORDER_CREATED_AT_DESC

+ const GetEventsQuery_PAGINATION_ORDER_UNSPECIFIED

+ func (GetEventsQuery_PaginationOrder) Descriptor() protoreflect.EnumDescriptor

+ func (GetEventsQuery_PaginationOrder) EnumDescriptor() ([]byte, []int)

+ func (GetEventsQuery_PaginationOrder) Type() protoreflect.EnumType

+ func (x GetEventsQuery_PaginationOrder) Enum() *GetEventsQuery_PaginationOrder

+ func (x GetEventsQuery_PaginationOrder) Number() protoreflect.EnumNumber

+ func (x GetEventsQuery_PaginationOrder) String() string

+ type GetEventsQuery_Target struct

+ CollectionId *GetEventsQuery_TargetValue

+ LayoutId *GetEventsQuery_TargetValue

+ ProjectId *GetEventsQuery_TargetValue

+ ServiceUserId *GetEventsQuery_TargetValue

+ func (*GetEventsQuery_Target) Descriptor() ([]byte, []int)

+ func (*GetEventsQuery_Target) ProtoMessage()

+ func (x *GetEventsQuery_Target) GetCollectionId() *GetEventsQuery_TargetValue

+ func (x *GetEventsQuery_Target) GetLayoutId() *GetEventsQuery_TargetValue

+ func (x *GetEventsQuery_Target) GetProjectId() *GetEventsQuery_TargetValue

+ func (x *GetEventsQuery_Target) GetServiceUserId() *GetEventsQuery_TargetValue

+ func (x *GetEventsQuery_Target) ProtoReflect() protoreflect.Message

+ func (x *GetEventsQuery_Target) Reset()

+ func (x *GetEventsQuery_Target) String() string

+ type GetEventsQuery_TargetValue struct

+ ExplicitOnly bool

+ Value string

+ func (*GetEventsQuery_TargetValue) Descriptor() ([]byte, []int)

+ func (*GetEventsQuery_TargetValue) ProtoMessage()

+ func (x *GetEventsQuery_TargetValue) GetExplicitOnly() bool

+ func (x *GetEventsQuery_TargetValue) GetValue() string

+ func (x *GetEventsQuery_TargetValue) ProtoReflect() protoreflect.Message

+ func (x *GetEventsQuery_TargetValue) Reset()

+ func (x *GetEventsQuery_TargetValue) String() string

+ type GetEventsRequest struct

+ Filter isGetEventsRequest_Filter

+ func (*GetEventsRequest) Descriptor() ([]byte, []int)

+ func (*GetEventsRequest) ProtoMessage()

+ func (m *GetEventsRequest) GetFilter() isGetEventsRequest_Filter

+ func (x *GetEventsRequest) GetCursor() string

+ func (x *GetEventsRequest) GetQuery() *GetEventsQuery

+ func (x *GetEventsRequest) ProtoReflect() protoreflect.Message

+ func (x *GetEventsRequest) Reset()

+ func (x *GetEventsRequest) String() string

+ type GetEventsRequest_Cursor struct

+ Cursor string

+ type GetEventsRequest_Query struct

+ Query *GetEventsQuery

+ type GetEventsResponse struct

+ Events []*Event

+ NextCursor *string

+ func (*GetEventsResponse) Descriptor() ([]byte, []int)

+ func (*GetEventsResponse) ProtoMessage()

+ func (x *GetEventsResponse) GetEvents() []*Event

+ func (x *GetEventsResponse) GetNextCursor() string

+ func (x *GetEventsResponse) ProtoReflect() protoreflect.Message

+ func (x *GetEventsResponse) Reset()

+ func (x *GetEventsResponse) String() string

+ type HistoryServiceClient interface

+ GetEvents func(ctx context.Context, in *GetEventsRequest, opts ...grpc.CallOption) (*GetEventsResponse, error)

+ func NewHistoryServiceClient(cc grpc.ClientConnInterface) HistoryServiceClient

+ type HistoryServiceServer interface

+ GetEvents func(context.Context, *GetEventsRequest) (*GetEventsResponse, error)

+ type ListWebhookSubscriptionsRequest struct

+ Target *ServiceEventTarget

+ func (*ListWebhookSubscriptionsRequest) Descriptor() ([]byte, []int)

+ func (*ListWebhookSubscriptionsRequest) ProtoMessage()

+ func (x *ListWebhookSubscriptionsRequest) GetTarget() *ServiceEventTarget

+ func (x *ListWebhookSubscriptionsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListWebhookSubscriptionsRequest) Reset()

+ func (x *ListWebhookSubscriptionsRequest) String() string

+ type ListWebhookSubscriptionsResponse struct

+ Subscriptions []*WebhookSubscription

+ func (*ListWebhookSubscriptionsResponse) Descriptor() ([]byte, []int)

+ func (*ListWebhookSubscriptionsResponse) ProtoMessage()

+ func (x *ListWebhookSubscriptionsResponse) GetSubscriptions() []*WebhookSubscription

+ func (x *ListWebhookSubscriptionsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListWebhookSubscriptionsResponse) Reset()

+ func (x *ListWebhookSubscriptionsResponse) String() string

+ type ServiceEventTarget struct

+ CollectionId *string

+ LayoutId *string

+ ProjectId *string

+ ServiceUserId *string

+ UserId *string

+ func (*ServiceEventTarget) Descriptor() ([]byte, []int)

+ func (*ServiceEventTarget) ProtoMessage()

+ func (x *ServiceEventTarget) GetCollectionId() string

+ func (x *ServiceEventTarget) GetLayoutId() string

+ func (x *ServiceEventTarget) GetProjectId() string

+ func (x *ServiceEventTarget) GetServiceUserId() string

+ func (x *ServiceEventTarget) GetUserId() string

+ func (x *ServiceEventTarget) ProtoReflect() protoreflect.Message

+ func (x *ServiceEventTarget) Reset()

+ func (x *ServiceEventTarget) String() string

type SubscribePayload

+ Events []string

+ func (x *SubscribePayload) GetEvents() []string

+ type UnimplementedHistoryServiceServer struct

+ func (UnimplementedHistoryServiceServer) GetEvents(context.Context, *GetEventsRequest) (*GetEventsResponse, error)

+ type UnimplementedWebhookServiceServer struct

+ func (UnimplementedWebhookServiceServer) CreateWebhookSubscription(context.Context, *CreateWebhookSubscriptionRequest) (*CreateWebhookSubscriptionResponse, error)

+ func (UnimplementedWebhookServiceServer) DeleteWebhookSubscription(context.Context, *DeleteWebhookSubscriptionRequest) (*DeleteWebhookSubscriptionResponse, error)

+ func (UnimplementedWebhookServiceServer) ListWebhookSubscriptions(context.Context, *ListWebhookSubscriptionsRequest) (*ListWebhookSubscriptionsResponse, error)

+ type UnsafeHistoryServiceServer interface

+ type UnsafeWebhookServiceServer interface

+ type WebhookServiceClient interface

+ CreateWebhookSubscription func(ctx context.Context, in *CreateWebhookSubscriptionRequest, ...) (*CreateWebhookSubscriptionResponse, error)

+ DeleteWebhookSubscription func(ctx context.Context, in *DeleteWebhookSubscriptionRequest, ...) (*DeleteWebhookSubscriptionResponse, error)

+ ListWebhookSubscriptions func(ctx context.Context, in *ListWebhookSubscriptionsRequest, ...) (*ListWebhookSubscriptionsResponse, error)

+ func NewWebhookServiceClient(cc grpc.ClientConnInterface) WebhookServiceClient

+ type WebhookServiceServer interface

+ CreateWebhookSubscription func(context.Context, *CreateWebhookSubscriptionRequest) (*CreateWebhookSubscriptionResponse, error)

+ DeleteWebhookSubscription func(context.Context, *DeleteWebhookSubscriptionRequest) (*DeleteWebhookSubscriptionResponse, error)

+ ListWebhookSubscriptions func(context.Context, *ListWebhookSubscriptionsRequest) (*ListWebhookSubscriptionsResponse, error)

+ type WebhookSubscription struct

+ Events []string

+ Target *ServiceEventTarget

+ TimeoutMs *uint32

+ Url string

+ WebhookId string

+ func (*WebhookSubscription) Descriptor() ([]byte, []int)

+ func (*WebhookSubscription) ProtoMessage()

+ func (x *WebhookSubscription) GetEvents() []string

+ func (x *WebhookSubscription) GetTarget() *ServiceEventTarget

+ func (x *WebhookSubscription) GetTimeoutMs() uint32

+ func (x *WebhookSubscription) GetUrl() string

+ func (x *WebhookSubscription) GetWebhookId() string

+ func (x *WebhookSubscription) ProtoReflect() protoreflect.Message

+ func (x *WebhookSubscription) Reset()

+ func (x *WebhookSubscription) String() string

v0.0.1

Apr 18, 2024

Changes in this version

+ const EventService_Publish_FullMethodName

+ const EventService_Stream_FullMethodName

+ var EventService_ServiceDesc = grpc.ServiceDesc

+ var EventsStreamMessageType_name = map[int32]string

+ var EventsStreamMessageType_value = map[string]int32

+ var File_apis_event_v2_api_proto protoreflect.FileDescriptor

+ func RegisterEventServiceServer(s grpc.ServiceRegistrar, srv EventServiceServer)

+ type EventServiceClient interface

+ Publish func(ctx context.Context, in *PublishEventRequest, opts ...grpc.CallOption) (*PublishEventResponse, error)

+ Stream func(ctx context.Context, opts ...grpc.CallOption) (EventService_StreamClient, error)

+ func NewEventServiceClient(cc grpc.ClientConnInterface) EventServiceClient

+ type EventServiceServer interface

+ Publish func(context.Context, *PublishEventRequest) (*PublishEventResponse, error)

+ Stream func(EventService_StreamServer) error

+ type EventService_StreamClient interface

+ Recv func() (*EventsStreamResponse, error)

+ Send func(*EventsStreamRequest) error

+ type EventService_StreamServer interface

+ Recv func() (*EventsStreamRequest, error)

+ Send func(*EventsStreamResponse) error

+ type EventTarget struct

+ CollectionId *string

+ LayoutId *string

+ ProjectId *string

+ func (*EventTarget) Descriptor() ([]byte, []int)

+ func (*EventTarget) ProtoMessage()

+ func (x *EventTarget) GetCollectionId() string

+ func (x *EventTarget) GetLayoutId() string

+ func (x *EventTarget) GetProjectId() string

+ func (x *EventTarget) ProtoReflect() protoreflect.Message

+ func (x *EventTarget) Reset()

+ func (x *EventTarget) String() string

+ type EventsStreamError struct

+ Code int32

+ Message string

+ func (*EventsStreamError) Descriptor() ([]byte, []int)

+ func (*EventsStreamError) ProtoMessage()

+ func (x *EventsStreamError) GetCode() int32

+ func (x *EventsStreamError) GetMessage() string

+ func (x *EventsStreamError) ProtoReflect() protoreflect.Message

+ func (x *EventsStreamError) Reset()

+ func (x *EventsStreamError) String() string

+ type EventsStreamMessageType int32

+ const EventsStreamMessageType_EVENTS_STREAM_MESSAGE_TYPE_ERROR

+ const EventsStreamMessageType_EVENTS_STREAM_MESSAGE_TYPE_PING

+ const EventsStreamMessageType_EVENTS_STREAM_MESSAGE_TYPE_PUBLISHED

+ const EventsStreamMessageType_EVENTS_STREAM_MESSAGE_TYPE_SUBSCRIBED

+ const EventsStreamMessageType_EVENTS_STREAM_MESSAGE_TYPE_UNSPECIFIED

+ const EventsStreamMessageType_EVENTS_STREAM_MESSAGE_TYPE_UNSUBSCRIBED

+ func (EventsStreamMessageType) Descriptor() protoreflect.EnumDescriptor

+ func (EventsStreamMessageType) EnumDescriptor() ([]byte, []int)

+ func (EventsStreamMessageType) Type() protoreflect.EnumType

+ func (x EventsStreamMessageType) Enum() *EventsStreamMessageType

+ func (x EventsStreamMessageType) Number() protoreflect.EnumNumber

+ func (x EventsStreamMessageType) String() string

+ type EventsStreamReconnectRequest struct

+ BeforeTimestamp string

+ Reauthenticate bool

+ func (*EventsStreamReconnectRequest) Descriptor() ([]byte, []int)

+ func (*EventsStreamReconnectRequest) ProtoMessage()

+ func (x *EventsStreamReconnectRequest) GetBeforeTimestamp() string

+ func (x *EventsStreamReconnectRequest) GetReauthenticate() bool

+ func (x *EventsStreamReconnectRequest) ProtoReflect() protoreflect.Message

+ func (x *EventsStreamReconnectRequest) Reset()

+ func (x *EventsStreamReconnectRequest) String() string

+ type EventsStreamRequest struct

+ CorrelationId *string

+ EventPayload isEventsStreamRequest_EventPayload

+ func (*EventsStreamRequest) Descriptor() ([]byte, []int)

+ func (*EventsStreamRequest) ProtoMessage()

+ func (m *EventsStreamRequest) GetEventPayload() isEventsStreamRequest_EventPayload

+ func (x *EventsStreamRequest) GetCorrelationId() string

+ func (x *EventsStreamRequest) GetPing() string

+ func (x *EventsStreamRequest) GetPublish() *PublishEventRequest

+ func (x *EventsStreamRequest) GetSubscribe() *SubscribePayload

+ func (x *EventsStreamRequest) GetUnsubscribe() *SubscribePayload

+ func (x *EventsStreamRequest) ProtoReflect() protoreflect.Message

+ func (x *EventsStreamRequest) Reset()

+ func (x *EventsStreamRequest) String() string

+ type EventsStreamRequest_Ping struct

+ Ping string

+ type EventsStreamRequest_Publish struct

+ Publish *PublishEventRequest

+ type EventsStreamRequest_Subscribe struct

+ Subscribe *SubscribePayload

+ type EventsStreamRequest_Unsubscribe struct

+ Unsubscribe *SubscribePayload

+ type EventsStreamResponse struct

+ CorrelationId *string

+ EventPayload isEventsStreamResponse_EventPayload

+ SessionId *string

+ func (*EventsStreamResponse) Descriptor() ([]byte, []int)

+ func (*EventsStreamResponse) ProtoMessage()

+ func (m *EventsStreamResponse) GetEventPayload() isEventsStreamResponse_EventPayload

+ func (x *EventsStreamResponse) GetCorrelationId() string

+ func (x *EventsStreamResponse) GetError() *EventsStreamError

+ func (x *EventsStreamResponse) GetEvent() *PublishEventResponse

+ func (x *EventsStreamResponse) GetPong() string

+ func (x *EventsStreamResponse) GetPublished() *PublishEventResponse

+ func (x *EventsStreamResponse) GetReconnectBefore() *EventsStreamReconnectRequest

+ func (x *EventsStreamResponse) GetSessionId() string

+ func (x *EventsStreamResponse) GetSubscribed() *SubscribePayload

+ func (x *EventsStreamResponse) GetUnsubscribed() *SubscribePayload

+ func (x *EventsStreamResponse) ProtoReflect() protoreflect.Message

+ func (x *EventsStreamResponse) Reset()

+ func (x *EventsStreamResponse) String() string

+ type EventsStreamResponse_Error struct

+ Error *EventsStreamError

+ type EventsStreamResponse_Event struct

+ Event *PublishEventResponse

+ type EventsStreamResponse_Pong struct

+ Pong string

+ type EventsStreamResponse_Published struct

+ Published *PublishEventResponse

+ type EventsStreamResponse_ReconnectBefore struct

+ ReconnectBefore *EventsStreamReconnectRequest

+ type EventsStreamResponse_Subscribed struct

+ Subscribed *SubscribePayload

+ type EventsStreamResponse_Unsubscribed struct

+ Unsubscribed *SubscribePayload

+ type PublishEventRequest struct

+ Name string

+ Payload *structpb.Struct

+ RequestMetadata *structpb.Value

+ Target *EventTarget

+ func (*PublishEventRequest) Descriptor() ([]byte, []int)

+ func (*PublishEventRequest) ProtoMessage()

+ func (x *PublishEventRequest) GetName() string

+ func (x *PublishEventRequest) GetPayload() *structpb.Struct

+ func (x *PublishEventRequest) GetRequestMetadata() *structpb.Value

+ func (x *PublishEventRequest) GetTarget() *EventTarget

+ func (x *PublishEventRequest) ProtoReflect() protoreflect.Message

+ func (x *PublishEventRequest) Reset()

+ func (x *PublishEventRequest) String() string

+ type PublishEventResponse struct

+ Id string

+ Name string

+ Payload *structpb.Struct

+ RequestMetadata *structpb.Value

+ Target *EventTarget

+ func (*PublishEventResponse) Descriptor() ([]byte, []int)

+ func (*PublishEventResponse) ProtoMessage()

+ func (x *PublishEventResponse) GetId() string

+ func (x *PublishEventResponse) GetName() string

+ func (x *PublishEventResponse) GetPayload() *structpb.Struct

+ func (x *PublishEventResponse) GetRequestMetadata() *structpb.Value

+ func (x *PublishEventResponse) GetTarget() *EventTarget

+ func (x *PublishEventResponse) ProtoReflect() protoreflect.Message

+ func (x *PublishEventResponse) Reset()

+ func (x *PublishEventResponse) String() string

+ type SubscribePayload struct

+ Name string

+ Target *EventTarget

+ func (*SubscribePayload) Descriptor() ([]byte, []int)

+ func (*SubscribePayload) ProtoMessage()

+ func (x *SubscribePayload) GetName() string

+ func (x *SubscribePayload) GetTarget() *EventTarget

+ func (x *SubscribePayload) ProtoReflect() protoreflect.Message

+ func (x *SubscribePayload) Reset()

+ func (x *SubscribePayload) String() string

+ type UnimplementedEventServiceServer struct

+ func (UnimplementedEventServiceServer) Publish(context.Context, *PublishEventRequest) (*PublishEventResponse, error)

+ func (UnimplementedEventServiceServer) Stream(EventService_StreamServer) error

+ type UnsafeEventServiceServer interface