The highest tagged major version is v2.

telem

package

v1.13.3 Latest Latest Go to latest Published: Jun 6, 2023 License: MIT Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/smartcontractkit/chainlink

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func RegisterTelemServer(s wsrpc.ServiceRegistrar, srv TelemServer)
type TelemBatchRequest
type TelemClient
- func NewTelemClient(cc wsrpc.ClientInterface) TelemClient
type TelemRequest
type TelemResponse
type TelemServer

Constants ¶

This section is empty.

Variables ¶

View Source

var File_telem_proto protoreflect.FileDescriptor

View Source

var Telem_ServiceDesc = wsrpc.ServiceDesc{
	ServiceName: "telem.Telem",
	HandlerType: (*TelemServer)(nil),
	Methods: []wsrpc.MethodDesc{
		{
			MethodName: "Telem",
			Handler:    _Telem_Telem_Handler,
		},
		{
			MethodName: "TelemBatch",
			Handler:    _Telem_TelemBatch_Handler,
		},
	},
}

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

Functions ¶

func RegisterTelemServer ¶

func RegisterTelemServer(s wsrpc.ServiceRegistrar, srv TelemServer)

Types ¶

type TelemBatchRequest ¶ added in v1.2.0

type TelemBatchRequest struct {
	ContractId    string   `protobuf:"bytes,1,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
	Telemetry     [][]byte `protobuf:"bytes,2,rep,name=telemetry,proto3" json:"telemetry,omitempty"`
	TelemetryType string   `protobuf:"bytes,3,opt,name=telemetry_type,json=telemetryType,proto3" json:"telemetry_type,omitempty"`
	SentAt        int64    `protobuf:"varint,4,opt,name=sent_at,json=sentAt,proto3" json:"sent_at,omitempty"`
	// contains filtered or unexported fields
}

func (*TelemBatchRequest) Descriptor deprecated added in v1.2.0

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

Deprecated: Use TelemBatchRequest.ProtoReflect.Descriptor instead.

func (*TelemBatchRequest) GetContractId ¶ added in v1.2.0

func (x *TelemBatchRequest) GetContractId() string

func (*TelemBatchRequest) GetSentAt ¶ added in v1.13.0

func (x *TelemBatchRequest) GetSentAt() int64

func (*TelemBatchRequest) GetTelemetry ¶ added in v1.2.0

func (x *TelemBatchRequest) GetTelemetry() [][]byte

func (*TelemBatchRequest) GetTelemetryType ¶ added in v1.13.0

func (x *TelemBatchRequest) GetTelemetryType() string

func (*TelemBatchRequest) ProtoMessage ¶ added in v1.2.0

func (*TelemBatchRequest) ProtoMessage()

func (*TelemBatchRequest) ProtoReflect ¶ added in v1.2.0

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

func (*TelemBatchRequest) Reset ¶ added in v1.2.0

func (x *TelemBatchRequest) Reset()

func (*TelemBatchRequest) String ¶ added in v1.2.0

func (x *TelemBatchRequest) String() string

type TelemClient ¶

type TelemClient interface {
	Telem(ctx context.Context, in *TelemRequest) (*TelemResponse, error)
	TelemBatch(ctx context.Context, in *TelemBatchRequest) (*TelemResponse, error)
}

TelemClient is the client API for Telem service.

func NewTelemClient ¶

func NewTelemClient(cc wsrpc.ClientInterface) TelemClient

type TelemRequest ¶

type TelemRequest struct {
	Telemetry     []byte `protobuf:"bytes,1,opt,name=telemetry,proto3" json:"telemetry,omitempty"`
	Address       string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	TelemetryType string `protobuf:"bytes,3,opt,name=telemetry_type,json=telemetryType,proto3" json:"telemetry_type,omitempty"`
	SentAt        int64  `protobuf:"varint,4,opt,name=sent_at,json=sentAt,proto3" json:"sent_at,omitempty"`
	// contains filtered or unexported fields
}

func (*TelemRequest) Descriptor deprecated

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

Deprecated: Use TelemRequest.ProtoReflect.Descriptor instead.

func (*TelemRequest) GetAddress ¶

func (x *TelemRequest) GetAddress() string

func (*TelemRequest) GetSentAt ¶ added in v1.13.0

func (x *TelemRequest) GetSentAt() int64

func (*TelemRequest) GetTelemetry ¶

func (x *TelemRequest) GetTelemetry() []byte

func (*TelemRequest) GetTelemetryType ¶ added in v1.13.0

func (x *TelemRequest) GetTelemetryType() string

func (*TelemRequest) ProtoMessage ¶

func (*TelemRequest) ProtoMessage()

func (*TelemRequest) ProtoReflect ¶

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

func (*TelemRequest) Reset ¶

func (x *TelemRequest) Reset()

func (*TelemRequest) String ¶

func (x *TelemRequest) String() string

type TelemResponse ¶

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

func (*TelemResponse) Descriptor deprecated

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

Deprecated: Use TelemResponse.ProtoReflect.Descriptor instead.

func (*TelemResponse) GetBody ¶

func (x *TelemResponse) GetBody() string

func (*TelemResponse) ProtoMessage ¶

func (*TelemResponse) ProtoMessage()

func (*TelemResponse) ProtoReflect ¶

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

func (*TelemResponse) Reset ¶

func (x *TelemResponse) Reset()

func (*TelemResponse) String ¶

func (x *TelemResponse) String() string

type TelemServer ¶

type TelemServer interface {
	Telem(context.Context, *TelemRequest) (*TelemResponse, error)
	TelemBatch(context.Context, *TelemBatchRequest) (*TelemResponse, error)
}

TelemServer is the server API for Telem service.

Source Files ¶

View all Source files

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