shadowpb

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Nov 5, 2020 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_pkg_shadow_shadowpb_shadow_proto protoreflect.FileDescriptor

Functions

func RegisterShadowsServer

func RegisterShadowsServer(s *grpc.Server, srv ShadowsServer)

Types

type GetRequest

type GetRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetId

func (x *GetRequest) GetId() string

func (*GetRequest) ProtoMessage

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect added in v0.1.5

func (x *GetRequest) ProtoReflect() protoreflect.Message

func (*GetRequest) Reset

func (x *GetRequest) Reset()

func (*GetRequest) String

func (x *GetRequest) String() string

type GetResponse

type GetResponse struct {
	Shadow *Shadow `protobuf:"bytes,1,opt,name=shadow,proto3" json:"shadow,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetShadow

func (x *GetResponse) GetShadow() *Shadow

func (*GetResponse) ProtoMessage

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect added in v0.1.5

func (x *GetResponse) ProtoReflect() protoreflect.Message

func (*GetResponse) Reset

func (x *GetResponse) Reset()

func (*GetResponse) String

func (x *GetResponse) String() string

type PatchDesiredStateRequest

type PatchDesiredStateRequest struct {
	Id   string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Data *_struct.Value `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PatchDesiredStateRequest) Descriptor deprecated

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

Deprecated: Use PatchDesiredStateRequest.ProtoReflect.Descriptor instead.

func (*PatchDesiredStateRequest) GetData

func (x *PatchDesiredStateRequest) GetData() *_struct.Value

func (*PatchDesiredStateRequest) GetId

func (x *PatchDesiredStateRequest) GetId() string

func (*PatchDesiredStateRequest) ProtoMessage

func (*PatchDesiredStateRequest) ProtoMessage()

func (*PatchDesiredStateRequest) ProtoReflect added in v0.1.5

func (x *PatchDesiredStateRequest) ProtoReflect() protoreflect.Message

func (*PatchDesiredStateRequest) Reset

func (x *PatchDesiredStateRequest) Reset()

func (*PatchDesiredStateRequest) String

func (x *PatchDesiredStateRequest) String() string

type PatchDesiredStateResponse

type PatchDesiredStateResponse struct {
	// contains filtered or unexported fields
}

func (*PatchDesiredStateResponse) Descriptor deprecated

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

Deprecated: Use PatchDesiredStateResponse.ProtoReflect.Descriptor instead.

func (*PatchDesiredStateResponse) ProtoMessage

func (*PatchDesiredStateResponse) ProtoMessage()

func (*PatchDesiredStateResponse) ProtoReflect added in v0.1.5

func (*PatchDesiredStateResponse) Reset

func (x *PatchDesiredStateResponse) Reset()

func (*PatchDesiredStateResponse) String

func (x *PatchDesiredStateResponse) String() string

type Shadow

type Shadow struct {
	Config   *VersionedValue `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	Reported *VersionedValue `protobuf:"bytes,3,opt,name=reported,proto3" json:"reported,omitempty"`
	Desired  *VersionedValue `protobuf:"bytes,4,opt,name=desired,proto3" json:"desired,omitempty"`
	// contains filtered or unexported fields
}

func (*Shadow) Descriptor deprecated

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

Deprecated: Use Shadow.ProtoReflect.Descriptor instead.

func (*Shadow) GetConfig

func (x *Shadow) GetConfig() *VersionedValue

func (*Shadow) GetDesired

func (x *Shadow) GetDesired() *VersionedValue

func (*Shadow) GetReported

func (x *Shadow) GetReported() *VersionedValue

func (*Shadow) ProtoMessage

func (*Shadow) ProtoMessage()

func (*Shadow) ProtoReflect added in v0.1.5

func (x *Shadow) ProtoReflect() protoreflect.Message

func (*Shadow) Reset

func (x *Shadow) Reset()

func (*Shadow) String

func (x *Shadow) String() string

type ShadowsClient

type ShadowsClient interface {
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	PatchDesiredState(ctx context.Context, in *PatchDesiredStateRequest, opts ...grpc.CallOption) (*PatchDesiredStateResponse, error)
	StreamReportedStateChanges(ctx context.Context, in *StreamReportedStateChangesRequest, opts ...grpc.CallOption) (Shadows_StreamReportedStateChangesClient, error)
}

ShadowsClient is the client API for Shadows service.

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

func NewShadowsClient

func NewShadowsClient(cc grpc.ClientConnInterface) ShadowsClient

type ShadowsServer

ShadowsServer is the server API for Shadows service.

type Shadows_StreamReportedStateChangesClient

type Shadows_StreamReportedStateChangesClient interface {
	Recv() (*StreamReportedStateChangesResponse, error)
	grpc.ClientStream
}

type Shadows_StreamReportedStateChangesServer

type Shadows_StreamReportedStateChangesServer interface {
	Send(*StreamReportedStateChangesResponse) error
	grpc.ServerStream
}

type StreamReportedStateChangesRequest

type StreamReportedStateChangesRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	OnlyDelta bool   `protobuf:"varint,2,opt,name=only_delta,json=onlyDelta,proto3" json:"only_delta,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamReportedStateChangesRequest) Descriptor deprecated

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

Deprecated: Use StreamReportedStateChangesRequest.ProtoReflect.Descriptor instead.

func (*StreamReportedStateChangesRequest) GetId

func (*StreamReportedStateChangesRequest) GetOnlyDelta added in v0.1.4

func (x *StreamReportedStateChangesRequest) GetOnlyDelta() bool

func (*StreamReportedStateChangesRequest) ProtoMessage

func (*StreamReportedStateChangesRequest) ProtoMessage()

func (*StreamReportedStateChangesRequest) ProtoReflect added in v0.1.5

func (*StreamReportedStateChangesRequest) Reset

func (*StreamReportedStateChangesRequest) String

type StreamReportedStateChangesResponse

type StreamReportedStateChangesResponse struct {
	ReportedState *VersionedValue `protobuf:"bytes,2,opt,name=reportedState,proto3" json:"reportedState,omitempty"`
	DesiredState  *VersionedValue `protobuf:"bytes,3,opt,name=desiredState,proto3" json:"desiredState,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamReportedStateChangesResponse) Descriptor deprecated

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

Deprecated: Use StreamReportedStateChangesResponse.ProtoReflect.Descriptor instead.

func (*StreamReportedStateChangesResponse) GetDesiredState added in v0.1.4

func (x *StreamReportedStateChangesResponse) GetDesiredState() *VersionedValue

func (*StreamReportedStateChangesResponse) GetReportedState added in v0.1.4

func (x *StreamReportedStateChangesResponse) GetReportedState() *VersionedValue

func (*StreamReportedStateChangesResponse) ProtoMessage

func (*StreamReportedStateChangesResponse) ProtoMessage()

func (*StreamReportedStateChangesResponse) ProtoReflect added in v0.1.5

func (*StreamReportedStateChangesResponse) Reset

func (*StreamReportedStateChangesResponse) String

type UnimplementedShadowsServer added in v0.1.5

type UnimplementedShadowsServer struct {
}

UnimplementedShadowsServer can be embedded to have forward compatible implementations.

func (*UnimplementedShadowsServer) Get added in v0.1.5

func (*UnimplementedShadowsServer) PatchDesiredState added in v0.1.5

func (*UnimplementedShadowsServer) StreamReportedStateChanges added in v0.1.5

type VersionedValue

type VersionedValue struct {
	Version   uint64               `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Data      *_struct.Value       `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionedValue) Descriptor deprecated

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

Deprecated: Use VersionedValue.ProtoReflect.Descriptor instead.

func (*VersionedValue) GetData

func (x *VersionedValue) GetData() *_struct.Value

func (*VersionedValue) GetTimestamp

func (x *VersionedValue) GetTimestamp() *timestamp.Timestamp

func (*VersionedValue) GetVersion

func (x *VersionedValue) GetVersion() uint64

func (*VersionedValue) ProtoMessage

func (*VersionedValue) ProtoMessage()

func (*VersionedValue) ProtoReflect added in v0.1.5

func (x *VersionedValue) ProtoReflect() protoreflect.Message

func (*VersionedValue) Reset

func (x *VersionedValue) Reset()

func (*VersionedValue) String

func (x *VersionedValue) String() string

Jump to

Keyboard shortcuts

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