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 (x *PatchDesiredStateResponse) ProtoReflect() protoreflect.Message

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 

type ShadowsServer interface {
	Get(context.Context, *GetRequest) (*GetResponse, error)
	PatchDesiredState(context.Context, *PatchDesiredStateRequest) (*PatchDesiredStateResponse, error)
	StreamReportedStateChanges(*StreamReportedStateChangesRequest, Shadows_StreamReportedStateChangesServer) error
}

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 (x *StreamReportedStateChangesRequest) GetId() string

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 (x *StreamReportedStateChangesRequest) ProtoReflect() protoreflect.Message

func (*StreamReportedStateChangesRequest) Reset 

func (x *StreamReportedStateChangesRequest) Reset()

func (*StreamReportedStateChangesRequest) String 

func (x *StreamReportedStateChangesRequest) String() 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 (x *StreamReportedStateChangesResponse) ProtoReflect() protoreflect.Message

func (*StreamReportedStateChangesResponse) Reset 

func (x *StreamReportedStateChangesResponse) Reset()

func (*StreamReportedStateChangesResponse) String 

func (x *StreamReportedStateChangesResponse) String() 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) Get(context.Context, *GetRequest) (*GetResponse, error)

func (*UnimplementedShadowsServer) PatchDesiredState added in v0.1.5 

func (*UnimplementedShadowsServer) PatchDesiredState(context.Context, *PatchDesiredStateRequest) (*PatchDesiredStateResponse, error)

func (*UnimplementedShadowsServer) StreamReportedStateChanges added in v0.1.5 

func (*UnimplementedShadowsServer) StreamReportedStateChanges(*StreamReportedStateChangesRequest, Shadows_StreamReportedStateChangesServer) error

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

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.