kafka_instance

package

v0.0.21 Latest Latest Go to latest Published: Sep 3, 2025 License: MPL-2.0 Imports: 12 Imported by: 0

Documentation ¶

Index ¶

Variables
func DataSourceByteplusKafkaInstances() *schema.Resource
func ResourceByteplusKafkaInstance() *schema.Resource
type ByteplusKafkaInstanceService
- func NewKafkaInstanceService(c *bp.SdkClient) *ByteplusKafkaInstanceService

Constants ¶

This section is empty.

Variables ¶

View Source

var TagsHash = func(v interface{}) int {
	if v == nil {
		return hashcode.String("")
	}
	m := v.(map[string]interface{})
	var (
		buf bytes.Buffer
	)
	buf.WriteString(fmt.Sprintf("%v#%v", m["key"], m["value"]))
	return hashcode.String(buf.String())
}

Functions ¶

func DataSourceByteplusKafkaInstances ¶

func DataSourceByteplusKafkaInstances() *schema.Resource

func ResourceByteplusKafkaInstance ¶

func ResourceByteplusKafkaInstance() *schema.Resource

Types ¶

type ByteplusKafkaInstanceService ¶

type ByteplusKafkaInstanceService struct {
	Client     *bp.SdkClient
	Dispatcher *bp.Dispatcher
}

func NewKafkaInstanceService ¶

func NewKafkaInstanceService(c *bp.SdkClient) *ByteplusKafkaInstanceService

func (*ByteplusKafkaInstanceService) CreateResource ¶

func (s *ByteplusKafkaInstanceService) CreateResource(resourceData *schema.ResourceData, resource *schema.Resource) []bp.Callback

func (*ByteplusKafkaInstanceService) DatasourceResources ¶

func (s *ByteplusKafkaInstanceService) DatasourceResources(*schema.ResourceData, *schema.Resource) bp.DataSourceInfo

func (*ByteplusKafkaInstanceService) GetClient ¶

func (s *ByteplusKafkaInstanceService) GetClient() *bp.SdkClient

func (*ByteplusKafkaInstanceService) ModifyResource ¶

func (s *ByteplusKafkaInstanceService) ModifyResource(resourceData *schema.ResourceData, resource *schema.Resource) []bp.Callback

func (*ByteplusKafkaInstanceService) ProjectTrn ¶

func (s *ByteplusKafkaInstanceService) ProjectTrn() *bp.ProjectTrn

func (*ByteplusKafkaInstanceService) ReadResource ¶

func (s *ByteplusKafkaInstanceService) ReadResource(resourceData *schema.ResourceData, id string) (data map[string]interface{}, err error)

func (*ByteplusKafkaInstanceService) ReadResourceId ¶

func (s *ByteplusKafkaInstanceService) ReadResourceId(id string) string

func (*ByteplusKafkaInstanceService) ReadResources ¶

func (s *ByteplusKafkaInstanceService) ReadResources(condition map[string]interface{}) (data []interface{}, err error)

func (*ByteplusKafkaInstanceService) RefreshResourceState ¶

func (s *ByteplusKafkaInstanceService) RefreshResourceState(resourceData *schema.ResourceData, target []string, timeout time.Duration, id string) *resource.StateChangeConf

func (*ByteplusKafkaInstanceService) RemoveResource ¶

func (s *ByteplusKafkaInstanceService) RemoveResource(resourceData *schema.ResourceData, r *schema.Resource) []bp.Callback

func (*ByteplusKafkaInstanceService) UnsubscribeInfo ¶

func (s *ByteplusKafkaInstanceService) UnsubscribeInfo(resourceData *schema.ResourceData, resource *schema.Resource) (*bp.UnsubscribeInfo, error)

func (ByteplusKafkaInstanceService) WithResourceResponseHandlers ¶

func (ByteplusKafkaInstanceService) WithResourceResponseHandlers(d map[string]interface{}) []bp.ResourceResponseHandler

Source Files ¶

View all Source files

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