s3

package
v0.0.0-...-726f7ef Latest Latest
Warning

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

 Go to latest Published: Feb 12, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	NotificationStream_StreamRecordType_name = map[int32]string{
		0: "UpdateDelta",
	}
	NotificationStream_StreamRecordType_value = map[string]int32{
		"UpdateDelta": 0,
	}
)

Enum value maps for NotificationStream_StreamRecordType.

View Source 
var File_s3_proto protoreflect.FileDescriptor
View Source 
var NotificationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "notificationpubsub.NotificationService",
	HandlerType: (*NotificationServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "subscribeNotifications",
			Handler:       _NotificationService_SubscribeNotifications_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "s3.proto",
}

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

Functions

func RegisterNotificationServiceServer 

func RegisterNotificationServiceServer(s grpc.ServiceRegistrar, srv NotificationServiceServer)

Types

type AckMsg 

type AckMsg struct {
	Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*AckMsg) Descriptor deprecated 

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

Deprecated: Use AckMsg.ProtoReflect.Descriptor instead.

func (*AckMsg) GetTimestamp 

func (x *AckMsg) GetTimestamp() int64

func (*AckMsg) ProtoMessage 

func (*AckMsg) ProtoMessage()

func (*AckMsg) ProtoReflect 

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

func (*AckMsg) Reset 

func (x *AckMsg) Reset()

func (*AckMsg) String 

func (x *AckMsg) String() string

type NotificationServiceClient 

type NotificationServiceClient interface {
	SubscribeNotifications(ctx context.Context, opts ...grpc.CallOption) (NotificationService_SubscribeNotificationsClient, error)
}

NotificationServiceClient is the client API for NotificationService 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 NewNotificationServiceClient 

func NewNotificationServiceClient(cc grpc.ClientConnInterface) NotificationServiceClient

type NotificationServiceServer 

type NotificationServiceServer interface {
	SubscribeNotifications(NotificationService_SubscribeNotificationsServer) error
	// contains filtered or unexported methods
}

NotificationServiceServer is the server API for NotificationService service. All implementations must embed UnimplementedNotificationServiceServer for forward compatibility

type NotificationService_SubscribeNotificationsClient 

type NotificationService_SubscribeNotificationsClient interface {
	Send(*RequestStream) error
	Recv() (*NotificationStream, error)
	grpc.ClientStream
}

type NotificationService_SubscribeNotificationsServer 

type NotificationService_SubscribeNotificationsServer interface {
	Send(*NotificationStream) error
	Recv() (*RequestStream, error)
	grpc.ServerStream
}

type NotificationStream 

type NotificationStream struct {
	SequenceId int64                               `protobuf:"varint,1,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"`
	Type       NotificationStream_StreamRecordType `protobuf:"varint,2,opt,name=type,proto3,enum=notificationpubsub.NotificationStream_StreamRecordType" json:"type,omitempty"`
	Payload    *Payload                            `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	Timestamp  int64                               `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*NotificationStream) Descriptor deprecated 

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

Deprecated: Use NotificationStream.ProtoReflect.Descriptor instead.

func (*NotificationStream) GetPayload 

func (x *NotificationStream) GetPayload() *Payload

func (*NotificationStream) GetSequenceId 

func (x *NotificationStream) GetSequenceId() int64

func (*NotificationStream) GetTimestamp 

func (x *NotificationStream) GetTimestamp() int64

func (*NotificationStream) GetType 

func (x *NotificationStream) GetType() NotificationStream_StreamRecordType

func (*NotificationStream) ProtoMessage 

func (*NotificationStream) ProtoMessage()

func (*NotificationStream) ProtoReflect 

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

func (*NotificationStream) Reset 

func (x *NotificationStream) Reset()

func (*NotificationStream) String 

func (x *NotificationStream) String() string

type NotificationStream_StreamRecordType 

type NotificationStream_StreamRecordType int32
const (
	NotificationStream_UpdateDelta NotificationStream_StreamRecordType = 0
)

func (NotificationStream_StreamRecordType) Descriptor 

func (NotificationStream_StreamRecordType) Descriptor() protoreflect.EnumDescriptor

func (NotificationStream_StreamRecordType) Enum 

func (x NotificationStream_StreamRecordType) Enum() *NotificationStream_StreamRecordType

func (NotificationStream_StreamRecordType) EnumDescriptor deprecated 

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

Deprecated: Use NotificationStream_StreamRecordType.Descriptor instead.

func (NotificationStream_StreamRecordType) Number 

func (x NotificationStream_StreamRecordType) Number() protoreflect.EnumNumber

func (NotificationStream_StreamRecordType) String 

func (x NotificationStream_StreamRecordType) String() string

func (NotificationStream_StreamRecordType) Type 

func (NotificationStream_StreamRecordType) Type() protoreflect.EnumType

type Payload 

type Payload struct {
	ObjectId string               `protobuf:"bytes,1,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	Bucket   string               `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
	OldState *Payload_ObjectState `protobuf:"bytes,3,opt,name=old_state,json=oldState,proto3" json:"old_state,omitempty"`
	NewState *Payload_ObjectState `protobuf:"bytes,4,opt,name=new_state,json=newState,proto3" json:"new_state,omitempty"`
	// contains filtered or unexported fields
}

func (*Payload) Descriptor deprecated 

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

Deprecated: Use Payload.ProtoReflect.Descriptor instead.

func (*Payload) GetBucket 

func (x *Payload) GetBucket() string

func (*Payload) GetNewState 

func (x *Payload) GetNewState() *Payload_ObjectState

func (*Payload) GetObjectId 

func (x *Payload) GetObjectId() string

func (*Payload) GetOldState 

func (x *Payload) GetOldState() *Payload_ObjectState

func (*Payload) ProtoMessage 

func (*Payload) ProtoMessage()

func (*Payload) ProtoReflect 

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

func (*Payload) Reset 

func (x *Payload) Reset()

func (*Payload) String 

func (x *Payload) String() string

type Payload_ObjectState 

type Payload_ObjectState struct {
	ContentLength int64             `protobuf:"varint,1,opt,name=contentLength,proto3" json:"contentLength,omitempty"`
	LastModified  int64             `protobuf:"varint,2,opt,name=lastModified,proto3" json:"lastModified,omitempty"`
	Attributes    map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Payload_ObjectState) Descriptor deprecated 

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

Deprecated: Use Payload_ObjectState.ProtoReflect.Descriptor instead.

func (*Payload_ObjectState) GetAttributes 

func (x *Payload_ObjectState) GetAttributes() map[string]string

func (*Payload_ObjectState) GetContentLength 

func (x *Payload_ObjectState) GetContentLength() int64

func (*Payload_ObjectState) GetLastModified 

func (x *Payload_ObjectState) GetLastModified() int64

func (*Payload_ObjectState) ProtoMessage 

func (*Payload_ObjectState) ProtoMessage()

func (*Payload_ObjectState) ProtoReflect 

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

func (*Payload_ObjectState) Reset 

func (x *Payload_ObjectState) Reset()

func (*Payload_ObjectState) String 

func (x *Payload_ObjectState) String() string

type RequestStream 

type RequestStream struct {

	// Types that are assignable to Val:
	//	*RequestStream_Request
	//	*RequestStream_Ack
	Val isRequestStream_Val `protobuf_oneof:"val"`
	// contains filtered or unexported fields
}

func (*RequestStream) Descriptor deprecated 

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

Deprecated: Use RequestStream.ProtoReflect.Descriptor instead.

func (*RequestStream) GetAck 

func (x *RequestStream) GetAck() *AckMsg

func (*RequestStream) GetRequest 

func (x *RequestStream) GetRequest() *SubRequest

func (*RequestStream) GetVal 

func (m *RequestStream) GetVal() isRequestStream_Val

func (*RequestStream) ProtoMessage 

func (*RequestStream) ProtoMessage()

func (*RequestStream) ProtoReflect 

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

func (*RequestStream) Reset 

func (x *RequestStream) Reset()

func (*RequestStream) String 

func (x *RequestStream) String() string

type RequestStream_Ack 

type RequestStream_Ack struct {
	Ack *AckMsg `protobuf:"bytes,2,opt,name=ack,proto3,oneof"`
}

type RequestStream_Request 

type RequestStream_Request struct {
	Request *SubRequest `protobuf:"bytes,1,opt,name=request,proto3,oneof"`
}

type SubRequest 

type SubRequest struct {
	Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Sync      bool  `protobuf:"varint,2,opt,name=sync,proto3" json:"sync,omitempty"`
	// contains filtered or unexported fields
}

func (*SubRequest) Descriptor deprecated 

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

Deprecated: Use SubRequest.ProtoReflect.Descriptor instead.

func (*SubRequest) GetSync 

func (x *SubRequest) GetSync() bool

func (*SubRequest) GetTimestamp 

func (x *SubRequest) GetTimestamp() int64

func (*SubRequest) ProtoMessage 

func (*SubRequest) ProtoMessage()

func (*SubRequest) ProtoReflect 

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

func (*SubRequest) Reset 

func (x *SubRequest) Reset()

func (*SubRequest) String 

func (x *SubRequest) String() string

type UnimplementedNotificationServiceServer 

type UnimplementedNotificationServiceServer struct {
}

UnimplementedNotificationServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedNotificationServiceServer) SubscribeNotifications 

func (UnimplementedNotificationServiceServer) SubscribeNotifications(NotificationService_SubscribeNotificationsServer) error

type UnsafeNotificationServiceServer 

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

UnsafeNotificationServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NotificationServiceServer 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.