cache

Documentation

Index

• type ACLCache
  • func (a ACLCache) Read(project, service, aclID string, client *aiven.Client) (acl aiven.KafkaACL, err error)
  • func (a ACLCache) Refresh(project, service string, client *aiven.Client) error
• type TopicCache
  • func GetTopicCache() *TopicCache
  • func NewTopicCache() *TopicCache
  • func (t *TopicCache) DeleteByProjectAndServiceName(projectName, serviceName string)
  • func (t *TopicCache) LoadByProjectAndServiceName(projectName, serviceName string) (map[string]aiven.KafkaTopic, bool)
  • func (t *TopicCache) LoadByTopicName(projectName, serviceName, topicName string) (aiven.KafkaTopic, bool)
  • func (t *TopicCache) StoreByProjectAndServiceName(projectName, serviceName string, list []*aiven.KafkaListTopic)

Types

type ACLCache

type ACLCache struct {
}

ACLCache type

func (ACLCache) Read

func (a ACLCache) Read(project, service, aclID string, client *aiven.Client) (acl aiven.KafkaACL, err error)

Read populates the cache if it doesn't exist, and reads the required acl. An aiven.Error with status 404 is returned upon cache miss

func (ACLCache) Refresh

func (a ACLCache) Refresh(project, service string, client *aiven.Client) error

Refresh refreshes the ACL cache

type TopicCache

type TopicCache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

TopicCache represents Kafka Topics cache based on Service and Project identifiers

func GetTopicCache

func GetTopicCache() *TopicCache

GetTopicCache gets a global Kafka Topics Cache

func NewTopicCache

func NewTopicCache() *TopicCache

NewTopicCache creates new global instance of Kafka Topic Cache

func (*TopicCache) DeleteByProjectAndServiceName

func (t *TopicCache) DeleteByProjectAndServiceName(projectName, serviceName string)

DeleteByProjectAndServiceName deletes the cache value for a key which is a combination of Project and Service names.

func (*TopicCache) LoadByProjectAndServiceName

func (t *TopicCache) LoadByProjectAndServiceName(projectName, serviceName string) (map[string]aiven.KafkaTopic, bool)

LoadByProjectAndServiceName returns a list of Kafka Topics stored in the cache for a given Project and Service names, or nil if no value is present. The ok result indicates whether value was found in the map.

func (*TopicCache) LoadByTopicName

func (t *TopicCache) LoadByTopicName(projectName, serviceName, topicName string) (aiven.KafkaTopic, bool)

LoadByTopicName returns a list of Kafka Topics stored in the cache for a given Project and Service names, or nil if no value is present. The ok result indicates whether value was found in the map.

func (*TopicCache) StoreByProjectAndServiceName

func (t *TopicCache) StoreByProjectAndServiceName(projectName, serviceName string, list []*aiven.KafkaListTopic)

StoreByProjectAndServiceName sets the values for a Project name and Service name key.