shadowpb

package
v0.0.0-...-c6a7f1f Latest Latest
Warning

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

 Go to latest Published: Feb 14, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_pkg_shadow_shadowpb_shadow_proto protoreflect.FileDescriptor
View Source 
var Shadows_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "infinimesh.shadow.Shadows",
	HandlerType: (*ShadowsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _Shadows_Get_Handler,
		},
		{
			MethodName: "GetForNS",
			Handler:    _Shadows_GetForNS_Handler,
		},
		{
			MethodName: "PatchDesiredState",
			Handler:    _Shadows_PatchDesiredState_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamReportedStateChanges",
			Handler:       _Shadows_StreamReportedStateChanges_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pkg/shadow/shadowpb/shadow.proto",
}

Shadows_ServiceDesc is the grpc.ServiceDesc for Shadows service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterShadowsServer 

func RegisterShadowsServer(s grpc.ServiceRegistrar, srv ShadowsServer)

Types

type GetForNSResponse 

type GetForNSResponse struct {
	Pool map[string]*Shadow `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetForNSResponse) Descriptor deprecated 

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

Deprecated: Use GetForNSResponse.ProtoReflect.Descriptor instead.

func (*GetForNSResponse) GetPool 

func (x *GetForNSResponse) GetPool() map[string]*Shadow

func (*GetForNSResponse) ProtoMessage 

func (*GetForNSResponse) ProtoMessage()

func (*GetForNSResponse) ProtoReflect 

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

func (*GetForNSResponse) Reset 

func (x *GetForNSResponse) Reset()

func (*GetForNSResponse) String 

func (x *GetForNSResponse) String() string

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 

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 

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 *structpb.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() *structpb.Value

func (*PatchDesiredStateRequest) GetId 

func (x *PatchDesiredStateRequest) GetId() string

func (*PatchDesiredStateRequest) ProtoMessage 

func (*PatchDesiredStateRequest) ProtoMessage()

func (*PatchDesiredStateRequest) ProtoReflect 

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 

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 

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)
	GetForNS(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetForNSResponse, 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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewShadowsClient 

func NewShadowsClient(cc grpc.ClientConnInterface) ShadowsClient

type ShadowsServer 

type ShadowsServer interface {
	Get(context.Context, *GetRequest) (*GetResponse, error)
	GetForNS(context.Context, *GetRequest) (*GetForNSResponse, error)
	PatchDesiredState(context.Context, *PatchDesiredStateRequest) (*PatchDesiredStateResponse, error)
	StreamReportedStateChanges(*StreamReportedStateChangesRequest, Shadows_StreamReportedStateChangesServer) error
	// contains filtered or unexported methods
}

ShadowsServer is the server API for Shadows service. All implementations must embed UnimplementedShadowsServer for forward compatibility

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 

func (x *StreamReportedStateChangesRequest) GetOnlyDelta() bool

func (*StreamReportedStateChangesRequest) ProtoMessage 

func (*StreamReportedStateChangesRequest) ProtoMessage()

func (*StreamReportedStateChangesRequest) ProtoReflect 

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 

func (x *StreamReportedStateChangesResponse) GetDesiredState() *VersionedValue

func (*StreamReportedStateChangesResponse) GetReportedState 

func (x *StreamReportedStateChangesResponse) GetReportedState() *VersionedValue

func (*StreamReportedStateChangesResponse) ProtoMessage 

func (*StreamReportedStateChangesResponse) ProtoMessage()

func (*StreamReportedStateChangesResponse) ProtoReflect 

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

func (*StreamReportedStateChangesResponse) Reset 

func (x *StreamReportedStateChangesResponse) Reset()

func (*StreamReportedStateChangesResponse) String 

func (x *StreamReportedStateChangesResponse) String() string

type UnimplementedShadowsServer 

type UnimplementedShadowsServer struct {
}

UnimplementedShadowsServer must be embedded to have forward compatible implementations.

func (UnimplementedShadowsServer) Get 

func (UnimplementedShadowsServer) Get(context.Context, *GetRequest) (*GetResponse, error)

func (UnimplementedShadowsServer) GetForNS 

func (UnimplementedShadowsServer) GetForNS(context.Context, *GetRequest) (*GetForNSResponse, error)

func (UnimplementedShadowsServer) PatchDesiredState 

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

func (UnimplementedShadowsServer) StreamReportedStateChanges 

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

type UnsafeShadowsServer 

type UnsafeShadowsServer interface {
	// contains filtered or unexported methods
}

UnsafeShadowsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ShadowsServer will result in compilation errors.

type VersionedValue 

type VersionedValue struct {
	Version   uint64                 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Data      *structpb.Value        `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Timestamp *timestamppb.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() *structpb.Value

func (*VersionedValue) GetTimestamp 

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

func (*VersionedValue) GetVersion 

func (x *VersionedValue) GetVersion() uint64

func (*VersionedValue) ProtoMessage 

func (*VersionedValue) ProtoMessage()

func (*VersionedValue) ProtoReflect 

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.