pubnub

package
v0.0.0-...-92b9dd0 Latest Latest
Warning

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

 Go to latest Published: Feb 6, 2020 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DriverTrackingMessage_DriverStatus_name = map[int32]string{
	0: "CUSTOM",
	1: "UNAVAILABLE",
	2: "WAITING_FOR_ASSIGNMENT",
	3: "EN_ROUTE_TO_PICKUP",
	4: "EN_ROUTE_TO_DELIVER",
}
View Source 
var DriverTrackingMessage_DriverStatus_value = map[string]int32{
	"CUSTOM":                 0,
	"UNAVAILABLE":            1,
	"WAITING_FOR_ASSIGNMENT": 2,
	"EN_ROUTE_TO_PICKUP":     3,
	"EN_ROUTE_TO_DELIVER":    4,
}
View Source 
var LocationTrackingMessage_TrackingStatus_name = map[int32]string{
	0: "CUSTOM",
	1: "READY_FOR_PICKUP",
	2: "EN_ROUTE_TO_DELIVER",
	3: "DELIVERED",
	4: "UNABLE_TO_DELIVER",
	5: "RETURNING",
	6: "CLOSED",
	7: "EXCEPTION",
}
View Source 
var LocationTrackingMessage_TrackingStatus_value = map[string]int32{
	"CUSTOM":              0,
	"READY_FOR_PICKUP":    1,
	"EN_ROUTE_TO_DELIVER": 2,
	"DELIVERED":           3,
	"UNABLE_TO_DELIVER":   4,
	"RETURNING":           5,
	"CLOSED":              6,
	"EXCEPTION":           7,
}
View Source 
var PublishResponse_Status_name = map[int32]string{
	0: "SUCCESS",
	1: "ERROR",
}
View Source 
var PublishResponse_Status_value = map[string]int32{
	"SUCCESS": 0,
	"ERROR":   1,
}

Functions

func RegisterDriverTrackingServer 

func RegisterDriverTrackingServer(s *grpc.Server, srv DriverTrackingServer)

func RegisterLocationTrackingServer 

func RegisterLocationTrackingServer(s *grpc.Server, srv LocationTrackingServer)

func RegisterPubSubServer 

func RegisterPubSubServer(s *grpc.Server, srv PubSubServer)

Types

type DriverTrackingClient 

type DriverTrackingClient interface {
	// Send a stream of driver tracking messages
	Publish(ctx context.Context, opts ...grpc.CallOption) (DriverTracking_PublishClient, error)
	// Subscribe to driver tracking messages on a channel
	Subscribe(ctx context.Context, in *Subscription, opts ...grpc.CallOption) (DriverTracking_SubscribeClient, error)
}

DriverTrackingClient is the client API for DriverTracking service.

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

func NewDriverTrackingClient 

func NewDriverTrackingClient(cc *grpc.ClientConn) DriverTrackingClient

type DriverTrackingEnvelope 

type DriverTrackingEnvelope struct {
	Channel              string                 `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	Data                 *DriverTrackingMessage `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*DriverTrackingEnvelope) Descriptor 

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

func (*DriverTrackingEnvelope) GetChannel 

func (m *DriverTrackingEnvelope) GetChannel() string

func (*DriverTrackingEnvelope) GetData 

func (m *DriverTrackingEnvelope) GetData() *DriverTrackingMessage

func (*DriverTrackingEnvelope) ProtoMessage 

func (*DriverTrackingEnvelope) ProtoMessage()

func (*DriverTrackingEnvelope) Reset 

func (m *DriverTrackingEnvelope) Reset()

func (*DriverTrackingEnvelope) String 

func (m *DriverTrackingEnvelope) String() string

func (*DriverTrackingEnvelope) XXX_DiscardUnknown 

func (m *DriverTrackingEnvelope) XXX_DiscardUnknown()

func (*DriverTrackingEnvelope) XXX_Marshal 

func (m *DriverTrackingEnvelope) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DriverTrackingEnvelope) XXX_Merge 

func (m *DriverTrackingEnvelope) XXX_Merge(src proto.Message)

func (*DriverTrackingEnvelope) XXX_Size 

func (m *DriverTrackingEnvelope) XXX_Size() int

func (*DriverTrackingEnvelope) XXX_Unmarshal 

func (m *DriverTrackingEnvelope) XXX_Unmarshal(b []byte) error

type DriverTrackingMessage 

type DriverTrackingMessage struct {
	DriverId             string                             `protobuf:"bytes,1,opt,name=driver_id,json=driverId,proto3" json:"driver_id,omitempty"`
	OrderId              string                             `protobuf:"bytes,2,opt,name=order_id,json=orderId,proto3" json:"order_id,omitempty"`
	DriverStatus         DriverTrackingMessage_DriverStatus `` /* 145-byte string literal not displayed */
	CustomStatus         *_struct.Value                     `protobuf:"bytes,4,opt,name=custom_status,json=customStatus,proto3" json:"custom_status,omitempty"`
	Location             *Location                          `protobuf:"bytes,5,opt,name=location,proto3" json:"location,omitempty"`
	Heading              float32                            `protobuf:"fixed32,6,opt,name=heading,proto3" json:"heading,omitempty"`
	Velocity             float32                            `protobuf:"fixed32,7,opt,name=velocity,proto3" json:"velocity,omitempty"`
	Road                 string                             `protobuf:"bytes,8,opt,name=road,proto3" json:"road,omitempty"`
	Metadata             *_struct.Value                     `protobuf:"bytes,9,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*DriverTrackingMessage) Descriptor 

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

func (*DriverTrackingMessage) GetCustomStatus 

func (m *DriverTrackingMessage) GetCustomStatus() *_struct.Value

func (*DriverTrackingMessage) GetDriverId 

func (m *DriverTrackingMessage) GetDriverId() string

func (*DriverTrackingMessage) GetDriverStatus 

func (m *DriverTrackingMessage) GetDriverStatus() DriverTrackingMessage_DriverStatus

func (*DriverTrackingMessage) GetHeading 

func (m *DriverTrackingMessage) GetHeading() float32

func (*DriverTrackingMessage) GetLocation 

func (m *DriverTrackingMessage) GetLocation() *Location

func (*DriverTrackingMessage) GetMetadata 

func (m *DriverTrackingMessage) GetMetadata() *_struct.Value

func (*DriverTrackingMessage) GetOrderId 

func (m *DriverTrackingMessage) GetOrderId() string

func (*DriverTrackingMessage) GetRoad 

func (m *DriverTrackingMessage) GetRoad() string

func (*DriverTrackingMessage) GetVelocity 

func (m *DriverTrackingMessage) GetVelocity() float32

func (*DriverTrackingMessage) ProtoMessage 

func (*DriverTrackingMessage) ProtoMessage()

func (*DriverTrackingMessage) Reset 

func (m *DriverTrackingMessage) Reset()

func (*DriverTrackingMessage) String 

func (m *DriverTrackingMessage) String() string

func (*DriverTrackingMessage) XXX_DiscardUnknown 

func (m *DriverTrackingMessage) XXX_DiscardUnknown()

func (*DriverTrackingMessage) XXX_Marshal 

func (m *DriverTrackingMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DriverTrackingMessage) XXX_Merge 

func (m *DriverTrackingMessage) XXX_Merge(src proto.Message)

func (*DriverTrackingMessage) XXX_Size 

func (m *DriverTrackingMessage) XXX_Size() int

func (*DriverTrackingMessage) XXX_Unmarshal 

func (m *DriverTrackingMessage) XXX_Unmarshal(b []byte) error

type DriverTrackingMessage_DriverStatus 

type DriverTrackingMessage_DriverStatus int32
const (
	DriverTrackingMessage_CUSTOM                 DriverTrackingMessage_DriverStatus = 0
	DriverTrackingMessage_UNAVAILABLE            DriverTrackingMessage_DriverStatus = 1
	DriverTrackingMessage_WAITING_FOR_ASSIGNMENT DriverTrackingMessage_DriverStatus = 2
	DriverTrackingMessage_EN_ROUTE_TO_PICKUP     DriverTrackingMessage_DriverStatus = 3
	DriverTrackingMessage_EN_ROUTE_TO_DELIVER    DriverTrackingMessage_DriverStatus = 4
)

func (DriverTrackingMessage_DriverStatus) EnumDescriptor 

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

func (DriverTrackingMessage_DriverStatus) String 

func (x DriverTrackingMessage_DriverStatus) String() string

type DriverTrackingServer 

type DriverTrackingServer interface {
	// Send a stream of driver tracking messages
	Publish(DriverTracking_PublishServer) error
	// Subscribe to driver tracking messages on a channel
	Subscribe(*Subscription, DriverTracking_SubscribeServer) error
}

DriverTrackingServer is the server API for DriverTracking service.

type DriverTracking_PublishClient 

type DriverTracking_PublishClient interface {
	Send(*DriverTrackingEnvelope) error
	Recv() (*PublishResponse, error)
	grpc.ClientStream
}

type DriverTracking_PublishServer 

type DriverTracking_PublishServer interface {
	Send(*PublishResponse) error
	Recv() (*DriverTrackingEnvelope, error)
	grpc.ServerStream
}

type DriverTracking_SubscribeClient 

type DriverTracking_SubscribeClient interface {
	Recv() (*DriverTrackingEnvelope, error)
	grpc.ClientStream
}

type DriverTracking_SubscribeServer 

type DriverTracking_SubscribeServer interface {
	Send(*DriverTrackingEnvelope) error
	grpc.ServerStream
}

type Location 

type Location struct {
	Latitude             float32  `protobuf:"fixed32,1,opt,name=latitude,proto3" json:"latitude,omitempty"`
	Longitude            float32  `protobuf:"fixed32,2,opt,name=longitude,proto3" json:"longitude,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Location) Descriptor 

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

func (*Location) GetLatitude 

func (m *Location) GetLatitude() float32

func (*Location) GetLongitude 

func (m *Location) GetLongitude() float32

func (*Location) ProtoMessage 

func (*Location) ProtoMessage()

func (*Location) Reset 

func (m *Location) Reset()

func (*Location) String 

func (m *Location) String() string

func (*Location) XXX_DiscardUnknown 

func (m *Location) XXX_DiscardUnknown()

func (*Location) XXX_Marshal 

func (m *Location) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Location) XXX_Merge 

func (m *Location) XXX_Merge(src proto.Message)

func (*Location) XXX_Size 

func (m *Location) XXX_Size() int

func (*Location) XXX_Unmarshal 

func (m *Location) XXX_Unmarshal(b []byte) error

type LocationTrackingClient 

type LocationTrackingClient interface {
	// Send a stream of location tracking messages
	Publish(ctx context.Context, opts ...grpc.CallOption) (LocationTracking_PublishClient, error)
	// Subscribe to location tracking messages on a channel
	Subscribe(ctx context.Context, in *Subscription, opts ...grpc.CallOption) (LocationTracking_SubscribeClient, error)
}

LocationTrackingClient is the client API for LocationTracking service.

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

func NewLocationTrackingClient 

func NewLocationTrackingClient(cc *grpc.ClientConn) LocationTrackingClient

type LocationTrackingEnvelope 

type LocationTrackingEnvelope struct {
	Channel              string                   `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	Data                 *LocationTrackingMessage `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*LocationTrackingEnvelope) Descriptor 

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

func (*LocationTrackingEnvelope) GetChannel 

func (m *LocationTrackingEnvelope) GetChannel() string

func (*LocationTrackingEnvelope) GetData 

func (m *LocationTrackingEnvelope) GetData() *LocationTrackingMessage

func (*LocationTrackingEnvelope) ProtoMessage 

func (*LocationTrackingEnvelope) ProtoMessage()

func (*LocationTrackingEnvelope) Reset 

func (m *LocationTrackingEnvelope) Reset()

func (*LocationTrackingEnvelope) String 

func (m *LocationTrackingEnvelope) String() string

func (*LocationTrackingEnvelope) XXX_DiscardUnknown 

func (m *LocationTrackingEnvelope) XXX_DiscardUnknown()

func (*LocationTrackingEnvelope) XXX_Marshal 

func (m *LocationTrackingEnvelope) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LocationTrackingEnvelope) XXX_Merge 

func (m *LocationTrackingEnvelope) XXX_Merge(src proto.Message)

func (*LocationTrackingEnvelope) XXX_Size 

func (m *LocationTrackingEnvelope) XXX_Size() int

func (*LocationTrackingEnvelope) XXX_Unmarshal 

func (m *LocationTrackingEnvelope) XXX_Unmarshal(b []byte) error

type LocationTrackingMessage 

type LocationTrackingMessage struct {
	TrackingId           string                                 `protobuf:"bytes,1,opt,name=tracking_id,json=trackingId,proto3" json:"tracking_id,omitempty"`
	TrackingStatus       LocationTrackingMessage_TrackingStatus `` /* 155-byte string literal not displayed */
	CustomStatus         *_struct.Value                         `protobuf:"bytes,3,opt,name=custom_status,json=customStatus,proto3" json:"custom_status,omitempty"`
	Location             *Location                              `protobuf:"bytes,4,opt,name=location,proto3" json:"location,omitempty"`
	Metadata             *_struct.Value                         `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                               `json:"-"`
	XXX_unrecognized     []byte                                 `json:"-"`
	XXX_sizecache        int32                                  `json:"-"`
}

func (*LocationTrackingMessage) Descriptor 

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

func (*LocationTrackingMessage) GetCustomStatus 

func (m *LocationTrackingMessage) GetCustomStatus() *_struct.Value

func (*LocationTrackingMessage) GetLocation 

func (m *LocationTrackingMessage) GetLocation() *Location

func (*LocationTrackingMessage) GetMetadata 

func (m *LocationTrackingMessage) GetMetadata() *_struct.Value

func (*LocationTrackingMessage) GetTrackingId 

func (m *LocationTrackingMessage) GetTrackingId() string

func (*LocationTrackingMessage) GetTrackingStatus 

func (m *LocationTrackingMessage) GetTrackingStatus() LocationTrackingMessage_TrackingStatus

func (*LocationTrackingMessage) ProtoMessage 

func (*LocationTrackingMessage) ProtoMessage()

func (*LocationTrackingMessage) Reset 

func (m *LocationTrackingMessage) Reset()

func (*LocationTrackingMessage) String 

func (m *LocationTrackingMessage) String() string

func (*LocationTrackingMessage) XXX_DiscardUnknown 

func (m *LocationTrackingMessage) XXX_DiscardUnknown()

func (*LocationTrackingMessage) XXX_Marshal 

func (m *LocationTrackingMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LocationTrackingMessage) XXX_Merge 

func (m *LocationTrackingMessage) XXX_Merge(src proto.Message)

func (*LocationTrackingMessage) XXX_Size 

func (m *LocationTrackingMessage) XXX_Size() int

func (*LocationTrackingMessage) XXX_Unmarshal 

func (m *LocationTrackingMessage) XXX_Unmarshal(b []byte) error

type LocationTrackingMessage_TrackingStatus 

type LocationTrackingMessage_TrackingStatus int32
const (
	LocationTrackingMessage_CUSTOM              LocationTrackingMessage_TrackingStatus = 0
	LocationTrackingMessage_READY_FOR_PICKUP    LocationTrackingMessage_TrackingStatus = 1
	LocationTrackingMessage_EN_ROUTE_TO_DELIVER LocationTrackingMessage_TrackingStatus = 2
	LocationTrackingMessage_DELIVERED           LocationTrackingMessage_TrackingStatus = 3
	LocationTrackingMessage_UNABLE_TO_DELIVER   LocationTrackingMessage_TrackingStatus = 4
	LocationTrackingMessage_RETURNING           LocationTrackingMessage_TrackingStatus = 5
	LocationTrackingMessage_CLOSED              LocationTrackingMessage_TrackingStatus = 6
	LocationTrackingMessage_EXCEPTION           LocationTrackingMessage_TrackingStatus = 7
)

func (LocationTrackingMessage_TrackingStatus) EnumDescriptor 

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

func (LocationTrackingMessage_TrackingStatus) String 

func (x LocationTrackingMessage_TrackingStatus) String() string

type LocationTrackingServer 

type LocationTrackingServer interface {
	// Send a stream of location tracking messages
	Publish(LocationTracking_PublishServer) error
	// Subscribe to location tracking messages on a channel
	Subscribe(*Subscription, LocationTracking_SubscribeServer) error
}

LocationTrackingServer is the server API for LocationTracking service.

type LocationTracking_PublishClient 

type LocationTracking_PublishClient interface {
	Send(*LocationTrackingEnvelope) error
	Recv() (*PublishResponse, error)
	grpc.ClientStream
}

type LocationTracking_PublishServer 

type LocationTracking_PublishServer interface {
	Send(*PublishResponse) error
	Recv() (*LocationTrackingEnvelope, error)
	grpc.ServerStream
}

type LocationTracking_SubscribeClient 

type LocationTracking_SubscribeClient interface {
	Recv() (*LocationTrackingEnvelope, error)
	grpc.ClientStream
}

type LocationTracking_SubscribeServer 

type LocationTracking_SubscribeServer interface {
	Send(*LocationTrackingEnvelope) error
	grpc.ServerStream
}

type Message 

type Message struct {
	Channel              string         `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	Data                 *_struct.Value `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Message) Descriptor 

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

func (*Message) GetChannel 

func (m *Message) GetChannel() string

func (*Message) GetData 

func (m *Message) GetData() *_struct.Value

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) String 

func (m *Message) String() string

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Message) XXX_Merge 

func (m *Message) XXX_Merge(src proto.Message)

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

func (m *Message) XXX_Unmarshal(b []byte) error

type PubSubClient 

type PubSubClient interface {
	// Send a message
	Publish(ctx context.Context, in *Message, opts ...grpc.CallOption) (*PublishResponse, error)
	// Send a stream of messages
	StreamingPublish(ctx context.Context, opts ...grpc.CallOption) (PubSub_StreamingPublishClient, error)
	// Subscribe to messages on a channel
	Subscribe(ctx context.Context, in *Subscription, opts ...grpc.CallOption) (PubSub_SubscribeClient, error)
}

PubSubClient is the client API for PubSub service.

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

func NewPubSubClient 

func NewPubSubClient(cc *grpc.ClientConn) PubSubClient

type PubSubServer 

type PubSubServer interface {
	// Send a message
	Publish(context.Context, *Message) (*PublishResponse, error)
	// Send a stream of messages
	StreamingPublish(PubSub_StreamingPublishServer) error
	// Subscribe to messages on a channel
	Subscribe(*Subscription, PubSub_SubscribeServer) error
}

PubSubServer is the server API for PubSub service.

type PubSub_StreamingPublishClient 

type PubSub_StreamingPublishClient interface {
	Send(*Message) error
	Recv() (*PublishResponse, error)
	grpc.ClientStream
}

type PubSub_StreamingPublishServer 

type PubSub_StreamingPublishServer interface {
	Send(*PublishResponse) error
	Recv() (*Message, error)
	grpc.ServerStream
}

type PubSub_SubscribeClient 

type PubSub_SubscribeClient interface {
	Recv() (*Message, error)
	grpc.ClientStream
}

type PubSub_SubscribeServer 

type PubSub_SubscribeServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type PublishResponse 

type PublishResponse struct {
	Message              string                 `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Timetoken            *Timetoken             `protobuf:"bytes,2,opt,name=timetoken,proto3" json:"timetoken,omitempty"`
	Status               PublishResponse_Status `protobuf:"varint,3,opt,name=status,proto3,enum=pubnub.PublishResponse_Status" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*PublishResponse) Descriptor 

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

func (*PublishResponse) GetMessage 

func (m *PublishResponse) GetMessage() string

func (*PublishResponse) GetStatus 

func (m *PublishResponse) GetStatus() PublishResponse_Status

func (*PublishResponse) GetTimetoken 

func (m *PublishResponse) GetTimetoken() *Timetoken

func (*PublishResponse) ProtoMessage 

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) Reset 

func (m *PublishResponse) Reset()

func (*PublishResponse) String 

func (m *PublishResponse) String() string

func (*PublishResponse) XXX_DiscardUnknown 

func (m *PublishResponse) XXX_DiscardUnknown()

func (*PublishResponse) XXX_Marshal 

func (m *PublishResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PublishResponse) XXX_Merge 

func (m *PublishResponse) XXX_Merge(src proto.Message)

func (*PublishResponse) XXX_Size 

func (m *PublishResponse) XXX_Size() int

func (*PublishResponse) XXX_Unmarshal 

func (m *PublishResponse) XXX_Unmarshal(b []byte) error

type PublishResponse_Status 

type PublishResponse_Status int32
const (
	PublishResponse_SUCCESS PublishResponse_Status = 0
	PublishResponse_ERROR   PublishResponse_Status = 1
)

func (PublishResponse_Status) EnumDescriptor 

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

func (PublishResponse_Status) String 

func (x PublishResponse_Status) String() string

type Subscription 

type Subscription struct {
	Channel              string   `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Subscription) Descriptor 

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

func (*Subscription) GetChannel 

func (m *Subscription) GetChannel() string

func (*Subscription) ProtoMessage 

func (*Subscription) ProtoMessage()

func (*Subscription) Reset 

func (m *Subscription) Reset()

func (*Subscription) String 

func (m *Subscription) String() string

func (*Subscription) XXX_DiscardUnknown 

func (m *Subscription) XXX_DiscardUnknown()

func (*Subscription) XXX_Marshal 

func (m *Subscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Subscription) XXX_Merge 

func (m *Subscription) XXX_Merge(src proto.Message)

func (*Subscription) XXX_Size 

func (m *Subscription) XXX_Size() int

func (*Subscription) XXX_Unmarshal 

func (m *Subscription) XXX_Unmarshal(b []byte) error

type Timetoken 

type Timetoken struct {
	T                    uint64   `protobuf:"varint,1,opt,name=t,proto3" json:"t,omitempty"`
	R                    uint32   `protobuf:"varint,2,opt,name=r,proto3" json:"r,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Timetoken) Descriptor 

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

func (*Timetoken) GetR 

func (m *Timetoken) GetR() uint32

func (*Timetoken) GetT 

func (m *Timetoken) GetT() uint64

func (*Timetoken) ProtoMessage 

func (*Timetoken) ProtoMessage()

func (*Timetoken) Reset 

func (m *Timetoken) Reset()

func (*Timetoken) String 

func (m *Timetoken) String() string

func (*Timetoken) XXX_DiscardUnknown 

func (m *Timetoken) XXX_DiscardUnknown()

func (*Timetoken) XXX_Marshal 

func (m *Timetoken) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Timetoken) XXX_Merge 

func (m *Timetoken) XXX_Merge(src proto.Message)

func (*Timetoken) XXX_Size 

func (m *Timetoken) XXX_Size() int

func (*Timetoken) XXX_Unmarshal 

func (m *Timetoken) XXX_Unmarshal(b []byte) error

type UnimplementedDriverTrackingServer 

type UnimplementedDriverTrackingServer struct {
}

UnimplementedDriverTrackingServer can be embedded to have forward compatible implementations.

func (*UnimplementedDriverTrackingServer) Publish 

func (*UnimplementedDriverTrackingServer) Publish(srv DriverTracking_PublishServer) error

func (*UnimplementedDriverTrackingServer) Subscribe 

func (*UnimplementedDriverTrackingServer) Subscribe(req *Subscription, srv DriverTracking_SubscribeServer) error

type UnimplementedLocationTrackingServer 

type UnimplementedLocationTrackingServer struct {
}

UnimplementedLocationTrackingServer can be embedded to have forward compatible implementations.

func (*UnimplementedLocationTrackingServer) Publish 

func (*UnimplementedLocationTrackingServer) Publish(srv LocationTracking_PublishServer) error

func (*UnimplementedLocationTrackingServer) Subscribe 

func (*UnimplementedLocationTrackingServer) Subscribe(req *Subscription, srv LocationTracking_SubscribeServer) error

type UnimplementedPubSubServer 

type UnimplementedPubSubServer struct {
}

UnimplementedPubSubServer can be embedded to have forward compatible implementations.

func (*UnimplementedPubSubServer) Publish 

func (*UnimplementedPubSubServer) Publish(ctx context.Context, req *Message) (*PublishResponse, error)

func (*UnimplementedPubSubServer) StreamingPublish 

func (*UnimplementedPubSubServer) StreamingPublish(srv PubSub_StreamingPublishServer) error

func (*UnimplementedPubSubServer) Subscribe 

func (*UnimplementedPubSubServer) Subscribe(req *Subscription, srv PubSub_SubscribeServer) 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.