queue

package
v0.0.0-...-68ea74a Latest Latest
Warning

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

 Go to latest Published: Oct 7, 2022 License: Apache-2.0 Imports: 10 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_api_queue_proto protoreflect.FileDescriptor

Functions

func RegisterQueueApiServer 

func RegisterQueueApiServer(s *grpc.Server, srv QueueApiServer)

Types

type AckRequest 

type AckRequest struct {
	UserToken string `protobuf:"bytes,1,opt,name=user_token,json=userToken,proto3" json:"user_token,omitempty"`
	Success   bool   `protobuf:"varint,2,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) GetSuccess 

func (x *AckRequest) GetSuccess() bool

func (*AckRequest) GetUserToken 

func (x *AckRequest) GetUserToken() string

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 AckResponse 

type AckResponse struct {
	// contains filtered or unexported fields
}

func (*AckResponse) Descriptor deprecated 

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

Deprecated: Use AckResponse.ProtoReflect.Descriptor instead.

func (*AckResponse) ProtoMessage 

func (*AckResponse) ProtoMessage()

func (*AckResponse) ProtoReflect 

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

func (*AckResponse) Reset 

func (x *AckResponse) Reset()

func (*AckResponse) String 

func (x *AckResponse) String() string

type CloseRequest 

type CloseRequest struct {
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseRequest) Descriptor deprecated 

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

Deprecated: Use CloseRequest.ProtoReflect.Descriptor instead.

func (*CloseRequest) GetClientId 

func (x *CloseRequest) GetClientId() string

func (*CloseRequest) ProtoMessage 

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) ProtoReflect 

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

func (*CloseRequest) Reset 

func (x *CloseRequest) Reset()

func (*CloseRequest) String 

func (x *CloseRequest) String() string

type CloseResponse 

type CloseResponse struct {
	// contains filtered or unexported fields
}

func (*CloseResponse) Descriptor deprecated 

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

Deprecated: Use CloseResponse.ProtoReflect.Descriptor instead.

func (*CloseResponse) ProtoMessage 

func (*CloseResponse) ProtoMessage()

func (*CloseResponse) ProtoReflect 

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

func (*CloseResponse) Reset 

func (x *CloseResponse) Reset()

func (*CloseResponse) String 

func (x *CloseResponse) String() string

type EventMsg 

type EventMsg struct {
	ClientId        string               `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	EventJson       string               `protobuf:"bytes,3,opt,name=event_json,json=eventJson,proto3" json:"event_json,omitempty"`
	UserToken       string               `protobuf:"bytes,4,opt,name=user_token,json=userToken,proto3" json:"user_token,omitempty"`
	FutureUserToken string               `protobuf:"bytes,5,opt,name=future_user_token,json=futureUserToken,proto3" json:"future_user_token,omitempty"`
	EffectiveDate   *timestamp.Timestamp `protobuf:"bytes,6,opt,name=effective_date,json=effectiveDate,proto3" json:"effective_date,omitempty"`
	SearchKey1      int64                `protobuf:"varint,7,opt,name=search_key1,json=searchKey1,proto3" json:"search_key1,omitempty"`
	SearchKey2      int64                `protobuf:"varint,8,opt,name=search_key2,json=searchKey2,proto3" json:"search_key2,omitempty"`
	// contains filtered or unexported fields
}

func (*EventMsg) Descriptor deprecated 

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

Deprecated: Use EventMsg.ProtoReflect.Descriptor instead.

func (*EventMsg) GetClientId 

func (x *EventMsg) GetClientId() string

func (*EventMsg) GetEffectiveDate 

func (x *EventMsg) GetEffectiveDate() *timestamp.Timestamp

func (*EventMsg) GetEventJson 

func (x *EventMsg) GetEventJson() string

func (*EventMsg) GetFutureUserToken 

func (x *EventMsg) GetFutureUserToken() string

func (*EventMsg) GetSearchKey1 

func (x *EventMsg) GetSearchKey1() int64

func (*EventMsg) GetSearchKey2 

func (x *EventMsg) GetSearchKey2() int64

func (*EventMsg) GetUserToken 

func (x *EventMsg) GetUserToken() string

func (*EventMsg) ProtoMessage 

func (*EventMsg) ProtoMessage()

func (*EventMsg) ProtoReflect 

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

func (*EventMsg) Reset 

func (x *EventMsg) Reset()

func (*EventMsg) String 

func (x *EventMsg) String() string

type PostEventResponse 

type PostEventResponse struct {
	// contains filtered or unexported fields
}

func (*PostEventResponse) Descriptor deprecated 

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

Deprecated: Use PostEventResponse.ProtoReflect.Descriptor instead.

func (*PostEventResponse) ProtoMessage 

func (*PostEventResponse) ProtoMessage()

func (*PostEventResponse) ProtoReflect 

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

func (*PostEventResponse) Reset 

func (x *PostEventResponse) Reset()

func (*PostEventResponse) String 

func (x *PostEventResponse) String() string

type QueueApiClient 

type QueueApiClient interface {
	PostEvent(ctx context.Context, in *EventMsg, opts ...grpc.CallOption) (*PostEventResponse, error)
	SubscribeEvents(ctx context.Context, in *SubscriptionRequest, opts ...grpc.CallOption) (QueueApi_SubscribeEventsClient, error)
	Ack(ctx context.Context, in *AckRequest, opts ...grpc.CallOption) (*AckResponse, error)
	Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error)
}

QueueApiClient is the client API for QueueApi service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueueApiClient 

func NewQueueApiClient(cc grpc.ClientConnInterface) QueueApiClient

type QueueApiServer 

type QueueApiServer interface {
	PostEvent(context.Context, *EventMsg) (*PostEventResponse, error)
	SubscribeEvents(*SubscriptionRequest, QueueApi_SubscribeEventsServer) error
	Ack(context.Context, *AckRequest) (*AckResponse, error)
	Close(context.Context, *CloseRequest) (*CloseResponse, error)
}

QueueApiServer is the server API for QueueApi service.

type QueueApi_SubscribeEventsClient 

type QueueApi_SubscribeEventsClient interface {
	Recv() (*EventMsg, error)
	grpc.ClientStream
}

type QueueApi_SubscribeEventsServer 

type QueueApi_SubscribeEventsServer interface {
	Send(*EventMsg) error
	grpc.ServerStream
}

type SubscriptionRequest 

type SubscriptionRequest struct {
	ClientId   string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	SearchKey2 int64  `protobuf:"varint,2,opt,name=search_key2,json=searchKey2,proto3" json:"search_key2,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use SubscriptionRequest.ProtoReflect.Descriptor instead.

func (*SubscriptionRequest) GetClientId 

func (x *SubscriptionRequest) GetClientId() string

func (*SubscriptionRequest) GetSearchKey2 

func (x *SubscriptionRequest) GetSearchKey2() int64

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 {
	// contains filtered or unexported fields
}

func (*SubscriptionResponse) Descriptor deprecated 

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

Deprecated: Use SubscriptionResponse.ProtoReflect.Descriptor instead.

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 UnimplementedQueueApiServer 

type UnimplementedQueueApiServer struct {
}

UnimplementedQueueApiServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueueApiServer) Ack 

func (*UnimplementedQueueApiServer) Ack(context.Context, *AckRequest) (*AckResponse, error)

func (*UnimplementedQueueApiServer) Close 

func (*UnimplementedQueueApiServer) Close(context.Context, *CloseRequest) (*CloseResponse, error)

func (*UnimplementedQueueApiServer) PostEvent 

func (*UnimplementedQueueApiServer) PostEvent(context.Context, *EventMsg) (*PostEventResponse, error)

func (*UnimplementedQueueApiServer) SubscribeEvents 

func (*UnimplementedQueueApiServer) SubscribeEvents(*SubscriptionRequest, QueueApi_SubscribeEventsServer) error

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.