consul/proto/pbpeering/peering.rpcglue.pb.go

// Code generated by proto-gen-rpc-glue. DO NOT EDIT.

package pbpeering

import (
	"time"

	"github.com/hashicorp/consul/agent/structs"
)

// Reference imports to suppress errors if they are not otherwise used.
var _ structs.RPCInfo
var _ time.Month

// IsRead implements structs.RPCInfo
func (msg *PeeringReadRequest) IsRead() bool {
	// TODO(peering): figure out read semantics here
	return true
}

// AllowStaleRead implements structs.RPCInfo
func (msg *PeeringReadRequest) AllowStaleRead() bool {
	// TODO(peering): figure out read semantics here
	// TODO(peering): this needs to stay false for calls to head to the leader until we sync stream tracker information
	// like ImportedServicesCount, ExportedServicesCount, as well as general Status fields thru raft to make available
	// to followers as well
	return false
}

// HasTimedOut implements structs.RPCInfo
func (msg *PeeringReadRequest) HasTimedOut(start time.Time, rpcHoldTimeout time.Duration, a time.Duration, b time.Duration) (bool, error) {
	// TODO(peering): figure out read semantics here
	return time.Since(start) > rpcHoldTimeout, nil
}

// Timeout implements structs.RPCInfo
func (msg *PeeringReadRequest) Timeout(rpcHoldTimeout time.Duration, a time.Duration, b time.Duration) time.Duration {
	// TODO(peering): figure out read semantics here
	return rpcHoldTimeout
}

// SetTokenSecret implements structs.RPCInfo
func (msg *PeeringReadRequest) SetTokenSecret(s string) {
	// TODO(peering): figure out read semantics here
}

// TokenSecret implements structs.RPCInfo
func (msg *PeeringReadRequest) TokenSecret() string {
	// TODO(peering): figure out read semantics here
	return ""
}

// Token implements structs.RPCInfo
func (msg *PeeringReadRequest) Token() string {
	// TODO(peering): figure out read semantics here
	return ""
}

// IsRead implements structs.RPCInfo
func (msg *PeeringListRequest) IsRead() bool {
	// TODO(peering): figure out read semantics here
	return true
}

// AllowStaleRead implements structs.RPCInfo
func (msg *PeeringListRequest) AllowStaleRead() bool {
	// TODO(peering): figure out read semantics here
	// TODO(peering): this needs to stay false for calls to head to the leader until we sync stream tracker information
	// like ImportedServicesCount, ExportedServicesCount, as well as general Status fields thru raft to make available
	// to followers as well
	return false
}

// HasTimedOut implements structs.RPCInfo
func (msg *PeeringListRequest) HasTimedOut(start time.Time, rpcHoldTimeout time.Duration, a time.Duration, b time.Duration) (bool, error) {
	// TODO(peering): figure out read semantics here
	return time.Since(start) > rpcHoldTimeout, nil
}

// Timeout implements structs.RPCInfo
func (msg *PeeringListRequest) Timeout(rpcHoldTimeout time.Duration, a time.Duration, b time.Duration) time.Duration {
	// TODO(peering): figure out read semantics here
	return rpcHoldTimeout
}

// SetTokenSecret implements structs.RPCInfo
func (msg *PeeringListRequest) SetTokenSecret(s string) {
	// TODO(peering): figure out read semantics here
}

// TokenSecret implements structs.RPCInfo
func (msg *PeeringListRequest) TokenSecret() string {
	// TODO(peering): figure out read semantics here
	return ""
}

// Token implements structs.RPCInfo
func (msg *PeeringListRequest) Token() string {
	// TODO(peering): figure out read semantics here
	return ""
}