edgenode

package
v0.0.0-...-aa8370d Latest Latest
Warning

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

 Go to latest Published: Jul 3, 2023 License: MIT Imports: 5 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterPubSubServer 

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

Types

type CameraInfo 

type CameraInfo struct {
	Camid                []string `protobuf:"bytes,1,rep,name=camid,proto3" json:"camid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CameraInfo) Descriptor 

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

func (*CameraInfo) GetCamid 

func (m *CameraInfo) GetCamid() []string

func (*CameraInfo) ProtoMessage 

func (*CameraInfo) ProtoMessage()

func (*CameraInfo) Reset 

func (m *CameraInfo) Reset()

func (*CameraInfo) String 

func (m *CameraInfo) String() string

func (*CameraInfo) XXX_DiscardUnknown 

func (m *CameraInfo) XXX_DiscardUnknown()

func (*CameraInfo) XXX_Marshal 

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

func (*CameraInfo) XXX_Merge 

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

func (*CameraInfo) XXX_Size 

func (m *CameraInfo) XXX_Size() int

func (*CameraInfo) XXX_Unmarshal 

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

type Id 

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

func (*Id) Descriptor 

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

func (*Id) GetId 

func (m *Id) GetId() string

func (*Id) ProtoMessage 

func (*Id) ProtoMessage()

func (*Id) Reset 

func (m *Id) Reset()

func (*Id) String 

func (m *Id) String() string

func (*Id) XXX_DiscardUnknown 

func (m *Id) XXX_DiscardUnknown()

func (*Id) XXX_Marshal 

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

func (*Id) XXX_Merge 

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

func (*Id) XXX_Size 

func (m *Id) XXX_Size() int

func (*Id) XXX_Unmarshal 

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

type Image 

type Image struct {
	Image                []byte   `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	Timestamp            string   `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Image) Descriptor 

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

func (*Image) GetImage 

func (m *Image) GetImage() []byte

func (*Image) GetTimestamp 

func (m *Image) GetTimestamp() string

func (*Image) ProtoMessage 

func (*Image) ProtoMessage()

func (*Image) Reset 

func (m *Image) Reset()

func (*Image) String 

func (m *Image) String() string

func (*Image) XXX_DiscardUnknown 

func (m *Image) XXX_DiscardUnknown()

func (*Image) XXX_Marshal 

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

func (*Image) XXX_Merge 

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

func (*Image) XXX_Size 

func (m *Image) XXX_Size() int

func (*Image) XXX_Unmarshal 

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

type ImageStreamParameters 

type ImageStreamParameters struct {
	Camid                string   `protobuf:"bytes,1,opt,name=camid,proto3" json:"camid,omitempty"`
	Latency              string   `protobuf:"bytes,2,opt,name=latency,proto3" json:"latency,omitempty"`
	Accuracy             string   `protobuf:"bytes,3,opt,name=accuracy,proto3" json:"accuracy,omitempty"`
	Start                string   `protobuf:"bytes,4,opt,name=start,proto3" json:"start,omitempty"`
	Stop                 string   `protobuf:"bytes,5,opt,name=stop,proto3" json:"stop,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ImageStreamParameters) Descriptor 

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

func (*ImageStreamParameters) GetAccuracy 

func (m *ImageStreamParameters) GetAccuracy() string

func (*ImageStreamParameters) GetCamid 

func (m *ImageStreamParameters) GetCamid() string

func (*ImageStreamParameters) GetLatency 

func (m *ImageStreamParameters) GetLatency() string

func (*ImageStreamParameters) GetStart 

func (m *ImageStreamParameters) GetStart() string

func (*ImageStreamParameters) GetStop 

func (m *ImageStreamParameters) GetStop() string

func (*ImageStreamParameters) ProtoMessage 

func (*ImageStreamParameters) ProtoMessage()

func (*ImageStreamParameters) Reset 

func (m *ImageStreamParameters) Reset()

func (*ImageStreamParameters) String 

func (m *ImageStreamParameters) String() string

func (*ImageStreamParameters) XXX_DiscardUnknown 

func (m *ImageStreamParameters) XXX_DiscardUnknown()

func (*ImageStreamParameters) XXX_Marshal 

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

func (*ImageStreamParameters) XXX_Merge 

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

func (*ImageStreamParameters) XXX_Size 

func (m *ImageStreamParameters) XXX_Size() int

func (*ImageStreamParameters) XXX_Unmarshal 

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

type LatencyMeasured 

type LatencyMeasured struct {
	CurrentLat           string   `protobuf:"bytes,1,opt,name=current_lat,json=currentLat,proto3" json:"current_lat,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LatencyMeasured) Descriptor 

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

func (*LatencyMeasured) GetCurrentLat 

func (m *LatencyMeasured) GetCurrentLat() string

func (*LatencyMeasured) ProtoMessage 

func (*LatencyMeasured) ProtoMessage()

func (*LatencyMeasured) Reset 

func (m *LatencyMeasured) Reset()

func (*LatencyMeasured) String 

func (m *LatencyMeasured) String() string

func (*LatencyMeasured) XXX_DiscardUnknown 

func (m *LatencyMeasured) XXX_DiscardUnknown()

func (*LatencyMeasured) XXX_Marshal 

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

func (*LatencyMeasured) XXX_Merge 

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

func (*LatencyMeasured) XXX_Size 

func (m *LatencyMeasured) XXX_Size() int

func (*LatencyMeasured) XXX_Unmarshal 

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

type PubSubClient 

type PubSubClient interface {
	Connect(ctx context.Context, in *Url, opts ...grpc.CallOption) (*Id, error)
	Publish(ctx context.Context, opts ...grpc.CallOption) (PubSub_PublishClient, error)
	Subscribe(ctx context.Context, in *ImageStreamParameters, opts ...grpc.CallOption) (PubSub_SubscribeClient, error)
	Unsubscribe(ctx context.Context, in *CameraInfo, opts ...grpc.CallOption) (*Status, error)
	LatencyCalc(ctx context.Context, in *LatencyMeasured, opts ...grpc.CallOption) (*Status, 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 {
	Connect(context.Context, *Url) (*Id, error)
	Publish(PubSub_PublishServer) error
	Subscribe(*ImageStreamParameters, PubSub_SubscribeServer) error
	Unsubscribe(context.Context, *CameraInfo) (*Status, error)
	LatencyCalc(context.Context, *LatencyMeasured) (*Status, error)
}

PubSubServer is the server API for PubSub service.

type PubSub_PublishClient 

type PubSub_PublishClient interface {
	Send(*Image) error
	CloseAndRecv() (*Status, error)
	grpc.ClientStream
}

type PubSub_PublishServer 

type PubSub_PublishServer interface {
	SendAndClose(*Status) error
	Recv() (*Image, error)
	grpc.ServerStream
}

type PubSub_SubscribeClient 

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

type PubSub_SubscribeServer 

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

type Status 

type Status struct {
	Status               bool     `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Status) Descriptor 

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

func (*Status) GetStatus 

func (m *Status) GetStatus() bool

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) String 

func (m *Status) String() string

func (*Status) XXX_DiscardUnknown 

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal 

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

func (*Status) XXX_Merge 

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

func (*Status) XXX_Size 

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal 

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

type Url 

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

func (*Url) Descriptor 

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

func (*Url) GetAddress 

func (m *Url) GetAddress() string

func (*Url) ProtoMessage 

func (*Url) ProtoMessage()

func (*Url) Reset 

func (m *Url) Reset()

func (*Url) String 

func (m *Url) String() string

func (*Url) XXX_DiscardUnknown 

func (m *Url) XXX_DiscardUnknown()

func (*Url) XXX_Marshal 

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

func (*Url) XXX_Merge 

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

func (*Url) XXX_Size 

func (m *Url) XXX_Size() int

func (*Url) XXX_Unmarshal 

func (m *Url) XXX_Unmarshal(b []byte) 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.