controller

Documentation

Index

• func RegisterLatencyControllerServer(s *grpc.Server, srv LatencyControllerServer)
• type CustomImage
  • func (*CustomImage) Descriptor() ([]byte, []int)
  • func (m *CustomImage) GetAcheivedAcc() string
  • func (m *CustomImage) GetImage() []byte
  • func (*CustomImage) ProtoMessage()
  • func (m *CustomImage) Reset()
  • func (m *CustomImage) String() string
  • func (m *CustomImage) XXX_DiscardUnknown()
  • func (m *CustomImage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CustomImage) XXX_Merge(src proto.Message)
  • func (m *CustomImage) XXX_Size() int
  • func (m *CustomImage) XXX_Unmarshal(b []byte) error
• type LatencyControllerClient
  • func NewLatencyControllerClient(cc *grpc.ClientConn) LatencyControllerClient
• type LatencyControllerServer
• type LatencyController_ControlClient
• type LatencyController_ControlServer
• type OriginalImage
  • func (*OriginalImage) Descriptor() ([]byte, []int)
  • func (m *OriginalImage) GetCurrentLat() string
  • func (m *OriginalImage) GetImage() []byte
  • func (*OriginalImage) ProtoMessage()
  • func (m *OriginalImage) Reset()
  • func (m *OriginalImage) String() string
  • func (m *OriginalImage) XXX_DiscardUnknown()
  • func (m *OriginalImage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *OriginalImage) XXX_Merge(src proto.Message)
  • func (m *OriginalImage) XXX_Size() int
  • func (m *OriginalImage) XXX_Unmarshal(b []byte) error
• type Status
  • func (*Status) Descriptor() ([]byte, []int)
  • func (m *Status) GetStatus() bool
  • func (*Status) ProtoMessage()
  • func (m *Status) Reset()
  • func (m *Status) String() string
  • func (m *Status) XXX_DiscardUnknown()
  • func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Status) XXX_Merge(src proto.Message)
  • func (m *Status) XXX_Size() int
  • func (m *Status) XXX_Unmarshal(b []byte) error
• type Targets
  • func (*Targets) Descriptor() ([]byte, []int)
  • func (m *Targets) GetTargetAcc() string
  • func (m *Targets) GetTargetLat() string
  • func (*Targets) ProtoMessage()
  • func (m *Targets) Reset()
  • func (m *Targets) String() string
  • func (m *Targets) XXX_DiscardUnknown()
  • func (m *Targets) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Targets) XXX_Merge(src proto.Message)
  • func (m *Targets) XXX_Size() int
  • func (m *Targets) XXX_Unmarshal(b []byte) error

Functions

func RegisterLatencyControllerServer

func RegisterLatencyControllerServer(s *grpc.Server, srv LatencyControllerServer)

Types

type CustomImage

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

func (*CustomImage) Descriptor

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

func (*CustomImage) GetAcheivedAcc

func (m *CustomImage) GetAcheivedAcc() string

func (*CustomImage) GetImage

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

func (*CustomImage) ProtoMessage

func (*CustomImage) ProtoMessage()

func (*CustomImage) Reset

func (m *CustomImage) Reset()

func (*CustomImage) String

func (m *CustomImage) String() string

func (*CustomImage) XXX_DiscardUnknown

func (m *CustomImage) XXX_DiscardUnknown()

func (*CustomImage) XXX_Marshal

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

func (*CustomImage) XXX_Merge

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

func (*CustomImage) XXX_Size

func (m *CustomImage) XXX_Size() int

func (*CustomImage) XXX_Unmarshal

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

type LatencyControllerClient

type LatencyControllerClient interface {
	SetTarget(ctx context.Context, in *Targets, opts ...grpc.CallOption) (*Status, error)
	Control(ctx context.Context, opts ...grpc.CallOption) (LatencyController_ControlClient, error)
}

LatencyControllerClient is the client API for LatencyController service.

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

func NewLatencyControllerClient

func NewLatencyControllerClient(cc *grpc.ClientConn) LatencyControllerClient

type LatencyControllerServer

type LatencyControllerServer interface {
	SetTarget(context.Context, *Targets) (*Status, error)
	Control(LatencyController_ControlServer) error
}

LatencyControllerServer is the server API for LatencyController service.

type LatencyController_ControlClient

type LatencyController_ControlClient interface {
	Send(*OriginalImage) error
	Recv() (*CustomImage, error)
	grpc.ClientStream
}

type LatencyController_ControlServer

type LatencyController_ControlServer interface {
	Send(*CustomImage) error
	Recv() (*OriginalImage, error)
	grpc.ServerStream
}

type OriginalImage

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

func (*OriginalImage) Descriptor

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

func (*OriginalImage) GetCurrentLat

func (m *OriginalImage) GetCurrentLat() string

func (*OriginalImage) GetImage

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

func (*OriginalImage) ProtoMessage

func (*OriginalImage) ProtoMessage()

func (*OriginalImage) Reset

func (m *OriginalImage) Reset()

func (*OriginalImage) String

func (m *OriginalImage) String() string

func (*OriginalImage) XXX_DiscardUnknown

func (m *OriginalImage) XXX_DiscardUnknown()

func (*OriginalImage) XXX_Marshal

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

func (*OriginalImage) XXX_Merge

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

func (*OriginalImage) XXX_Size

func (m *OriginalImage) XXX_Size() int

func (*OriginalImage) XXX_Unmarshal

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

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 Targets

type Targets struct {
	TargetLat            string   `protobuf:"bytes,1,opt,name=target_lat,json=targetLat,proto3" json:"target_lat,omitempty"`
	TargetAcc            string   `protobuf:"bytes,2,opt,name=target_acc,json=targetAcc,proto3" json:"target_acc,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Targets) Descriptor

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

func (*Targets) GetTargetAcc

func (m *Targets) GetTargetAcc() string

func (*Targets) GetTargetLat

func (m *Targets) GetTargetLat() string

func (*Targets) ProtoMessage

func (*Targets) ProtoMessage()

func (*Targets) Reset

func (m *Targets) Reset()

func (*Targets) String

func (m *Targets) String() string

func (*Targets) XXX_DiscardUnknown

func (m *Targets) XXX_DiscardUnknown()

func (*Targets) XXX_Marshal

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

func (*Targets) XXX_Merge

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

func (*Targets) XXX_Size

func (m *Targets) XXX_Size() int

func (*Targets) XXX_Unmarshal

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