stream

package
v0.0.0-...-8bc70f8 Latest Latest
Warning

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

 Go to latest Published: May 8, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterApiCallerScaleServer 

func RegisterApiCallerScaleServer(s *grpc.Server, srv ApiCallerScaleServer)

Types

type ApiCallerScaleClient 

type ApiCallerScaleClient interface {
	ScalesMessageOutChannel(ctx context.Context, opts ...grpc.CallOption) (ApiCallerScale_ScalesMessageOutChannelClient, error)
	SetTare(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ResponseSetScale, error)
	SetTareValue(ctx context.Context, in *RequestTareValue, opts ...grpc.CallOption) (*ResponseSetScale, error)
	SetZero(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ResponseSetScale, error)
	GetInstantWeight(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ResponseInstantWeight, error)
	GetState(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ResponseScale, error)
}

ApiCallerScaleClient is the client API for ApiCallerScale service.

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

func NewApiCallerScaleClient 

func NewApiCallerScaleClient(cc grpc.ClientConnInterface) ApiCallerScaleClient

type ApiCallerScaleServer 

type ApiCallerScaleServer interface {
	ScalesMessageOutChannel(ApiCallerScale_ScalesMessageOutChannelServer) error
	SetTare(context.Context, *Empty) (*ResponseSetScale, error)
	SetTareValue(context.Context, *RequestTareValue) (*ResponseSetScale, error)
	SetZero(context.Context, *Empty) (*ResponseSetScale, error)
	GetInstantWeight(context.Context, *Empty) (*ResponseInstantWeight, error)
	GetState(context.Context, *Empty) (*ResponseScale, error)
}

ApiCallerScaleServer is the server API for ApiCallerScale service.

type ApiCallerScale_ScalesMessageOutChannelClient 

type ApiCallerScale_ScalesMessageOutChannelClient interface {
	Send(*RequestScale) error
	Recv() (*ResponseScale, error)
	grpc.ClientStream
}

type ApiCallerScale_ScalesMessageOutChannelServer 

type ApiCallerScale_ScalesMessageOutChannelServer interface {
	Send(*ResponseScale) error
	Recv() (*RequestScale, error)
	grpc.ServerStream
}

type Empty 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

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

func (*Empty) XXX_Merge 

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

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

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

type RequestScale 

type RequestScale struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Type                 string   `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Subtype              string   `protobuf:"bytes,3,opt,name=subtype,proto3" json:"subtype,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RequestScale) Descriptor 

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

func (*RequestScale) GetMessage 

func (m *RequestScale) GetMessage() string

func (*RequestScale) GetSubtype 

func (m *RequestScale) GetSubtype() string

func (*RequestScale) GetType 

func (m *RequestScale) GetType() string

func (*RequestScale) ProtoMessage 

func (*RequestScale) ProtoMessage()

func (*RequestScale) Reset 

func (m *RequestScale) Reset()

func (*RequestScale) String 

func (m *RequestScale) String() string

func (*RequestScale) XXX_DiscardUnknown 

func (m *RequestScale) XXX_DiscardUnknown()

func (*RequestScale) XXX_Marshal 

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

func (*RequestScale) XXX_Merge 

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

func (*RequestScale) XXX_Size 

func (m *RequestScale) XXX_Size() int

func (*RequestScale) XXX_Unmarshal 

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

type RequestTareValue 

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

func (*RequestTareValue) Descriptor 

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

func (*RequestTareValue) GetMessage 

func (m *RequestTareValue) GetMessage() string

func (*RequestTareValue) ProtoMessage 

func (*RequestTareValue) ProtoMessage()

func (*RequestTareValue) Reset 

func (m *RequestTareValue) Reset()

func (*RequestTareValue) String 

func (m *RequestTareValue) String() string

func (*RequestTareValue) XXX_DiscardUnknown 

func (m *RequestTareValue) XXX_DiscardUnknown()

func (*RequestTareValue) XXX_Marshal 

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

func (*RequestTareValue) XXX_Merge 

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

func (*RequestTareValue) XXX_Size 

func (m *RequestTareValue) XXX_Size() int

func (*RequestTareValue) XXX_Unmarshal 

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

type ResponseInstantWeight 

type ResponseInstantWeight struct {
	Error                string   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResponseInstantWeight) Descriptor 

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

func (*ResponseInstantWeight) GetError 

func (m *ResponseInstantWeight) GetError() string

func (*ResponseInstantWeight) GetMessage 

func (m *ResponseInstantWeight) GetMessage() string

func (*ResponseInstantWeight) ProtoMessage 

func (*ResponseInstantWeight) ProtoMessage()

func (*ResponseInstantWeight) Reset 

func (m *ResponseInstantWeight) Reset()

func (*ResponseInstantWeight) String 

func (m *ResponseInstantWeight) String() string

func (*ResponseInstantWeight) XXX_DiscardUnknown 

func (m *ResponseInstantWeight) XXX_DiscardUnknown()

func (*ResponseInstantWeight) XXX_Marshal 

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

func (*ResponseInstantWeight) XXX_Merge 

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

func (*ResponseInstantWeight) XXX_Size 

func (m *ResponseInstantWeight) XXX_Size() int

func (*ResponseInstantWeight) XXX_Unmarshal 

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

type ResponseScale 

type ResponseScale struct {
	Error                string   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Type                 string   `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Subtype              string   `protobuf:"bytes,4,opt,name=subtype,proto3" json:"subtype,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The response message

func (*ResponseScale) Descriptor 

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

func (*ResponseScale) GetError 

func (m *ResponseScale) GetError() string

func (*ResponseScale) GetMessage 

func (m *ResponseScale) GetMessage() string

func (*ResponseScale) GetSubtype 

func (m *ResponseScale) GetSubtype() string

func (*ResponseScale) GetType 

func (m *ResponseScale) GetType() string

func (*ResponseScale) ProtoMessage 

func (*ResponseScale) ProtoMessage()

func (*ResponseScale) Reset 

func (m *ResponseScale) Reset()

func (*ResponseScale) String 

func (m *ResponseScale) String() string

func (*ResponseScale) XXX_DiscardUnknown 

func (m *ResponseScale) XXX_DiscardUnknown()

func (*ResponseScale) XXX_Marshal 

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

func (*ResponseScale) XXX_Merge 

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

func (*ResponseScale) XXX_Size 

func (m *ResponseScale) XXX_Size() int

func (*ResponseScale) XXX_Unmarshal 

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

type ResponseSetScale 

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

func (*ResponseSetScale) Descriptor 

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

func (*ResponseSetScale) GetError 

func (m *ResponseSetScale) GetError() string

func (*ResponseSetScale) ProtoMessage 

func (*ResponseSetScale) ProtoMessage()

func (*ResponseSetScale) Reset 

func (m *ResponseSetScale) Reset()

func (*ResponseSetScale) String 

func (m *ResponseSetScale) String() string

func (*ResponseSetScale) XXX_DiscardUnknown 

func (m *ResponseSetScale) XXX_DiscardUnknown()

func (*ResponseSetScale) XXX_Marshal 

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

func (*ResponseSetScale) XXX_Merge 

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

func (*ResponseSetScale) XXX_Size 

func (m *ResponseSetScale) XXX_Size() int

func (*ResponseSetScale) XXX_Unmarshal 

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

type UnimplementedApiCallerScaleServer 

type UnimplementedApiCallerScaleServer struct {
}

UnimplementedApiCallerScaleServer can be embedded to have forward compatible implementations.

func (*UnimplementedApiCallerScaleServer) GetInstantWeight 

func (*UnimplementedApiCallerScaleServer) GetInstantWeight(ctx context.Context, req *Empty) (*ResponseInstantWeight, error)

func (*UnimplementedApiCallerScaleServer) GetState 

func (*UnimplementedApiCallerScaleServer) GetState(ctx context.Context, req *Empty) (*ResponseScale, error)

func (*UnimplementedApiCallerScaleServer) ScalesMessageOutChannel 

func (*UnimplementedApiCallerScaleServer) ScalesMessageOutChannel(srv ApiCallerScale_ScalesMessageOutChannelServer) error

func (*UnimplementedApiCallerScaleServer) SetTare 

func (*UnimplementedApiCallerScaleServer) SetTare(ctx context.Context, req *Empty) (*ResponseSetScale, error)

func (*UnimplementedApiCallerScaleServer) SetTareValue 

func (*UnimplementedApiCallerScaleServer) SetTareValue(ctx context.Context, req *RequestTareValue) (*ResponseSetScale, error)

func (*UnimplementedApiCallerScaleServer) SetZero 

func (*UnimplementedApiCallerScaleServer) SetZero(ctx context.Context, req *Empty) (*ResponseSetScale, 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.