espressopb

package
v0.2.5 Latest Latest
Warning

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

Go to latest
Published: Mar 27, 2021 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterEspressoServer

func RegisterEspressoServer(s *grpc.Server, srv EspressoServer)

Types

type Configuration

type Configuration struct {
	Temperature          float32              `protobuf:"fixed32,1,opt,name=temperature,proto3" json:"temperature,omitempty"`
	P                    float32              `protobuf:"fixed32,2,opt,name=p,proto3" json:"p,omitempty"`
	I                    float32              `protobuf:"fixed32,3,opt,name=i,proto3" json:"i,omitempty"`
	D                    float32              `protobuf:"fixed32,4,opt,name=d,proto3" json:"d,omitempty"`
	SetAt                *timestamp.Timestamp `protobuf:"bytes,5,opt,name=set_at,json=setAt,proto3" json:"set_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Configuration) Descriptor

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

func (*Configuration) GetD

func (m *Configuration) GetD() float32

func (*Configuration) GetI

func (m *Configuration) GetI() float32

func (*Configuration) GetP

func (m *Configuration) GetP() float32

func (*Configuration) GetSetAt

func (m *Configuration) GetSetAt() *timestamp.Timestamp

func (*Configuration) GetTemperature

func (m *Configuration) GetTemperature() float32

func (*Configuration) ProtoMessage

func (*Configuration) ProtoMessage()

func (*Configuration) Reset

func (m *Configuration) Reset()

func (*Configuration) String

func (m *Configuration) String() string

func (*Configuration) XXX_DiscardUnknown

func (m *Configuration) XXX_DiscardUnknown()

func (*Configuration) XXX_Marshal

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

func (*Configuration) XXX_Merge

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

func (*Configuration) XXX_Size

func (m *Configuration) XXX_Size() int

func (*Configuration) XXX_Unmarshal

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

type EspressoClient

type EspressoClient interface {
	BoilerTemperature(ctx context.Context, in *TemperatureStreamRequest, opts ...grpc.CallOption) (Espresso_BoilerTemperatureClient, error)
	GetConfiguration(ctx context.Context, in *GetConfigurationRequest, opts ...grpc.CallOption) (*Configuration, error)
	SetConfiguration(ctx context.Context, in *Configuration, opts ...grpc.CallOption) (*Configuration, error)
}

EspressoClient is the client API for Espresso service.

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

func NewEspressoClient

func NewEspressoClient(cc grpc.ClientConnInterface) EspressoClient

type EspressoServer

type EspressoServer interface {
	BoilerTemperature(*TemperatureStreamRequest, Espresso_BoilerTemperatureServer) error
	GetConfiguration(context.Context, *GetConfigurationRequest) (*Configuration, error)
	SetConfiguration(context.Context, *Configuration) (*Configuration, error)
}

EspressoServer is the server API for Espresso service.

type Espresso_BoilerTemperatureClient

type Espresso_BoilerTemperatureClient interface {
	Recv() (*TemperatureStreamResponse, error)
	grpc.ClientStream
}

type Espresso_BoilerTemperatureServer

type Espresso_BoilerTemperatureServer interface {
	Send(*TemperatureStreamResponse) error
	grpc.ServerStream
}

type GetConfigurationRequest

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

func (*GetConfigurationRequest) Descriptor

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

func (*GetConfigurationRequest) ProtoMessage

func (*GetConfigurationRequest) ProtoMessage()

func (*GetConfigurationRequest) Reset

func (m *GetConfigurationRequest) Reset()

func (*GetConfigurationRequest) String

func (m *GetConfigurationRequest) String() string

func (*GetConfigurationRequest) XXX_DiscardUnknown

func (m *GetConfigurationRequest) XXX_DiscardUnknown()

func (*GetConfigurationRequest) XXX_Marshal

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

func (*GetConfigurationRequest) XXX_Merge

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

func (*GetConfigurationRequest) XXX_Size

func (m *GetConfigurationRequest) XXX_Size() int

func (*GetConfigurationRequest) XXX_Unmarshal

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

type TemperatureHistory

type TemperatureHistory struct {
	Samples              []*TemperatureSample `protobuf:"bytes,1,rep,name=samples,proto3" json:"samples,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*TemperatureHistory) Descriptor

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

func (*TemperatureHistory) GetSamples

func (m *TemperatureHistory) GetSamples() []*TemperatureSample

func (*TemperatureHistory) ProtoMessage

func (*TemperatureHistory) ProtoMessage()

func (*TemperatureHistory) Reset

func (m *TemperatureHistory) Reset()

func (*TemperatureHistory) String

func (m *TemperatureHistory) String() string

func (*TemperatureHistory) XXX_DiscardUnknown

func (m *TemperatureHistory) XXX_DiscardUnknown()

func (*TemperatureHistory) XXX_Marshal

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

func (*TemperatureHistory) XXX_Merge

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

func (*TemperatureHistory) XXX_Size

func (m *TemperatureHistory) XXX_Size() int

func (*TemperatureHistory) XXX_Unmarshal

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

type TemperatureSample

type TemperatureSample struct {
	Value                float32              `protobuf:"fixed32,1,opt,name=value,proto3" json:"value,omitempty"`
	ObservedAt           *timestamp.Timestamp `protobuf:"bytes,2,opt,name=observed_at,json=observedAt,proto3" json:"observed_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*TemperatureSample) Descriptor

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

func (*TemperatureSample) GetObservedAt

func (m *TemperatureSample) GetObservedAt() *timestamp.Timestamp

func (*TemperatureSample) GetValue

func (m *TemperatureSample) GetValue() float32

func (*TemperatureSample) ProtoMessage

func (*TemperatureSample) ProtoMessage()

func (*TemperatureSample) Reset

func (m *TemperatureSample) Reset()

func (*TemperatureSample) String

func (m *TemperatureSample) String() string

func (*TemperatureSample) XXX_DiscardUnknown

func (m *TemperatureSample) XXX_DiscardUnknown()

func (*TemperatureSample) XXX_Marshal

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

func (*TemperatureSample) XXX_Merge

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

func (*TemperatureSample) XXX_Size

func (m *TemperatureSample) XXX_Size() int

func (*TemperatureSample) XXX_Unmarshal

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

type TemperatureStreamRequest

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

func (*TemperatureStreamRequest) Descriptor

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

func (*TemperatureStreamRequest) ProtoMessage

func (*TemperatureStreamRequest) ProtoMessage()

func (*TemperatureStreamRequest) Reset

func (m *TemperatureStreamRequest) Reset()

func (*TemperatureStreamRequest) String

func (m *TemperatureStreamRequest) String() string

func (*TemperatureStreamRequest) XXX_DiscardUnknown

func (m *TemperatureStreamRequest) XXX_DiscardUnknown()

func (*TemperatureStreamRequest) XXX_Marshal

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

func (*TemperatureStreamRequest) XXX_Merge

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

func (*TemperatureStreamRequest) XXX_Size

func (m *TemperatureStreamRequest) XXX_Size() int

func (*TemperatureStreamRequest) XXX_Unmarshal

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

type TemperatureStreamResponse

type TemperatureStreamResponse struct {
	// Types that are valid to be assigned to Data:
	//	*TemperatureStreamResponse_History
	//	*TemperatureStreamResponse_Sample
	Data                 isTemperatureStreamResponse_Data `protobuf_oneof:"data"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*TemperatureStreamResponse) Descriptor

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

func (*TemperatureStreamResponse) GetData

func (m *TemperatureStreamResponse) GetData() isTemperatureStreamResponse_Data

func (*TemperatureStreamResponse) GetHistory

func (*TemperatureStreamResponse) GetSample

func (*TemperatureStreamResponse) ProtoMessage

func (*TemperatureStreamResponse) ProtoMessage()

func (*TemperatureStreamResponse) Reset

func (m *TemperatureStreamResponse) Reset()

func (*TemperatureStreamResponse) String

func (m *TemperatureStreamResponse) String() string

func (*TemperatureStreamResponse) XXX_DiscardUnknown

func (m *TemperatureStreamResponse) XXX_DiscardUnknown()

func (*TemperatureStreamResponse) XXX_Marshal

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

func (*TemperatureStreamResponse) XXX_Merge

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

func (*TemperatureStreamResponse) XXX_OneofWrappers

func (*TemperatureStreamResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TemperatureStreamResponse) XXX_Size

func (m *TemperatureStreamResponse) XXX_Size() int

func (*TemperatureStreamResponse) XXX_Unmarshal

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

type TemperatureStreamResponse_History

type TemperatureStreamResponse_History struct {
	History *TemperatureHistory `protobuf:"bytes,1,opt,name=history,proto3,oneof"`
}

type TemperatureStreamResponse_Sample

type TemperatureStreamResponse_Sample struct {
	Sample *TemperatureSample `protobuf:"bytes,2,opt,name=sample,proto3,oneof"`
}

type UnimplementedEspressoServer

type UnimplementedEspressoServer struct {
}

UnimplementedEspressoServer can be embedded to have forward compatible implementations.

func (*UnimplementedEspressoServer) BoilerTemperature

func (*UnimplementedEspressoServer) GetConfiguration

func (*UnimplementedEspressoServer) SetConfiguration

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL