v1

package
v0.0.0-...-2b6d021 Latest Latest
Warning

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

 Go to latest Published: Sep 7, 2023 License: MPL-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SubscriptionTransport_name = map[int32]string{
		0: "SUBSCRIPTION_TRANSPORT_WEBHOOK_UNSPECIFIED",
		2: "SUBSCRIPTION_TRANSPORT_WS",
		3: "SUBSCRIPTION_TRANSPORT_AWS_SNS",
	}
	SubscriptionTransport_value = map[string]int32{
		"SUBSCRIPTION_TRANSPORT_WEBHOOK_UNSPECIFIED": 0,
		"SUBSCRIPTION_TRANSPORT_WS":                  2,
		"SUBSCRIPTION_TRANSPORT_AWS_SNS":             3,
	}
)

Enum value maps for SubscriptionTransport.

View Source 
var File_events_notifications_v1_notifications_proto protoreflect.FileDescriptor
View Source 
var Notifications_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "events.notifications.v1.Notifications",
	HandlerType: (*NotificationsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Subscription",
			Handler:    _Notifications_Subscription_Handler,
		},
		{
			MethodName: "DeleteSubscription",
			Handler:    _Notifications_DeleteSubscription_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "events/notifications/v1/notifications.proto",
}

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

Functions

func RegisterNotificationsServer 

func RegisterNotificationsServer(s grpc.ServiceRegistrar, srv NotificationsServer)

Types

type DeleteSubscriptionRequest 

type DeleteSubscriptionRequest struct {
	Identifier string `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*DeleteSubscriptionRequest) GetIdentifier 

func (x *DeleteSubscriptionRequest) GetIdentifier() string

func (*DeleteSubscriptionRequest) ProtoMessage 

func (*DeleteSubscriptionRequest) ProtoMessage()

func (*DeleteSubscriptionRequest) ProtoReflect 

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

func (*DeleteSubscriptionRequest) Reset 

func (x *DeleteSubscriptionRequest) Reset()

func (*DeleteSubscriptionRequest) String 

func (x *DeleteSubscriptionRequest) String() string

type DeleteSubscriptionResponse 

type DeleteSubscriptionResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSubscriptionResponse) Descriptor deprecated 

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

Deprecated: Use DeleteSubscriptionResponse.ProtoReflect.Descriptor instead.

func (*DeleteSubscriptionResponse) GetSuccess 

func (x *DeleteSubscriptionResponse) GetSuccess() bool

func (*DeleteSubscriptionResponse) ProtoMessage 

func (*DeleteSubscriptionResponse) ProtoMessage()

func (*DeleteSubscriptionResponse) ProtoReflect 

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

func (*DeleteSubscriptionResponse) Reset 

func (x *DeleteSubscriptionResponse) Reset()

func (*DeleteSubscriptionResponse) String 

func (x *DeleteSubscriptionResponse) String() string

type NotificationsClient 

type NotificationsClient interface {
	Subscription(ctx context.Context, in *SubscriptionRequest, opts ...grpc.CallOption) (*SubscriptionResponse, error)
	DeleteSubscription(ctx context.Context, in *DeleteSubscriptionRequest, opts ...grpc.CallOption) (*DeleteSubscriptionResponse, error)
}

NotificationsClient is the client API for Notifications 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 NewNotificationsClient 

func NewNotificationsClient(cc grpc.ClientConnInterface) NotificationsClient

type NotificationsServer 

type NotificationsServer interface {
	Subscription(context.Context, *SubscriptionRequest) (*SubscriptionResponse, error)
	DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*DeleteSubscriptionResponse, error)
	// contains filtered or unexported methods
}

NotificationsServer is the server API for Notifications service. All implementations must embed UnimplementedNotificationsServer for forward compatibility

type Subscription 

type Subscription struct {
	Identifier    string `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	WebookURL     string `protobuf:"bytes,2,opt,name=WebookURL,proto3" json:"WebookURL,omitempty"`
	WebSocketHost string `protobuf:"bytes,3,opt,name=WebSocketHost,proto3" json:"WebSocketHost,omitempty"`
	SnsArn        string `protobuf:"bytes,4,opt,name=SnsArn,proto3" json:"SnsArn,omitempty"`
	Retries       int32  `protobuf:"varint,5,opt,name=Retries,proto3" json:"Retries,omitempty"`
	// contains filtered or unexported fields
}

func (*Subscription) Descriptor deprecated 

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

Deprecated: Use Subscription.ProtoReflect.Descriptor instead.

func (*Subscription) GetIdentifier 

func (x *Subscription) GetIdentifier() string

func (*Subscription) GetRetries 

func (x *Subscription) GetRetries() int32

func (*Subscription) GetSnsArn 

func (x *Subscription) GetSnsArn() string

func (*Subscription) GetWebSocketHost 

func (x *Subscription) GetWebSocketHost() string

func (*Subscription) GetWebookURL 

func (x *Subscription) GetWebookURL() string

func (*Subscription) ProtoMessage 

func (*Subscription) ProtoMessage()

func (*Subscription) ProtoReflect 

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

func (*Subscription) Reset 

func (x *Subscription) Reset()

func (*Subscription) String 

func (x *Subscription) String() string

type SubscriptionRequest 

type SubscriptionRequest struct {
	Subscription *Subscription `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use SubscriptionRequest.ProtoReflect.Descriptor instead.

func (*SubscriptionRequest) GetSubscription 

func (x *SubscriptionRequest) GetSubscription() *Subscription

func (*SubscriptionRequest) ProtoMessage 

func (*SubscriptionRequest) ProtoMessage()

func (*SubscriptionRequest) ProtoReflect 

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

func (*SubscriptionRequest) Reset 

func (x *SubscriptionRequest) Reset()

func (*SubscriptionRequest) String 

func (x *SubscriptionRequest) String() string

type SubscriptionResponse 

type SubscriptionResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionResponse) Descriptor deprecated 

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

Deprecated: Use SubscriptionResponse.ProtoReflect.Descriptor instead.

func (*SubscriptionResponse) GetSuccess 

func (x *SubscriptionResponse) GetSuccess() bool

func (*SubscriptionResponse) ProtoMessage 

func (*SubscriptionResponse) ProtoMessage()

func (*SubscriptionResponse) ProtoReflect 

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

func (*SubscriptionResponse) Reset 

func (x *SubscriptionResponse) Reset()

func (*SubscriptionResponse) String 

func (x *SubscriptionResponse) String() string

type SubscriptionTransport 

type SubscriptionTransport int32
const (
	SubscriptionTransport_SUBSCRIPTION_TRANSPORT_WEBHOOK_UNSPECIFIED SubscriptionTransport = 0
	SubscriptionTransport_SUBSCRIPTION_TRANSPORT_WS                  SubscriptionTransport = 2
	SubscriptionTransport_SUBSCRIPTION_TRANSPORT_AWS_SNS             SubscriptionTransport = 3
)

func (SubscriptionTransport) Descriptor 

func (SubscriptionTransport) Descriptor() protoreflect.EnumDescriptor

func (SubscriptionTransport) Enum 

func (x SubscriptionTransport) Enum() *SubscriptionTransport

func (SubscriptionTransport) EnumDescriptor deprecated 

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

Deprecated: Use SubscriptionTransport.Descriptor instead.

func (SubscriptionTransport) Number 

func (x SubscriptionTransport) Number() protoreflect.EnumNumber

func (SubscriptionTransport) String 

func (x SubscriptionTransport) String() string

func (SubscriptionTransport) Type 

func (SubscriptionTransport) Type() protoreflect.EnumType

type UnimplementedNotificationsServer 

type UnimplementedNotificationsServer struct {
}

UnimplementedNotificationsServer must be embedded to have forward compatible implementations.

func (UnimplementedNotificationsServer) DeleteSubscription 

func (UnimplementedNotificationsServer) DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*DeleteSubscriptionResponse, error)

func (UnimplementedNotificationsServer) Subscription 

func (UnimplementedNotificationsServer) Subscription(context.Context, *SubscriptionRequest) (*SubscriptionResponse, error)

type UnsafeNotificationsServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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